Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
CheckpointedRestoringOperator
Deprecated.
|
KeyContext
Inteface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamCheckpointedOperator
Deprecated.
|
StreamOperator
Basic interface for stream operators.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
KeyContext
Inteface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamOperator
Basic interface for stream operators.
|
TimestampedCollector |
Class and Description |
---|
InternalTimerService
Interface for working with time and timers.
|
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. |
Class and Description |
---|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamSink |
StreamSource
StreamOperator for streaming sources. |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
KeyContext
Inteface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamOperator
Basic interface for stream operators.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
CheckpointedRestoringOperator
Deprecated.
|
KeyContext
Inteface 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. |
StreamOperator
Basic interface for stream operators.
|
Class and Description |
---|
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
Class and Description |
---|
StreamOperator
Basic interface for stream operators.
|
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractStreamOperator.LatencyGauge
The gauge uses a HashMap internally to avoid classloading issues when accessing
the values using JMX.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined
function.
|
ChainingStrategy
Defines the chaining scheme for the operator.
|
CheckpointedRestoringOperator
Deprecated.
|
InternalTimer
Internal class for keeping track of in-flight timers.
|
InternalTimerService
Interface for working with time and timers.
|
KeyContext
Inteface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
OperatorSnapshotResult |
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. |
StreamCheckpointedOperator
Deprecated.
|
StreamingRuntimeContext
Implementation of the
RuntimeContext ,
for streaming operators. |
StreamOperator
Basic interface for stream operators.
|
StreamSource
StreamOperator for streaming sources. |
Triggerable
Interface for things that can be called by
InternalTimerService . |
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.
|
CheckpointedRestoringOperator
Deprecated.
|
KeyContext
Inteface 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. |
StreamCheckpointedOperator
Deprecated.
|
StreamOperator
Basic interface for stream operators.
|
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.
|
CheckpointedRestoringOperator
Deprecated.
|
InternalTimer
Internal class for keeping track of in-flight timers.
|
KeyContext
Inteface 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. |
StreamCheckpointedOperator
Deprecated.
|
StreamOperator
Basic interface for stream operators.
|
TimestampedCollector |
Triggerable
Interface for things that can be called by
InternalTimerService . |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
ChainingStrategy
Defines the chaining scheme for the operator.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamSink |
StreamSource
StreamOperator for streaming sources. |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
KeyContext
Inteface for setting and querying the current key of keyed operations.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamOperator
Basic interface for stream operators.
|
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.
|
CheckpointedRestoringOperator
Deprecated.
|
KeyContext
Inteface 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. |
StreamCheckpointedOperator
Deprecated.
|
StreamingRuntimeContext
Implementation of the
RuntimeContext ,
for streaming operators. |
StreamOperator
Basic interface for stream operators.
|
StreamSink |
Class and Description |
---|
StreamingRuntimeContext
Implementation of the
RuntimeContext ,
for streaming operators. |
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. |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
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.
|
CheckpointedRestoringOperator
Deprecated.
|
KeyContext
Inteface 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. |
StreamCheckpointedOperator
Deprecated.
|
StreamOperator
Basic interface for stream operators.
|
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.
|
CheckpointedRestoringOperator
Deprecated.
|
InternalTimer
Internal class for keeping track of in-flight timers.
|
InternalTimerService
Interface for working with time and timers.
|
KeyContext
Inteface 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. |
StreamCheckpointedOperator
Deprecated.
|
StreamOperator
Basic interface for stream operators.
|
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. |
StreamOperator
Basic interface for stream operators.
|
StreamSource
StreamOperator for streaming sources. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.