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

Class FlussEvent

java.lang.Object

org.apache.flink.cdc.connectors.fluss.sink.v2.FlussEvent

public class FlussEvent
extends Object

FlussEvent is a wrapper for a list of genericRows.

Constructor Summary

Constructors

Constructor	Description
FlussEvent(org.apache.fluss.metadata.TablePath tablePath, List<FlussRowWithOp> rowWithOps, int schemaId)

Method Summary

Modifier and Type	Method	Description
List<FlussRowWithOp>	getRowWithOps()
int	getSchemaId()
org.apache.fluss.metadata.TablePath	getTablePath()

Methods inherited from class java.lang.Object

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

Constructor Detail

FlussEvent

public FlussEvent(org.apache.fluss.metadata.TablePath tablePath,
                  List<FlussRowWithOp> rowWithOps,
                  int schemaId)

Method Detail

getTablePath

public org.apache.fluss.metadata.TablePath getTablePath()

getRowWithOps

public List<FlussRowWithOp> getRowWithOps()

getSchemaId

public int getSchemaId()