public class KeySelectorUtil extends Object
Constructor and Description |
---|
KeySelectorUtil() |
Modifier and Type | Method and Description |
---|---|
static RowDataKeySelector |
getRowDataSelector(int[] keyFields,
InternalTypeInfo<RowData> rowType)
Create a RowDataKeySelector to extract keys from DataStream which type is
InternalTypeInfo of RowData . |
public static RowDataKeySelector getRowDataSelector(int[] keyFields, InternalTypeInfo<RowData> rowType)
InternalTypeInfo
of RowData
.keyFields
- key fieldsrowType
- type of DataStream to extract keysInternalTypeInfo
of RowData
.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.