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 org.apache.flink.table.runtime.keyselector.RowDataKeySelector	getRowDataSelector(ClassLoader classLoader, int[] keyFields, org.apache.flink.table.runtime.typeutils.InternalTypeInfo<org.apache.flink.table.data.RowData> rowType)
static org.apache.flink.table.runtime.keyselector.RowDataKeySelector	getRowDataSelector(ClassLoader classLoader, int[] keyFields, org.apache.flink.table.runtime.typeutils.InternalTypeInfo<org.apache.flink.table.data.RowData> rowType, Class<? extends org.apache.flink.table.data.RowData> outClass) Create a RowDataKeySelector to extract keys from DataStream which type is InternalTypeInfo of RowData.

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 org.apache.flink.table.runtime.keyselector.RowDataKeySelector getRowDataSelector(ClassLoader classLoader,
                                                                                               int[] keyFields,
                                                                                               org.apache.flink.table.runtime.typeutils.InternalTypeInfo<org.apache.flink.table.data.RowData> rowType)

getRowDataSelector

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

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

Parameters:

classLoader - user ClassLoader

keyFields - key fields

rowType - type of DataStream to extract keys

Returns:

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