Package org.apache.flink.table.runtime.operators.join.stream.bundle

Class InputSideHasUniqueKeyBundle

java.lang.Object

org.apache.flink.table.runtime.operators.join.stream.bundle.BufferBundle<Map<RowData,List<RowData>>>

org.apache.flink.table.runtime.operators.join.stream.bundle.InputSideHasUniqueKeyBundle

public class InputSideHasUniqueKeyBundle
extends BufferBundle<Map<RowData,List<RowData>>>

For the case that input has uniqueKey which is not contained by joinKey.

Field Summary

Fields inherited from class org.apache.flink.table.runtime.operators.join.stream.bundle.BufferBundle

actualSize, bundle, count

Constructor Summary

Constructors

Constructor	Description
InputSideHasUniqueKeyBundle()

Method Summary

Modifier and Type	Method	Description
int	addRecord(RowData joinKey, RowData uniqueKey, RowData record)	Adds a record into the bufferBundle when processing element in a stream and this function would return the size of the bufferBundle.
Set<RowData>	getJoinKeys()	Get the joinKeys in bufferBundle.
Map<RowData,List<RowData>>	getRecords()	Get records associated with joinKeys from bufferBundle.
Map<RowData,List<RowData>>	getRecordsWithJoinKey(RowData joinKey)	Get records associated with joinKeys from bufferBundle.

Methods inherited from class org.apache.flink.table.runtime.operators.join.stream.bundle.BufferBundle

clear, isEmpty, reducedSize

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InputSideHasUniqueKeyBundle

public InputSideHasUniqueKeyBundle()

Method Detail

addRecord

public int addRecord(RowData joinKey,
                     RowData uniqueKey,
                     RowData record)

Description copied from class: BufferBundle

Adds a record into the bufferBundle when processing element in a stream and this function would return the size of the bufferBundle.

Specified by:

addRecord in class BufferBundle<Map<RowData,List<RowData>>>

Parameters:

joinKey - the joinKey associated with the record.

uniqueKey - the uniqueKey associated with the record. This could be null.

record - The record to add.

Returns:

number of processed by current bundle.

getRecords

public Map<RowData,List<RowData>> getRecords()

Description copied from class: BufferBundle

Get records associated with joinKeys from bufferBundle.

Specified by:

getRecords in class BufferBundle<Map<RowData,List<RowData>>>

Returns:

a map whose key is joinKey and value is list of records.

getJoinKeys

public Set<RowData> getJoinKeys()

Description copied from class: BufferBundle

Get the joinKeys in bufferBundle. Whether to override this method is based on the implementing class.

Overrides:

getJoinKeys in class BufferBundle<Map<RowData,List<RowData>>>

getRecordsWithJoinKey

public Map<RowData,List<RowData>> getRecordsWithJoinKey(RowData joinKey)

Description copied from class: BufferBundle

Get records associated with joinKeys from bufferBundle. And this function is different from getRecords() above where getRecords() returns a map whose key is joinKey and value is list of records.

Specified by:

getRecordsWithJoinKey in class BufferBundle<Map<RowData,List<RowData>>>

Parameters:

joinKey - one of joinKeys stored in this bundle.

Returns:

a map whose key is uniqueKey and value is a list of records.