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

类 KeySelectorUtil

java.lang.Object

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

public class KeySelectorUtil
extends Object

Utility for KeySelector.

构造器概要

构造器

构造器和说明
KeySelectorUtil()

方法概要

限定符和类型	方法和说明
static org.apache.flink.table.runtime.keyselector.RowDataKeySelector	getRowDataSelector(int[] keyFields, org.apache.flink.table.runtime.typeutils.InternalTypeInfo<org.apache.flink.table.data.RowData> rowType) Create a RowDataKeySelector to extract keys from DataStream which type is InternalTypeInfo of RowData.

从类继承的方法 java.lang.Object

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

构造器详细资料

KeySelectorUtil

public KeySelectorUtil()

方法详细资料

getRowDataSelector

public static org.apache.flink.table.runtime.keyselector.RowDataKeySelector getRowDataSelector(int[] keyFields,
                                                                                               org.apache.flink.table.runtime.typeutils.InternalTypeInfo<org.apache.flink.table.data.RowData> rowType)

Create a RowDataKeySelector to extract keys from DataStream which type is InternalTypeInfo of RowData.

参数:

keyFields - key fields

rowType - type of DataStream to extract keys

返回:

the RowDataKeySelector to extract keys from DataStream which type is InternalTypeInfo of RowData.