Package org.apache.flink.table.runtime.operators.join.stream.bundle
-
Class Summary Class Description BufferBundle<T> ABufferBundleis a bundle to buffer the input records in memory and fold data based on specified pattern to reduce state access.InputSideHasNoUniqueKeyBundle For the case that input has no uniqueKey.InputSideHasUniqueKeyBundle For the case that input has uniqueKey which is not contained by joinKey.JoinKeyContainsUniqueKeyBundle For the case that input has joinKey contains uniqueKey.