org.apache.flink.table.dataformat

Class ObjectArrayRow

java.lang.Object

org.apache.flink.table.dataformat.ObjectArrayRow

All Implemented Interfaces:

BaseRow, TypeGetterSetters

Direct Known Subclasses:

BoxedWrapperRow, GenericRow

public abstract class ObjectArrayRow
extends Object
implements BaseRow

An row implementation that uses an array of objects as the underlying storage.

Field Summary

Fields

Modifier and Type	Field and Description
protected Object[]	fields

Constructor Summary

Constructors

Constructor and Description
ObjectArrayRow(int arity)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
boolean	equalsWithoutHeader(BaseRow o)
int	getArity() Get the number of fields in the BaseRow.
BaseArray	getArray(int ordinal) Get array value, internal format is BaseArray.
byte[]	getBinary(int ordinal) Get binary value, internal format is byte[].
Decimal	getDecimal(int ordinal, int precision, int scale) Get decimal value, internal format is Decimal.
<T> BinaryGeneric<T>	getGeneric(int ordinal) Get generic value, internal format is BinaryGeneric.
byte	getHeader() The header represents the type of this Row.
BaseMap	getMap(int ordinal) Get map value, internal format is BaseMap.
BaseRow	getRow(int ordinal, int numFields) Get row value, internal format is BaseRow.
BinaryString	getString(int ordinal) Get string value, internal format is BinaryString.
SqlTimestamp	getTimestamp(int ordinal, int precision) Get Timestamp value, internal format is SqlTimestamp.
int	hashCode()
boolean	isNullAt(int ordinal) Because the specific row implementation such as BinaryRow uses the binary format.
void	setDecimal(int i, Decimal value, int precision) Set the decimal column value.
void	setHeader(byte header) Set the byte header.
void	setNullAt(int ordinal) Set null to this field.
void	setTimestamp(int ordinal, SqlTimestamp value, int precision) Set Timestamp value.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flink.table.dataformat.TypeGetterSetters

get, getBoolean, getByte, getDouble, getFloat, getInt, getLong, getShort, setBoolean, setByte, setDouble, setFloat, setInt, setLong, setShort

Field Detail

fields

protected final Object[] fields

Constructor Detail

ObjectArrayRow

public ObjectArrayRow(int arity)

Method Detail

getArity

public int getArity()

Description copied from interface: BaseRow

Get the number of fields in the BaseRow.

Specified by:

getArity in interface BaseRow

Returns:

The number of fields in the BaseRow.

getHeader

public byte getHeader()

Description copied from interface: BaseRow

The header represents the type of this Row. Now just used in streaming. Now there are two message: ACCUMULATE_MSG and RETRACT_MSG.

Specified by:

getHeader in interface BaseRow

setHeader

public void setHeader(byte header)

Description copied from interface: BaseRow

Set the byte header.

Specified by:

setHeader in interface BaseRow

isNullAt

public boolean isNullAt(int ordinal)

Description copied from interface: TypeGetterSetters

Because the specific row implementation such as BinaryRow uses the binary format. We must first determine if it is null, and then make a specific get.

Specified by:

isNullAt in interface TypeGetterSetters

Returns:

true if this field is null.

setNullAt

public void setNullAt(int ordinal)

Description copied from interface: TypeGetterSetters

Set null to this field.

Specified by:

setNullAt in interface TypeGetterSetters

setDecimal

public void setDecimal(int i,
                       Decimal value,
                       int precision)

Description copied from interface: TypeGetterSetters

Set the decimal column value.

Note: Precision is compact: can call setNullAt when decimal is null. Precision is not compact: can not call setNullAt when decimal is null, must call setDecimal(i, null, precision) because we need update var-length-part.

Specified by:

setDecimal in interface TypeGetterSetters

setTimestamp

public void setTimestamp(int ordinal,
                         SqlTimestamp value,
                         int precision)

Description copied from interface: TypeGetterSetters

Set Timestamp value.

Note: If precision is compact: can call setNullAt when SqlTimestamp value is null. Otherwise: can not call setNullAt when SqlTimestamp value is null, must call setTimestamp(ordinal, null, precision) because we need to update var-length-part.

Specified by:

setTimestamp in interface TypeGetterSetters

getString

public BinaryString getString(int ordinal)

Description copied from interface: TypeGetterSetters

Get string value, internal format is BinaryString.

Specified by:

getString in interface TypeGetterSetters

getBinary

public byte[] getBinary(int ordinal)

Description copied from interface: TypeGetterSetters

Get binary value, internal format is byte[].

Specified by:

getBinary in interface TypeGetterSetters

getArray

public BaseArray getArray(int ordinal)

Description copied from interface: TypeGetterSetters

Get array value, internal format is BaseArray.

Specified by:

getArray in interface TypeGetterSetters

getMap

public BaseMap getMap(int ordinal)

Description copied from interface: TypeGetterSetters

Get map value, internal format is BaseMap.

Specified by:

getMap in interface TypeGetterSetters

getDecimal

public Decimal getDecimal(int ordinal,
                          int precision,
                          int scale)

Description copied from interface: TypeGetterSetters

Get decimal value, internal format is Decimal.

Specified by:

getDecimal in interface TypeGetterSetters

getTimestamp

public SqlTimestamp getTimestamp(int ordinal,
                                 int precision)

Description copied from interface: TypeGetterSetters

Get Timestamp value, internal format is SqlTimestamp.

Specified by:

getTimestamp in interface TypeGetterSetters

getGeneric

public <T> BinaryGeneric<T> getGeneric(int ordinal)

Description copied from interface: TypeGetterSetters

Get generic value, internal format is BinaryGeneric.

Specified by:

getGeneric in interface TypeGetterSetters

getRow

public BaseRow getRow(int ordinal,
                      int numFields)

Description copied from interface: TypeGetterSetters

Get row value, internal format is BaseRow.

Specified by:

getRow in interface TypeGetterSetters

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

equalsWithoutHeader

public boolean equalsWithoutHeader(BaseRow o)