public class RowDataUtils extends Object
RowData
structures.Constructor and Description |
---|
RowDataUtils() |
Modifier and Type | Method and Description |
---|---|
static long |
castToIntegral(org.apache.flink.table.data.DecimalData dec) |
static int |
compare(Object x,
Object y,
org.apache.flink.table.types.logical.LogicalTypeRoot type) |
static Object |
copy(Object o,
org.apache.flink.table.types.logical.LogicalType type) |
static org.apache.flink.table.data.ArrayData |
copyArray(org.apache.flink.table.data.ArrayData from,
org.apache.flink.table.types.logical.LogicalType eleType) |
static org.apache.flink.table.data.RowData |
copyRowData(org.apache.flink.table.data.RowData row,
org.apache.flink.table.types.logical.RowType rowType) |
static org.apache.flink.table.data.RowData.FieldGetter[] |
createFieldGetters(List<org.apache.flink.table.types.logical.LogicalType> fieldTypes) |
static org.apache.flink.table.data.RowData.FieldGetter |
createNullCheckingFieldGetter(org.apache.flink.table.types.logical.LogicalType logicalType,
int index) |
static List<String> |
fromStringArrayData(org.apache.flink.table.data.ArrayData arrayData) |
static Object |
get(org.apache.flink.table.data.ArrayData array,
int pos,
org.apache.flink.table.types.logical.LogicalType fieldType) |
static Object |
get(org.apache.flink.table.data.RowData row,
int pos,
org.apache.flink.table.types.logical.LogicalType fieldType) |
static org.apache.flink.table.data.ArrayData |
toStringArrayData(List<String> list) |
public static org.apache.flink.table.data.RowData copyRowData(org.apache.flink.table.data.RowData row, org.apache.flink.table.types.logical.RowType rowType)
public static org.apache.flink.table.data.ArrayData copyArray(org.apache.flink.table.data.ArrayData from, org.apache.flink.table.types.logical.LogicalType eleType)
public static Object get(org.apache.flink.table.data.RowData row, int pos, org.apache.flink.table.types.logical.LogicalType fieldType)
public static Object get(org.apache.flink.table.data.ArrayData array, int pos, org.apache.flink.table.types.logical.LogicalType fieldType)
public static org.apache.flink.table.data.ArrayData toStringArrayData(List<String> list)
public static List<String> fromStringArrayData(org.apache.flink.table.data.ArrayData arrayData)
public static long castToIntegral(org.apache.flink.table.data.DecimalData dec)
public static org.apache.flink.table.data.RowData.FieldGetter[] createFieldGetters(List<org.apache.flink.table.types.logical.LogicalType> fieldTypes)
public static org.apache.flink.table.data.RowData.FieldGetter createNullCheckingFieldGetter(org.apache.flink.table.types.logical.LogicalType logicalType, int index)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.