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, runOne
addInput, close, getConfig, getDefaultParallelism, getGraph, getInputs, getNoOfWorkers, getTaskExecutor, getTSetGraph, getWorkerEnv, getWorkerID, initBatch, initCheckpointing, initStreaming, isCheckpointingEnabled, parallelize, parallelize, parallelize, parallelize, setDefaultParallelism, settBaseGraph
public BatchTSetCDFWEnvironment(CDFWEnv env)
protected void executeBuildContext(BuildContext buildContext)
TSetEnvironment
BuildContext
executeBuildContext
in class TSetEnvironment
buildContext
- data flow graph wrapped by BuildContext