Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined function.
|
Input
Input interface used in MultipleInputStreamOperator . |
InternalTimer
Internal interface for in-flight timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
Output
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
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Triggerable
Interface for things that can be called by
InternalTimerService . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractStreamOperatorFactory
Base class for all stream operator factories.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
OneInputStreamOperatorFactory
A factory to create
OneInputStreamOperator . |
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamOperatorParameters
Helper class to construct
AbstractStreamOperatorV2 . |
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
StreamOperatorFactory
A factory to create
StreamOperator . |
Class and Description |
---|
StreamOperator
Basic interface for stream operators.
|
Class and Description |
---|
InternalTimerService
Interface for working with time and timers.
|
InternalTimeServiceManager
An entity keeping all the time-related services.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined function.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
ChainingStrategy
Defines the chaining scheme for the operator.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
OperatorSnapshotFutures |
Output
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
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator
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
Basic interface for stream operators.
|
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. |
Class and Description |
---|
InternalTimer
Internal interface for in-flight timers.
|
Triggerable
Interface for things that can be called by
InternalTimerService . |
Class and Description |
---|
InternalTimerService
Interface for working with time and timers.
|
Class and Description |
---|
OneInputStreamOperator
Interface for stream operators with one input.
|
OneInputStreamOperatorFactory
A factory to create
OneInputStreamOperator . |
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamSource
StreamOperator for streaming sources. |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
TwoInputStreamOperatorFactory
A factory to create
TwoInputStreamOperator . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractStreamOperatorFactory
Base class for all stream operator factories.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
OneInputStreamOperatorFactory
A factory to create
OneInputStreamOperator . |
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamOperatorParameters
Helper class to construct
AbstractStreamOperatorV2 . |
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
YieldingOperatorFactory
An operator that needs access to the
MailboxExecutor to yield to downstream operators
needs to be created through a factory implementing this interface. |
Class and Description |
---|
InternalTimeServiceManager.Provider
A provider pattern for creating an instance of a
InternalTimeServiceManager . |
SourceOperatorFactory
The Factory class for
SourceOperator . |
StreamOperator
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractStreamOperatorFactory
Base class for all stream operator factories.
|
AbstractStreamOperatorV2
New base class for all stream operators, intended to eventually replace
AbstractStreamOperator . |
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined function.
|
ChainingStrategy
Defines the chaining scheme for the operator.
|
CoordinatedOperatorFactory
A factory class for the
StreamOperator s implementing OperatorEventHandler . |
Input
Input interface used in MultipleInputStreamOperator . |
InputFormatOperatorFactory
Input format source operator factory.
|
InputSelection
Describe the input selection that stream operators want to read records.
|
InputSelection.Builder
Utility class for creating
InputSelection . |
InternalTimer
Internal interface for in-flight timers.
|
InternalTimerService
Interface for working with time and timers.
|
InternalTimersSnapshot
A snapshot of internal timers, containing event and processing timers and the serializers to use
to write / read them.
|
InternalTimersSnapshotReaderWriters.InternalTimersSnapshotReader
A reader for a
InternalTimersSnapshot . |
InternalTimersSnapshotReaderWriters.InternalTimersSnapshotWriter
A writer for a
InternalTimersSnapshot . |
InternalTimeServiceManager
An entity keeping all the time-related services.
|
InternalTimeServiceManager.Provider
A provider pattern for creating an instance of a
InternalTimeServiceManager . |
InternalTimeServiceManagerImpl
An entity keeping all the time-related services.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
OperatorSnapshotFutures |
Output
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
Interface for operator factories which create the sink operator containing an
OutputFormat . |
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator
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. |
SimpleOperatorFactory
Simple factory which just wrap existed
StreamOperator . |
StreamingRuntimeContext
Implementation of the
RuntimeContext , for streaming
operators. |
StreamOperator
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamOperatorParameters
Helper class to construct
AbstractStreamOperatorV2 . |
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 . |
StreamSink
A
StreamOperator for executing SinkFunctions . |
StreamSource
StreamOperator for streaming sources. |
StreamTaskStateInitializer
This is the interface through which stream task expose a
StreamOperatorStateContext to
their operators. |
TimerHeapInternalTimer
Implementation of
InternalTimer to use with a HeapPriorityQueueSet . |
TimerSerializer
A serializer for
TimerHeapInternalTimer objects that produces a serialization format that
is lexicographically aligned the priority of the timers. |
TimerSerializerSnapshot
Snapshot class for the
TimerSerializer . |
Triggerable
Interface for things that can be called by
InternalTimerService . |
UdfStreamOperatorFactory
Udf stream operator factory.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractStreamOperatorFactory
Base class for all stream operator factories.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined function.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
OneInputStreamOperatorFactory
A factory to create
OneInputStreamOperator . |
Output
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
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamOperatorParameters
Helper class to construct
AbstractStreamOperatorV2 . |
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
YieldingOperatorFactory
An operator that needs access to the
MailboxExecutor to yield to downstream operators
needs to be created through a factory implementing this interface. |
Class and Description |
---|
TimestampedCollector |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined function.
|
BoundedMultiInput
Interface for multi-input operators that need to be notified about the logical/semantical end of
input.
|
InputSelectable
Interface for stream operators that can select the input to get
StreamRecord . |
InputSelection
Describe the input selection that stream operators want to read records.
|
InternalTimer
Internal interface for in-flight timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
TimestampedCollector |
Triggerable
Interface for things that can be called by
InternalTimerService . |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractStreamOperatorFactory
Base class for all stream operator factories.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined function.
|
CoordinatedOperatorFactory
A factory class for the
StreamOperator s implementing OperatorEventHandler . |
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator
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. |
SimpleOperatorFactory
Simple factory which just wrap existed
StreamOperator . |
SimpleUdfStreamOperatorFactory
Udf stream operator factory which just wrap existed
AbstractUdfStreamOperator . |
StreamOperator
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamOperatorParameters
Helper class to construct
AbstractStreamOperatorV2 . |
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
StreamSink
A
StreamOperator for executing SinkFunctions . |
UdfStreamOperatorFactory
Udf stream operator factory.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedMultiInput
Interface for multi-input operators that need to be notified about the logical/semantical end of
input.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
InputSelectable
Interface for stream operators that can select the input to get
StreamRecord . |
InputSelection
Describe the input selection that stream operators want to read records.
|
InternalTimer
Internal interface for in-flight timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
TimestampedCollector |
Triggerable
Interface for things that can be called by
InternalTimerService . |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedMultiInput
Interface for multi-input operators that need to be notified about the logical/semantical end of
input.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
InputSelectable
Interface for stream operators that can select the input to get
StreamRecord . |
InputSelection
Describe the input selection that stream operators want to read records.
|
InternalTimer
Internal interface for in-flight timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Triggerable
Interface for things that can be called by
InternalTimerService . |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
TimestampedCollector |
Class and Description |
---|
InternalTimerService
Interface for working with time and timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
Class and Description |
---|
InputSelectable
Interface for stream operators that can select the input to get
StreamRecord . |
Class and Description |
---|
InternalTimerService
Interface for working with time and timers.
|
InternalTimeServiceManager
An entity keeping all the time-related services.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
Triggerable
Interface for things that can be called by
InternalTimerService . |
Class and Description |
---|
ChainingStrategy
Defines the chaining scheme for the operator.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamSink
A
StreamOperator for executing SinkFunctions . |
StreamSource
StreamOperator for streaming sources. |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
InternalTimerService
Interface for working with time and timers.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
StreamingRuntimeContext
Implementation of the
RuntimeContext , for streaming
operators. |
Class and Description |
---|
StreamingRuntimeContext
Implementation of the
RuntimeContext , for streaming
operators. |
Class and Description |
---|
BoundedMultiInput
Interface for multi-input operators that need to be notified about the logical/semantical end of
input.
|
InputSelectable
Interface for stream operators that can select the input to get
StreamRecord . |
MultipleInputStreamOperator
Interface for stream operators with multiple
Input s. |
Output
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. |
SourceOperator
Base source operator only used for integrating the source reader which is proposed by FLIP-27.
|
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
Output
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. |
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperatorFactory
Base class for all stream operator factories.
|
OneInputStreamOperatorFactory
A factory to create
OneInputStreamOperator . |
StreamOperator
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamOperatorParameters
Helper class to construct
AbstractStreamOperatorV2 . |
YieldingOperatorFactory
An operator that needs access to the
MailboxExecutor to yield to downstream operators
needs to be created through a factory implementing this interface. |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined function.
|
Input
Input interface used in MultipleInputStreamOperator . |
InternalTimer
Internal interface for in-flight timers.
|
InternalTimerService
Interface for working with time and timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
TimestampedCollector |
Triggerable
Interface for things that can be called by
InternalTimerService . |
Class and Description |
---|
BoundedMultiInput
Interface for multi-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
OperatorSnapshotFutures |
Output
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. |
SourceOperator
Base source operator only used for integrating the source reader which is proposed by FLIP-27.
|
StreamOperator
Basic interface for stream operators.
|
StreamSource
StreamOperator for streaming sources. |
StreamTaskStateInitializer
This is the interface through which stream task expose a
StreamOperatorStateContext to
their operators. |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
StreamOperator
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
Class and Description |
---|
StreamOperator
Basic interface for stream operators.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractStreamOperatorFactory
Base class for all stream operator factories.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamOperatorParameters
Helper class to construct
AbstractStreamOperatorV2 . |
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
TimestampedCollector |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractStreamOperatorFactory
Base class for all stream operator factories.
|
AbstractStreamOperatorV2
New base class for all stream operators, intended to eventually replace
AbstractStreamOperator . |
ChainingStrategy
Defines the chaining scheme for the operator.
|
CoordinatedOperatorFactory
A factory class for the
StreamOperator s implementing OperatorEventHandler . |
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
MultipleInputStreamOperator
Interface for stream operators with multiple
Input s. |
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamOperatorParameters
Helper class to construct
AbstractStreamOperatorV2 . |
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined function.
|
BoundedMultiInput
Interface for multi-input operators that need to be notified about the logical/semantical end of
input.
|
InputSelectable
Interface for stream operators that can select the input to get
StreamRecord . |
InputSelection
Describe the input selection that stream operators want to read records.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Triggerable
Interface for things that can be called by
InternalTimerService . |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
TimestampedCollector |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
InternalTimer
Internal interface for in-flight timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Triggerable
Interface for things that can be called by
InternalTimerService . |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
InternalTimer
Internal interface for in-flight timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
TimestampedCollector |
Triggerable
Interface for things that can be called by
InternalTimerService . |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractStreamOperatorFactory
Base class for all stream operator factories.
|
AbstractStreamOperatorV2
New base class for all stream operators, intended to eventually replace
AbstractStreamOperator . |
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined function.
|
BoundedMultiInput
Interface for multi-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
InputSelectable
Interface for stream operators that can select the input to get
StreamRecord . |
InputSelection
Describe the input selection that stream operators want to read records.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
MultipleInputStreamOperator
Interface for stream operators with multiple
Input s. |
OneInputStreamOperator
Interface for stream operators with one input.
|
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator
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. |
StreamMap
A
StreamOperator for executing MapFunctions . |
StreamOperator
Basic interface for stream operators.
|
StreamOperatorFactory
A factory to create
StreamOperator . |
StreamOperatorParameters
Helper class to construct
AbstractStreamOperatorV2 . |
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
Input
Input interface used in MultipleInputStreamOperator . |
InputSelection
Describe the input selection that stream operators want to read records.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
OneInputStreamOperator
Interface for stream operators with one input.
|
Output
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. |
StreamOperator
Basic interface for stream operators.
|
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
InternalTimer
Internal interface for in-flight timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Triggerable
Interface for things that can be called by
InternalTimerService . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
InternalTimer
Internal interface for in-flight timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Triggerable
Interface for things that can be called by
InternalTimerService . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined function.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
BoundedOneInput
Interface for one-input operators that need to be notified about the logical/semantical end of
input.
|
Input
Input interface used in MultipleInputStreamOperator . |
InternalTimer
Internal interface for in-flight timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Triggerable
Interface for things that can be called by
InternalTimerService . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
Input
Input interface used in MultipleInputStreamOperator . |
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
Triggerable
Interface for things that can be called by
InternalTimerService . |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
Input
Input interface used in MultipleInputStreamOperator . |
InternalTimer
Internal interface for in-flight timers.
|
InternalTimerService
Interface for working with time and timers.
|
KeyContext
Interface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
SetupableStreamOperator
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
Basic interface for stream operators.
|
StreamOperatorStateHandler.CheckpointedStreamOperator
Custom state handling hooks to be invoked by
StreamOperatorStateHandler . |
TimestampedCollector |
Triggerable
Interface for things that can be called by
InternalTimerService . |
Class and Description |
---|
Output
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. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.