Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamOperator
Basic interface for stream operators.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamOperator
Basic interface for stream operators.
|
TimestampedCollector |
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.
|
AsyncExceptionChecker
An interface used by sources that may throw exceptions
asynchronously like the
StreamSource . |
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.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined
function.
|
AsyncExceptionChecker
An interface used by sources that may throw exceptions
asynchronously like the
StreamSource . |
ChainingStrategy
Defines the chaining scheme for the operator.
|
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. |
StreamingRuntimeContext
Implementation of the
RuntimeContext ,
for streaming operators. |
StreamOperator
Basic interface for stream operators.
|
StreamSource
StreamOperator for streaming sources. |
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.
|
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.
|
TimestampedCollector |
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.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamOperator
Basic interface for stream operators.
|
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 |
---|
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.
|
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 |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined
function.
|
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.
|
TimestampedCollector |
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 |
---|
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.