| Class | Description |
|---|---|
| CoBroadcastWithKeyedOperator<KS,IN1,IN2,OUT> |
A
TwoInputStreamOperator for executing KeyedBroadcastProcessFunctions. |
| CoBroadcastWithNonKeyedOperator<IN1,IN2,OUT> |
A
TwoInputStreamOperator for executing BroadcastProcessFunctions. |
| CoProcessOperator<IN1,IN2,OUT> |
A
StreamOperator for executing
CoProcessFunctions. |
| CoStreamFlatMap<IN1,IN2,OUT> |
StreamOperator for processing
CoFlatMapFunctions. |
| CoStreamMap<IN1,IN2,OUT> |
StreamOperator for processing
CoMapFunctions. |
| IntervalJoinOperator<K,T1,T2,OUT> |
An
operator to execute time-bounded stream inner joins. |
| IntervalJoinOperator.BufferEntrySerializerSnapshot<T> |
A
TypeSerializerSnapshot for BufferEntrySerializer. |
| IntervalJoinOperator.BufferSerializerConfigSnapshot<T> | Deprecated
this snapshot class is no longer in use, and is maintained only for backwards compatibility.
|
| KeyedCoProcessOperator<K,IN1,IN2,OUT> |
A
StreamOperator for executing keyed
CoProcessFunctions. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.