Package org.apache.flink.cdc.connectors.paimon.sink.v2

Class PaimonEvent

java.lang.Object

org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonEvent

public class PaimonEvent
extends Object

Contains the data to be written for PaimonWriter.

Constructor Summary

Constructors

Constructor	Description
PaimonEvent(org.apache.paimon.catalog.Identifier tableId, List<org.apache.paimon.data.GenericRow> genericRows)
PaimonEvent(org.apache.paimon.catalog.Identifier tableId, List<org.apache.paimon.data.GenericRow> genericRows, boolean shouldRefreshSchema)
PaimonEvent(org.apache.paimon.catalog.Identifier tableId, List<org.apache.paimon.data.GenericRow> genericRows, boolean shouldRefreshSchema, int bucket)

Method Summary

Modifier and Type	Method	Description
int	getBucket()
List<org.apache.paimon.data.GenericRow>	getGenericRows()
org.apache.paimon.catalog.Identifier	getTableId()
boolean	isShouldRefreshSchema()
void	setBucket(int bucket)
void	setGenericRows(List<org.apache.paimon.data.GenericRow> genericRows)
void	setShouldRefreshSchema(boolean shouldRefreshSchema)
void	setTableId(org.apache.paimon.catalog.Identifier tableId)

Methods inherited from class java.lang.Object

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

Constructor Detail

PaimonEvent

public PaimonEvent(org.apache.paimon.catalog.Identifier tableId,
                   List<org.apache.paimon.data.GenericRow> genericRows)

PaimonEvent

public PaimonEvent(org.apache.paimon.catalog.Identifier tableId,
                   List<org.apache.paimon.data.GenericRow> genericRows,
                   boolean shouldRefreshSchema)

PaimonEvent

public PaimonEvent(org.apache.paimon.catalog.Identifier tableId,
                   List<org.apache.paimon.data.GenericRow> genericRows,
                   boolean shouldRefreshSchema,
                   int bucket)

Method Detail

getTableId

public org.apache.paimon.catalog.Identifier getTableId()

setTableId

public void setTableId(org.apache.paimon.catalog.Identifier tableId)

isShouldRefreshSchema

public boolean isShouldRefreshSchema()

setShouldRefreshSchema

public void setShouldRefreshSchema(boolean shouldRefreshSchema)

getGenericRows

public List<org.apache.paimon.data.GenericRow> getGenericRows()

setGenericRows

public void setGenericRows(List<org.apache.paimon.data.GenericRow> genericRows)

getBucket

public int getBucket()

setBucket

public void setBucket(int bucket)