org.apache.flink.table.planner.plan.utils

Class KeySelectorUtil

java.lang.Object

org.apache.flink.table.planner.plan.utils.KeySelectorUtil

public class KeySelectorUtil
extends Object

Utility for KeySelector.

Constructor Summary

Constructors

Constructor and Description
KeySelectorUtil()

Method Summary

Modifier and Type	Method and Description
static RowDataKeySelector	getRowDataSelector(int[] keyFields, RowDataTypeInfo rowType) Create a RowDataKeySelector to extract keys from DataStream which type is RowDataTypeInfo.

Methods inherited from class java.lang.Object

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

Constructor Detail

KeySelectorUtil

public KeySelectorUtil()

Method Detail

getRowDataSelector

public static RowDataKeySelector getRowDataSelector(int[] keyFields,
                                                    RowDataTypeInfo rowType)

Create a RowDataKeySelector to extract keys from DataStream which type is RowDataTypeInfo.

Parameters:

keyFields - key fields

rowType - type of DataStream to extract keys

Returns:

the RowDataKeySelector to extract keys from DataStream which type is RowDataTypeInfo.