Interface | Description |
---|---|
CheckpointedRestoringOperator | Deprecated |
InternalTimerService<N> |
Interface for working with time and timers.
|
KeyContext |
Inteface for setting and querying the current key of keyed operations.
|
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. |
StreamCheckpointedOperator | Deprecated |
StreamOperator<OUT> |
Basic interface for stream operators.
|
Triggerable<K,N> |
Interface for things that can be called by
InternalTimerService . |
TwoInputStreamOperator<IN1,IN2,OUT> |
Interface for stream operators with two inputs.
|
Class | Description |
---|---|
AbstractStreamOperator<OUT> |
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<OUT,F extends Function> |
This is used as the base class for operators that have a user-defined
function.
|
HeapInternalTimerService<K,N> |
InternalTimerService that stores timers on the Java heap. |
InternalTimer<K,N> |
Internal class for keeping track of in-flight timers.
|
InternalTimer.TimerSerializer<K,N> |
A
TypeSerializer used to serialize/deserialize a InternalTimer . |
OperatorSnapshotResult | |
ProcessOperator<K,IN,OUT> | |
StoppableStreamSource<OUT,SRC extends SourceFunction<OUT> & StoppableFunction> | |
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. |
StreamSourceContexts |
Source contexts for various stream time characteristics.
|
TimestampedCollector<T> |
Enum | Description |
---|---|
ChainingStrategy |
Defines the chaining scheme for the operator.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.