public class RowDataProjection
extends java.lang.Object
implements org.apache.flink.table.data.RowData
Modifier and Type | Method and Description |
---|---|
static RowDataProjection |
create(org.apache.flink.table.types.logical.RowType rowType,
Types.StructType schema,
Types.StructType projectedSchema)
Creates a projecting wrapper for
RowData rows. |
static RowDataProjection |
create(Schema schema,
Schema projectedSchema)
Creates a projecting wrapper for
RowData rows. |
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 kind) |
org.apache.flink.table.data.RowData |
wrap(org.apache.flink.table.data.RowData row) |
public static RowDataProjection create(Schema schema, Schema projectedSchema)
RowData
rows.
This projection will not project the nested children types of repeated types like lists and maps.
schema
- schema of rows wrapped by this projectionprojectedSchema
- result schema of the projected rowspublic static RowDataProjection create(org.apache.flink.table.types.logical.RowType rowType, Types.StructType schema, Types.StructType projectedSchema)
RowData
rows.
This projection will not project the nested children types of repeated types like lists and maps.
rowType
- flink row type of rows wrapped by this projectionschema
- schema of rows wrapped by this projectionprojectedSchema
- result schema of the projected rowspublic org.apache.flink.table.data.RowData wrap(org.apache.flink.table.data.RowData 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