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

Class CdcAsFlussRow

java.lang.Object

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

All Implemented Interfaces:

org.apache.fluss.row.DataGetters, org.apache.fluss.row.InternalRow

@Internal
public class CdcAsFlussRow
extends Object
implements org.apache.fluss.row.InternalRow

Wraps a CDC RecordData as a Fluss InternalRow.

Nested Class Summary

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

org.apache.fluss.row.InternalRow.FieldGetter

Method Summary

Modifier and Type	Method	Description
static org.apache.fluss.row.Decimal	fromFlinkDecimal(DecimalData decimal)
org.apache.fluss.row.InternalArray	getArray(int i)
byte[]	getBinary(int pos, int length)
boolean	getBoolean(int pos)
byte	getByte(int pos)
byte[]	getBytes(int pos)
RecordData	getCdcRecord()
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)
int	getFieldCount()
float	getFloat(int pos)
Map<Integer,Integer>	getIndexMapping()
int	getInt(int pos)
long	getLong(int pos)
org.apache.fluss.row.InternalMap	getMap(int i)
org.apache.fluss.row.InternalRow	getRow(int i, 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)
static CdcAsFlussRow	replace(RecordData cdcRecord)
static CdcAsFlussRow	replace(RecordData cdcRecord, Integer rowFieldCount, Map<Integer,Integer> indexMapping)

Methods inherited from class java.lang.Object

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

Method Detail

replace

public static CdcAsFlussRow replace(RecordData cdcRecord,
                                    Integer rowFieldCount,
                                    Map<Integer,Integer> indexMapping)

replace

public static CdcAsFlussRow replace(RecordData cdcRecord)

getFieldCount

public int getFieldCount()

Specified by:

getFieldCount in interface org.apache.fluss.row.InternalRow

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

fromFlinkDecimal

public static org.apache.fluss.row.Decimal fromFlinkDecimal(DecimalData decimal)

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 i)

Specified by:

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

getMap

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

Specified by:

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

getRow

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

Specified by:

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

getCdcRecord

@VisibleForTesting
public RecordData getCdcRecord()

getIndexMapping

@VisibleForTesting
public Map<Integer,Integer> getIndexMapping()