Package org.apache.flink.streaming.api.operators

Interface Summary

Interface	Description
OneInputStreamOperator<IN,OUT>	Interface for stream operators with one input.
Output<T>	A StreamOperator is supplied with an object of this interface that can be used to emit elements and other messages, such as barriers and watermarks, from an operator.
OutputTypeConfigurable<OUT>	Stream operators can implement this interface if they need access to the output type information at StreamGraph generation.
StreamOperator<OUT>	Basic interface for stream operators.
TwoInputStreamOperator<IN1,IN2,OUT>	Interface for stream operators with two inputs.

Class Summary

Class	Description
AbstractStreamOperator<OUT>	Base class for all stream operators.
AbstractUdfStreamOperator<OUT,F extends Function>	This is used as the base class for operators that have a user-defined function.
StoppableStreamSource<OUT,SRC extends SourceFunction<OUT> & StoppableFunction>	StoppableStreamSource takes a SourceFunction that implements StoppableFunction.
StreamCounter<IN>
StreamFilter<IN>
StreamFlatMap<IN,OUT>
StreamGroupedFold<IN,OUT,KEY>
StreamGroupedReduce<IN>
StreamingRuntimeContext	Implementation of the RuntimeContext, for streaming operators.
StreamMap<IN,OUT>
StreamProject<IN,OUT extends Tuple>
StreamSink<IN>
StreamSource<OUT,SRC extends SourceFunction<OUT>>	StreamOperator for streaming sources.
StreamSource.AutomaticWatermarkContext<T>	SourceFunction.SourceContext to be used for sources with automatic timestamps and watermark emission.
StreamSource.ManualWatermarkContext<T>	A SourceContext for event time.
StreamSource.NonTimestampContext<T>	A source context that attached -1 as a timestamp to all records, and that does not forward watermarks.
TimestampedCollector<T>	Wrapper around an Output for user functions that expect a Collector.

Enum Summary

Enum	Description
ChainingStrategy	Defines the chaining scheme for the operator.