edu.iu.dsc.tws.tset.cdfw

Class StreamTSetCDFWEnvironment

java.lang.Object

edu.iu.dsc.tws.tset.env.TSetEnvironment

edu.iu.dsc.tws.tset.env.StreamingEnvironment

edu.iu.dsc.tws.tset.cdfw.StreamTSetCDFWEnvironment

public class StreamTSetCDFWEnvironment
extends StreamingEnvironment

Constructor Summary

Constructors

Constructor and Description
StreamTSetCDFWEnvironment(CDFWEnv env)

Method Summary

Modifier and Type	Method and Description
protected void	executeBuildContext(BuildContext buildContext) Executes data flow graph wrapped by a BuildContext

Methods inherited from class edu.iu.dsc.tws.tset.env.StreamingEnvironment

createArrowSource, createArrowSource, createCSVSource, createKeyedSource, createKeyedSource, createSource, createSource, createTextSource, getOperationMode, run

Methods inherited from class edu.iu.dsc.tws.tset.env.TSetEnvironment

addInput, close, getConfig, getDefaultParallelism, getGraph, getInputs, getNoOfWorkers, getTaskExecutor, getTSetGraph, getWorkerEnv, getWorkerID, initBatch, initCheckpointing, initStreaming, isCheckpointingEnabled, parallelize, parallelize, parallelize, parallelize, setDefaultParallelism, settBaseGraph

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamTSetCDFWEnvironment

public StreamTSetCDFWEnvironment(CDFWEnv env)

Method Detail

executeBuildContext

protected void executeBuildContext(BuildContext buildContext)

Description copied from class: TSetEnvironment

Executes data flow graph wrapped by a BuildContext

Overrides:

executeBuildContext in class TSetEnvironment

Parameters:

buildContext - data flow graph wrapped by BuildContext