public class RowDataUtil
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.table.data.RowData |
clone(org.apache.flink.table.data.RowData from,
org.apache.flink.table.data.RowData reuse,
org.apache.flink.table.types.logical.RowType rowType,
org.apache.flink.api.common.typeutils.TypeSerializer[] fieldSerializers)
Similar to the private
RowDataSerializer.copyRowData(RowData, RowData) method. |
static java.lang.Object |
convertConstant(Type type,
java.lang.Object value) |
public static java.lang.Object convertConstant(Type type, java.lang.Object value)
public static org.apache.flink.table.data.RowData clone(org.apache.flink.table.data.RowData from, org.apache.flink.table.data.RowData reuse, org.apache.flink.table.types.logical.RowType rowType, org.apache.flink.api.common.typeutils.TypeSerializer[] fieldSerializers)
RowDataSerializer.copyRowData(RowData, RowData)
method. This
skips the check the arity of rowType and from, because the from RowData may contains additional
column for position deletes. Using RowDataSerializer.copy(RowData, RowData)
will fail
the arity check.