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 . |
KeyedCoProcessOperator<K,IN1,IN2,OUT> |
A
StreamOperator for executing keyed
CoProcessFunctions . |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.