public class SourceTaskDataLoader extends TaskWorker
| Modifier and Type | Class and Description |
|---|---|
class |
SourceTaskDataLoader.SimpleDataAggregator |
computeEnvironment, config, persistentVolume, taskExecutor, volatileVolume, workerController, workerEnvironment, workerId| Constructor and Description |
|---|
SourceTaskDataLoader() |
| Modifier and Type | Method and Description |
|---|---|
void |
execute()
A user needs to implement this method to create the task graph and execute it
|
void |
getParams() |
executepublic void execute()
TaskWorkerexecute in class TaskWorkerpublic void getParams()