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

Class WriteResultWrapper

java.lang.Object

org.apache.flink.cdc.connectors.iceberg.sink.v2.WriteResultWrapper

All Implemented Interfaces:

Serializable

public class WriteResultWrapper
extends Object
implements Serializable

A wrapper class for WriteResult and TableId.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
WriteResultWrapper(org.apache.iceberg.io.WriteResult writeResult, TableId tableId, long checkpointId, String jobId, String operatorId)
WriteResultWrapper(org.apache.iceberg.io.WriteResult writeResult, TableId tableId, long checkpointId, String jobId, String operatorId, int batchIndex)

Method Summary

Modifier and Type	Method	Description
String	buildDescription()	Build a simple description for the write result.
int	getBatchIndex()
long	getCheckpointId()
String	getJobId()
String	getOperatorId()
TableId	getTableId()
org.apache.iceberg.io.WriteResult	getWriteResult()

Methods inherited from class java.lang.Object

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

Constructor Detail

WriteResultWrapper

public WriteResultWrapper(org.apache.iceberg.io.WriteResult writeResult,
                          TableId tableId,
                          long checkpointId,
                          String jobId,
                          String operatorId,
                          int batchIndex)

WriteResultWrapper

public WriteResultWrapper(org.apache.iceberg.io.WriteResult writeResult,
                          TableId tableId,
                          long checkpointId,
                          String jobId,
                          String operatorId)

Method Detail

getWriteResult

public org.apache.iceberg.io.WriteResult getWriteResult()

getTableId

public TableId getTableId()

getCheckpointId

public long getCheckpointId()

getJobId

public String getJobId()

getOperatorId

public String getOperatorId()

getBatchIndex

public int getBatchIndex()

buildDescription

public String buildDescription()

Build a simple description for the write result.