public class BatchTSetCDFWEnvironment extends BatchEnvironment
| Constructor and Description |
|---|
BatchTSetCDFWEnvironment(CDFWEnv env) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
executeBuildContext(BuildContext buildContext)
Executes data flow graph wrapped by a
BuildContext |
createArrowSource, createArrowSource, createCSVSource, createHadoopSource, createHadoopSource, createKeyedHadoopSource, createKeyedSource, createKeyedSource, createRowSource, createSource, createSource, createTextSource, eval, evalAndUpdate, finishEval, getData, getOperationMode, run, runAndUpdate, runOneaddInput, close, getConfig, getDefaultParallelism, getGraph, getInputs, getNoOfWorkers, getTaskExecutor, getTSetGraph, getWorkerEnv, getWorkerID, initBatch, initCheckpointing, initStreaming, isCheckpointingEnabled, parallelize, parallelize, parallelize, parallelize, setDefaultParallelism, settBaseGraphpublic BatchTSetCDFWEnvironment(CDFWEnv env)
protected void executeBuildContext(BuildContext buildContext)
TSetEnvironmentBuildContextexecuteBuildContext in class TSetEnvironmentbuildContext - data flow graph wrapped by BuildContext