Package | Description |
---|---|
org.apache.flink.streaming.api.operators.co | |
org.apache.flink.table.runtime.operators.join |
Class and Description |
---|
CoBroadcastWithKeyedOperator
A
TwoInputStreamOperator for executing KeyedBroadcastProcessFunctions . |
CoBroadcastWithNonKeyedOperator
A
TwoInputStreamOperator for executing BroadcastProcessFunctions . |
IntervalJoinOperator.BufferEntry
A container for elements put in the left/write buffer.
|
IntervalJoinOperator.BufferEntrySerializer
A
serializer for the IntervalJoinOperator.BufferEntry . |
Class and Description |
---|
KeyedCoProcessOperator
A
StreamOperator for executing keyed KeyedCoProcessFunction . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.