Interface | Description |
---|---|
BoundedMultiInput |
Interface for the multi-input operators that can process EndOfInput event.
|
BoundedOneInput |
Interface for the one-input operators that can process EndOfInput event.
|
CoordinatedOperatorFactory<OUT> |
A factory class for the
StreamOperator s implementing OperatorEventHandler . |
Input<IN> |
Input interface used in MultipleInputStreamOperator . |
InputFormatOperatorFactory<OUT> |
Input format source operator factory.
|
InputSelectable |
Interface for stream operators that can select the input to get
StreamRecord . |
InternalTimer<K,N> |
Internal interface for in-flight timers.
|
InternalTimerService<N> |
Interface for working with time and timers.
|
InternalTimersSnapshotReaderWriters.InternalTimersSnapshotReader<K,N> |
A reader for a
InternalTimersSnapshot . |
InternalTimersSnapshotReaderWriters.InternalTimersSnapshotWriter |
A writer for a
InternalTimersSnapshot . |
KeyContext |
Inteface for setting and querying the current key of keyed operations.
|
MailboxExecutor |
Executor like interface for an build around a mailbox-based
execution model (see TaskMailbox ). |
MultipleInputStreamOperator<OUT> |
Interface for stream operators with multiple
Input s. |
OneInputStreamOperator<IN,OUT> |
Interface for stream operators with one input.
|
OneInputStreamOperatorFactory<IN,OUT> |
A factory to create
OneInputStreamOperator . |
OnWatermarkCallback<KEY> |
A callback registered with the
InternalWatermarkCallbackService service. |
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. |
OutputFormatOperatorFactory<IN> |
Interface for operator factories which create the sink operator containing an
OutputFormat . |
OutputTypeConfigurable<OUT> |
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator<OUT> | Deprecated
This class is deprecated in favour of using
StreamOperatorFactory and it's
StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>) and passing the required parameters to the
Operator's constructor in create method. |
StreamOperator<OUT> |
Basic interface for stream operators.
|
StreamOperatorFactory<OUT> |
A factory to create
StreamOperator . |
StreamOperatorStateContext |
This interface represents a context from which a stream operator can initialize everything
connected to state such as e.g.
|
StreamOperatorStateHandler.CheckpointedStreamOperator |
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
StreamTaskStateInitializer |
This is the interface through which stream task expose a
StreamOperatorStateContext to
their operators. |
Triggerable<K,N> |
Interface for things that can be called by
InternalTimerService . |
TwoInputStreamOperator<IN1,IN2,OUT> |
Interface for stream operators with two inputs.
|
UdfStreamOperatorFactory<OUT> |
Udf stream operator factory.
|
YieldingOperatorFactory<OUT> |
An operator that needs access to the
MailboxExecutor to yield to downstream operators
needs to be created through a factory implementing this interface. |
Class | Description |
---|---|
AbstractInput<IN,OUT> |
Base abstract implementation of
Input interface intended to be used when extending AbstractStreamOperatorV2 . |
AbstractStreamOperator<OUT> |
Base class for all stream operators.
|
AbstractStreamOperatorFactory<OUT> |
Base class for all stream operator factories.
|
AbstractStreamOperatorV2<OUT> |
New base class for all stream operators, intended to eventually replace
AbstractStreamOperator . |
AbstractUdfStreamOperator<OUT,F extends Function> |
This is used as the base class for operators that have a user-defined function.
|
BackendRestorerProcedure<T extends Closeable & Disposable,S extends StateObject> |
This class implements the logic that creates (and potentially restores) a state backend.
|
CountingOutput<OUT> |
Wrapping
Output that updates metrics on the number of emitted elements. |
InputSelection |
Describe the input selection that stream operators want to read records.
|
InputSelection.Builder |
Utility class for creating
InputSelection . |
InternalTimerServiceImpl<K,N> |
InternalTimerService that stores timers on the Java heap. |
InternalTimerServiceSerializationProxy<K> |
Serialization proxy for the timer services for a given key-group.
|
InternalTimersSnapshot<K,N> |
A snapshot of internal timers, containing event and processing timers and the serializers to use
to write / read them.
|
InternalTimersSnapshotReaderWriters |
Readers and writers for different versions of the
InternalTimersSnapshot . |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer<K,N> |
A
TypeSerializer used to serialize/deserialize a TimerHeapInternalTimer . |
InternalTimeServiceManager<K> |
An entity keeping all the time-related services available to all operators extending the
AbstractStreamOperator . |
KeyedProcessOperator<K,IN,OUT> |
A
StreamOperator for executing KeyedProcessFunctions . |
LegacyKeyedProcessOperator<K,IN,OUT> | Deprecated
Replaced by
KeyedProcessOperator which takes KeyedProcessFunction |
OperatorSnapshotFinalizer |
This class finalizes
OperatorSnapshotFutures . |
OperatorSnapshotFutures | |
ProcessOperator<IN,OUT> |
A
StreamOperator for executing ProcessFunctions . |
SimpleInputFormatOperatorFactory<OUT> |
Input format source operator factory which just wrap existed
StreamSource . |
SimpleOperatorFactory<OUT> |
Simple factory which just wrap existed
StreamOperator . |
SimpleOutputFormatOperatorFactory<IN> |
A simple operator factory which create
StreamSink containing an OutputFormat . |
SimpleUdfStreamOperatorFactory<OUT> |
Udf stream operator factory which just wrap existed
AbstractUdfStreamOperator . |
SourceOperator<OUT,SplitT extends SourceSplit> |
Base source operator only used for integrating the source reader which is proposed by FLIP-27.
|
SourceOperatorFactory<OUT> |
The Factory class for
SourceOperator . |
StreamFilter<IN> |
A
StreamOperator for executing FilterFunctions . |
StreamFlatMap<IN,OUT> |
A
StreamOperator for executing FlatMapFunctions . |
StreamGroupedFold<IN,OUT,KEY> | Deprecated
will be removed in a future version
|
StreamGroupedReduce<IN> | |
StreamingRuntimeContext |
Implementation of the
RuntimeContext , for streaming
operators. |
StreamMap<IN,OUT> |
A
StreamOperator for executing MapFunctions . |
StreamOperatorFactoryUtil |
A utility to instantiate new operators with a given factory.
|
StreamOperatorParameters<OUT> |
Helper class to construct
AbstractStreamOperatorV2 . |
StreamOperatorStateHandler |
Class encapsulating various state backend handling logic for
StreamOperator
implementations. |
StreamProject<IN,OUT extends Tuple> |
A
StreamOperator for executing projections on streams. |
StreamSink<IN> |
A
StreamOperator for executing SinkFunctions . |
StreamSource<OUT,SRC extends SourceFunction<OUT>> |
StreamOperator for streaming sources. |
StreamSourceContexts |
Source contexts for various stream time characteristics.
|
StreamTaskStateInitializerImpl |
This class is the main implementation of a
StreamTaskStateInitializer . |
TimerHeapInternalTimer<K,N> |
Implementation of
InternalTimer to use with a HeapPriorityQueueSet . |
TimerSerializer<K,N> |
A serializer for
TimerHeapInternalTimer objects that produces a serialization format that
is lexicographically aligned the priority of the timers. |
TimerSerializer.TimerSerializerConfigSnapshot<K,N> | Deprecated
this snapshot class is no longer in use, and is maintained only for backwards
compatibility purposes.
|
TimerSerializerSnapshot<K,N> |
Snapshot class for the
TimerSerializer . |
TimestampedCollector<T> |
Enum | Description |
---|---|
ChainingStrategy |
Defines the chaining scheme for the operator.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.