Package org.apache.flink.cdc.connectors.fluss.sink.row

Class CdcAsFlussArray

java.lang.Object

org.apache.flink.cdc.connectors.fluss.sink.row.CdcAsFlussArray

All Implemented Interfaces:

org.apache.fluss.row.DataGetters, org.apache.fluss.row.InternalArray

public class CdcAsFlussArray
extends Object
implements org.apache.fluss.row.InternalArray

Wraps a CDC ArrayData as a Fluss InternalArray.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.fluss.row.InternalArray

org.apache.fluss.row.InternalArray.ElementGetter

Constructor Summary

Constructors

Constructor	Description
CdcAsFlussArray(ArrayData flussArray)

Method Summary

Modifier and Type	Method	Description
org.apache.fluss.row.InternalArray	getArray(int pos)
byte[]	getBinary(int pos, int length)
boolean	getBoolean(int pos)
byte	getByte(int pos)
byte[]	getBytes(int pos)
org.apache.fluss.row.BinaryString	getChar(int pos, int length)
org.apache.fluss.row.Decimal	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.fluss.row.InternalMap	getMap(int pos)
org.apache.fluss.row.InternalRow	getRow(int pos, int numFields)
short	getShort(int pos)
org.apache.fluss.row.BinaryString	getString(int pos)
org.apache.fluss.row.TimestampLtz	getTimestampLtz(int pos, int precision)
org.apache.fluss.row.TimestampNtz	getTimestampNtz(int pos, int precision)
boolean	isNullAt(int pos)
int	size()
boolean[]	toBooleanArray()
byte[]	toByteArray()
double[]	toDoubleArray()
float[]	toFloatArray()
int[]	toIntArray()
long[]	toLongArray()
short[]	toShortArray()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CdcAsFlussArray

public CdcAsFlussArray(ArrayData flussArray)

Method Detail

size

public int size()

Specified by:

size in interface org.apache.fluss.row.InternalArray

toBooleanArray

public boolean[] toBooleanArray()

Specified by:

toBooleanArray in interface org.apache.fluss.row.InternalArray

toByteArray

public byte[] toByteArray()

Specified by:

toByteArray in interface org.apache.fluss.row.InternalArray

toShortArray

public short[] toShortArray()

Specified by:

toShortArray in interface org.apache.fluss.row.InternalArray

toIntArray

public int[] toIntArray()

Specified by:

toIntArray in interface org.apache.fluss.row.InternalArray

toLongArray

public long[] toLongArray()

Specified by:

toLongArray in interface org.apache.fluss.row.InternalArray

toFloatArray

public float[] toFloatArray()

Specified by:

toFloatArray in interface org.apache.fluss.row.InternalArray

toDoubleArray

public double[] toDoubleArray()

Specified by:

toDoubleArray in interface org.apache.fluss.row.InternalArray

isNullAt

public boolean isNullAt(int pos)

Specified by:

isNullAt in interface org.apache.fluss.row.DataGetters

getBoolean

public boolean getBoolean(int pos)

Specified by:

getBoolean in interface org.apache.fluss.row.DataGetters

getByte

public byte getByte(int pos)

Specified by:

getByte in interface org.apache.fluss.row.DataGetters

getShort

public short getShort(int pos)

Specified by:

getShort in interface org.apache.fluss.row.DataGetters

getInt

public int getInt(int pos)

Specified by:

getInt in interface org.apache.fluss.row.DataGetters

getLong

public long getLong(int pos)

Specified by:

getLong in interface org.apache.fluss.row.DataGetters

getFloat

public float getFloat(int pos)

Specified by:

getFloat in interface org.apache.fluss.row.DataGetters

getDouble

public double getDouble(int pos)

Specified by:

getDouble in interface org.apache.fluss.row.DataGetters

getChar

public org.apache.fluss.row.BinaryString getChar(int pos,
                                                 int length)

Specified by:

getChar in interface org.apache.fluss.row.DataGetters

getString

public org.apache.fluss.row.BinaryString getString(int pos)

Specified by:

getString in interface org.apache.fluss.row.DataGetters

getDecimal

public org.apache.fluss.row.Decimal getDecimal(int pos,
                                               int precision,
                                               int scale)

Specified by:

getDecimal in interface org.apache.fluss.row.DataGetters

getTimestampNtz

public org.apache.fluss.row.TimestampNtz getTimestampNtz(int pos,
                                                         int precision)

Specified by:

getTimestampNtz in interface org.apache.fluss.row.DataGetters

getTimestampLtz

public org.apache.fluss.row.TimestampLtz getTimestampLtz(int pos,
                                                         int precision)

Specified by:

getTimestampLtz in interface org.apache.fluss.row.DataGetters

getBinary

public byte[] getBinary(int pos,
                        int length)

Specified by:

getBinary in interface org.apache.fluss.row.DataGetters

getBytes

public byte[] getBytes(int pos)

Specified by:

getBytes in interface org.apache.fluss.row.DataGetters

getArray

public org.apache.fluss.row.InternalArray getArray(int pos)

Specified by:

getArray in interface org.apache.fluss.row.DataGetters

getMap

public org.apache.fluss.row.InternalMap getMap(int pos)

Specified by:

getMap in interface org.apache.fluss.row.DataGetters

getRow

public org.apache.fluss.row.InternalRow getRow(int pos,
                                               int numFields)

Specified by:

getRow in interface org.apache.fluss.row.DataGetters