org.apache.paimon.flink.log

Class LogWriteCallback

java.lang.Object

org.apache.paimon.flink.log.LogWriteCallback

All Implemented Interfaces:

LogSinkFunction.WriteCallback

public class LogWriteCallback
extends Object
implements LogSinkFunction.WriteCallback

A LogSinkFunction.WriteCallback implementation.

Constructor Summary

Constructors

Constructor and Description
LogWriteCallback()

Method Summary

Modifier and Type	Method and Description
Map<Integer,Long>	offsets()
void	onCompletion(int bucket, long offset) A callback method the user can implement to provide asynchronous handling of request completion.

Methods inherited from class java.lang.Object

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

Constructor Detail

LogWriteCallback

public LogWriteCallback()

Method Detail

onCompletion

public void onCompletion(int bucket,
                         long offset)

Description copied from interface: LogSinkFunction.WriteCallback

A callback method the user can implement to provide asynchronous handling of request completion. This method will be called when the record sent to the server has been acknowledged.

Specified by:

onCompletion in interface LogSinkFunction.WriteCallback

offsets

public Map<Integer,Long> offsets()