@Internal
public class StructRowData
extends java.lang.Object
implements org.apache.flink.table.data.RowData
Constructor and Description |
---|
StructRowData(Types.StructType type) |
StructRowData(Types.StructType type,
org.apache.flink.types.RowKind kind) |
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) |
void |
setRowKind(org.apache.flink.types.RowKind newKind) |
StructRowData |
setStruct(StructLike newStruct) |
public StructRowData(Types.StructType type)
public StructRowData(Types.StructType type, org.apache.flink.types.RowKind kind)
public StructRowData setStruct(StructLike newStruct)
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 newKind)
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