All Classes

Class	Description
ApplyPartitionFunction<OUT>	A function to be applied to all partitions .
BroadcastStream<T>	This interface represents a stream that each parallel task processes the same data.
Collector<OUT>	This class take response for collecting data to output stream.
DataStream	This is the topmost base interface of all streams of DataStream V2 API.
ExecutionEnvironment	This is the context in which a program is executed.
GlobalStream<T>	This interface represents a stream that force single parallelism.
GlobalStream.ProcessConfigurableAndGlobalStream<T>	This interface represents a configurable GlobalStream.
GlobalStream.TwoGlobalStreams<T1,T2>	This class represents a combination of two GlobalStream.
JobInfo	JobInfo contains all the meta information of the job.
JobInfo.ExecutionMode	Execution mode of this current job.
KeyedPartitionStream<K,T>	This interface represents a kind of partitioned data stream.
KeyedPartitionStream.ProcessConfigurableAndKeyedPartitionStream<K,T>	This interface represents a configurable KeyedPartitionStream.
KeyedPartitionStream.TwoKeyedPartitionStreams<K,T1,T2>	This class represents a combination of two KeyedPartitionStream.
NonKeyedPartitionStream<T>	This interface represents a kind of partitioned data stream.
NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<T>	This interface represents a configurable NonKeyedPartitionStream.
NonKeyedPartitionStream.TwoNonKeyedPartitionStreams<T1,T2>	This interface represents a combination of two NonKeyedPartitionStream.
NonPartitionedContext<OUT>	This interface represents the context associated with all operations must be applied to all partitions.
OneInputStreamProcessFunction<IN,OUT>	This contains all logical related to process records from single input.
PartitionedContext	On the base of RuntimeContext, PartitionedContext also contains all partition-wise execution information, such as getting state, registering timer, etc.
ProcessConfigurable<T extends ProcessConfigurable<T>>	This represents the configuration handle of processing.
ProcessFunction	Base class for all user defined process functions.
ProcessingTimeManager	This is responsibility for managing runtime information related to processing time of process function.
RuntimeContext	A RuntimeContext contains information about the context in which process functions are executed.
StateManager	This is responsibility for managing runtime information related to state of process function.
TaskInfo	TaskInfo contains all the meta information of the task.
TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT>	This contains all logical related to process records from a broadcast stream and a non-broadcast stream.
TwoInputNonBroadcastStreamProcessFunction<IN1,IN2,OUT>	This contains all logical related to process records from two non-broadcast input.
TwoOutputApplyPartitionFunction<OUT1,OUT2>	A function to be applied to all partitions with two outputs.
TwoOutputNonPartitionedContext<OUT1,OUT2>	This interface represents the context associated with all operations must be applied to all partitions with two outputs.
TwoOutputStreamProcessFunction<IN,OUT1,OUT2>	This contains all logical related to process and emit records to two output streams.