Package org.apache.iceberg.flink.data
Class RowDataProjection
- java.lang.Object
-
- org.apache.iceberg.flink.data.RowDataProjection
-
- All Implemented Interfaces:
org.apache.flink.table.data.RowData
public class RowDataProjection extends java.lang.Object implements org.apache.flink.table.data.RowData
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static RowDataProjection
create(org.apache.flink.table.types.logical.RowType rowType, Types.StructType schema, Types.StructType projectedSchema)
Creates a projecting wrapper forRowData
rows.static RowDataProjection
create(Schema schema, Schema projectedSchema)
Creates a projecting wrapper forRowData
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)
-
-
-
Method Detail
-
create
public static RowDataProjection create(Schema schema, Schema projectedSchema)
Creates a projecting wrapper forRowData
rows.This projection will not project the nested children types of repeated types like lists and maps.
- Parameters:
schema
- schema of rows wrapped by this projectionprojectedSchema
- result schema of the projected rows- Returns:
- a wrapper to project rows
-
create
public static RowDataProjection create(org.apache.flink.table.types.logical.RowType rowType, Types.StructType schema, Types.StructType projectedSchema)
Creates a projecting wrapper forRowData
rows.This projection will not project the nested children types of repeated types like lists and maps.
- Parameters:
rowType
- flink row type of rows wrapped by this projectionschema
- schema of rows wrapped by this projectionprojectedSchema
- result schema of the projected rows- Returns:
- a wrapper to project rows
-
wrap
public org.apache.flink.table.data.RowData wrap(org.apache.flink.table.data.RowData row)
-
getArity
public int getArity()
- Specified by:
getArity
in interfaceorg.apache.flink.table.data.RowData
-
getRowKind
public org.apache.flink.types.RowKind getRowKind()
- Specified by:
getRowKind
in interfaceorg.apache.flink.table.data.RowData
-
setRowKind
public void setRowKind(org.apache.flink.types.RowKind kind)
- Specified by:
setRowKind
in interfaceorg.apache.flink.table.data.RowData
-
isNullAt
public boolean isNullAt(int pos)
- Specified by:
isNullAt
in interfaceorg.apache.flink.table.data.RowData
-
getBoolean
public boolean getBoolean(int pos)
- Specified by:
getBoolean
in interfaceorg.apache.flink.table.data.RowData
-
getByte
public byte getByte(int pos)
- Specified by:
getByte
in interfaceorg.apache.flink.table.data.RowData
-
getShort
public short getShort(int pos)
- Specified by:
getShort
in interfaceorg.apache.flink.table.data.RowData
-
getInt
public int getInt(int pos)
- Specified by:
getInt
in interfaceorg.apache.flink.table.data.RowData
-
getLong
public long getLong(int pos)
- Specified by:
getLong
in interfaceorg.apache.flink.table.data.RowData
-
getFloat
public float getFloat(int pos)
- Specified by:
getFloat
in interfaceorg.apache.flink.table.data.RowData
-
getDouble
public double getDouble(int pos)
- Specified by:
getDouble
in interfaceorg.apache.flink.table.data.RowData
-
getString
public org.apache.flink.table.data.StringData getString(int pos)
- Specified by:
getString
in interfaceorg.apache.flink.table.data.RowData
-
getDecimal
public org.apache.flink.table.data.DecimalData getDecimal(int pos, int precision, int scale)
- Specified by:
getDecimal
in interfaceorg.apache.flink.table.data.RowData
-
getTimestamp
public org.apache.flink.table.data.TimestampData getTimestamp(int pos, int precision)
- Specified by:
getTimestamp
in interfaceorg.apache.flink.table.data.RowData
-
getRawValue
public <T> org.apache.flink.table.data.RawValueData<T> getRawValue(int pos)
- Specified by:
getRawValue
in interfaceorg.apache.flink.table.data.RowData
-
getBinary
public byte[] getBinary(int pos)
- Specified by:
getBinary
in interfaceorg.apache.flink.table.data.RowData
-
getArray
public org.apache.flink.table.data.ArrayData getArray(int pos)
- Specified by:
getArray
in interfaceorg.apache.flink.table.data.RowData
-
getMap
public org.apache.flink.table.data.MapData getMap(int pos)
- Specified by:
getMap
in interfaceorg.apache.flink.table.data.RowData
-
getRow
public org.apache.flink.table.data.RowData getRow(int pos, int numFields)
- Specified by:
getRow
in interfaceorg.apache.flink.table.data.RowData
-
-