public class FlinkRowData extends Object implements org.apache.flink.table.data.RowData
Constructor and Description |
---|
FlinkRowData(InternalRow row) |
Modifier and Type | Method and Description |
---|---|
int |
getArity() |
org.apache.flink.table.data.ArrayData |
getArray(int pos) |
byte[] |
getBinary(int pos) |
boolean |
getBoolean(int pos) |
byte |
getByte(int pos) |
org.apache.flink.table.data.DecimalData |
getDecimal(int pos,
int precision,
int scale) |
double |
getDouble(int pos) |
float |
getFloat(int pos) |
int |
getInt(int pos) |
long |
getLong(int pos) |
org.apache.flink.table.data.MapData |
getMap(int pos) |
<T> org.apache.flink.table.data.RawValueData<T> |
getRawValue(int pos) |
org.apache.flink.table.data.RowData |
getRow(int pos,
int numFields) |
org.apache.flink.types.RowKind |
getRowKind() |
short |
getShort(int pos) |
org.apache.flink.table.data.StringData |
getString(int pos) |
org.apache.flink.table.data.TimestampData |
getTimestamp(int pos,
int precision) |
boolean |
isNullAt(int pos) |
FlinkRowData |
replace(InternalRow row) |
void |
setRowKind(org.apache.flink.types.RowKind kind) |
static org.apache.flink.table.data.DecimalData |
toFlinkDecimal(Decimal decimal) |
static org.apache.flink.types.RowKind |
toFlinkRowKind(RowKind rowKind) |
static org.apache.flink.table.data.StringData |
toFlinkString(BinaryString str) |
static org.apache.flink.table.data.TimestampData |
toFlinkTimestamp(Timestamp timestamp) |
public FlinkRowData(InternalRow row)
public FlinkRowData replace(InternalRow row)
public int getArity()
getArity
in interface org.apache.flink.table.data.RowData
public org.apache.flink.types.RowKind getRowKind()
getRowKind
in interface org.apache.flink.table.data.RowData
public void setRowKind(org.apache.flink.types.RowKind kind)
setRowKind
in interface org.apache.flink.table.data.RowData
public boolean isNullAt(int pos)
isNullAt
in interface org.apache.flink.table.data.RowData
public boolean getBoolean(int pos)
getBoolean
in interface org.apache.flink.table.data.RowData
public byte getByte(int pos)
getByte
in interface org.apache.flink.table.data.RowData
public short getShort(int pos)
getShort
in interface org.apache.flink.table.data.RowData
public int getInt(int pos)
getInt
in interface org.apache.flink.table.data.RowData
public long getLong(int pos)
getLong
in interface org.apache.flink.table.data.RowData
public float getFloat(int pos)
getFloat
in interface org.apache.flink.table.data.RowData
public double getDouble(int pos)
getDouble
in interface org.apache.flink.table.data.RowData
public org.apache.flink.table.data.StringData getString(int pos)
getString
in interface org.apache.flink.table.data.RowData
public org.apache.flink.table.data.DecimalData getDecimal(int pos, int precision, int scale)
getDecimal
in interface org.apache.flink.table.data.RowData
public org.apache.flink.table.data.TimestampData getTimestamp(int pos, int precision)
getTimestamp
in interface org.apache.flink.table.data.RowData
public <T> org.apache.flink.table.data.RawValueData<T> getRawValue(int pos)
getRawValue
in interface org.apache.flink.table.data.RowData
public byte[] getBinary(int pos)
getBinary
in interface org.apache.flink.table.data.RowData
public org.apache.flink.table.data.ArrayData getArray(int pos)
getArray
in interface org.apache.flink.table.data.RowData
public org.apache.flink.table.data.MapData getMap(int pos)
getMap
in interface org.apache.flink.table.data.RowData
public org.apache.flink.table.data.RowData getRow(int pos, int numFields)
getRow
in interface org.apache.flink.table.data.RowData
public static org.apache.flink.table.data.StringData toFlinkString(BinaryString str)
public static org.apache.flink.table.data.TimestampData toFlinkTimestamp(Timestamp timestamp)
public static org.apache.flink.table.data.DecimalData toFlinkDecimal(Decimal decimal)
public static org.apache.flink.types.RowKind toFlinkRowKind(RowKind rowKind)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.