public class KeySelectorUtil extends Object
Constructor and Description |
---|
KeySelectorUtil() |
Modifier and Type | Method and Description |
---|---|
static BaseRowKeySelector |
getBaseRowSelector(int[] keyFields,
BaseRowTypeInfo rowType)
Create a BaseRowKeySelector to extract keys from DataStream which type is BaseRowTypeInfo.
|
public static BaseRowKeySelector getBaseRowSelector(int[] keyFields, BaseRowTypeInfo rowType)
keyFields
- key fieldsrowType
- type of DataStream to extract keysCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.