public final class TaskRecorder
extends Object
Modifier and Type | Field and Description |
---|---|
static String |
RUNNING_TASK_KEY_PREFIX |
Modifier and Type | Method and Description |
---|---|
List<RunningEtlTask> |
getRunningTasks(String requestId)
Get the running tasks for the given requestId.
|
List<RunningEtlTask> |
getRunningTasksForAccount(String tenant)
Get all running tasks for the account.
|
int |
getTaskCount(String tenant)
Gets the task count.
|
static TaskRecorder |
instance()
Returns TaskRecorder instance.
|
boolean |
isCodeRecordingEnabled()
Checks if code recording is enabled.
|
boolean |
isEnabled()
Checks if recording is enabled.
|
boolean |
isExtractRecordingEnabled()
Checks if extract recording is enabled.
|
boolean |
isHwmRecordingEnabled()
Checks if HWM recording is enabled.
|
void |
recordFinishExtract(Source source)
Record event when the extract has finished running.
|
void |
recordFinishHwmQuery(Destination destination)
Record event when the HWM query has finished running.
|
void |
recordFinishLoad(Destination destination)
Record event when the HWM query has finished running.
|
void |
recordFinishTask(Task task)
Record event when the task has finished running.
|
void |
recordStartExtract(Source source,
String code)
Record event when the extract has started.
|
void |
recordStartHwmQuery(Destination destination,
String code)
Record event when the HWM query has started.
|
void |
recordStartLoad(Destination destination)
Record event when the load has started.
|
void |
recordStartTask(Task task,
String code)
Record event when the task has started.
|
public static final String RUNNING_TASK_KEY_PREFIX
public static TaskRecorder instance()
public void recordStartTask(Task task, String code)
task
- the taskcode
- the codepublic void recordFinishTask(Task task)
task
- the taskpublic void recordStartExtract(Source source, String code)
source
- the sourcecode
- the codepublic void recordFinishExtract(Source source)
source
- the sourcepublic void recordStartHwmQuery(Destination destination, String code)
destination
- the destinationcode
- the codepublic void recordFinishHwmQuery(Destination destination)
destination
- the destinationpublic void recordStartLoad(Destination destination)
destination
- the destinationpublic void recordFinishLoad(Destination destination)
destination
- the destinationpublic List<RunningEtlTask> getRunningTasks(String requestId)
requestId
- the request idpublic List<RunningEtlTask> getRunningTasksForAccount(String tenant)
tenant
- the tenantpublic int getTaskCount(String tenant)
tenant
- the tenantpublic boolean isEnabled()
public boolean isExtractRecordingEnabled()
public boolean isCodeRecordingEnabled()
public boolean isHwmRecordingEnabled()
Copyright © 2010-2020 Toolsverse. All Rights Reserved.