org.apache.paimon.flink.sink

Interface LogSinkFunction.WriteCallback

All Known Implementing Classes:

LogWriteCallback

Enclosing interface:

LogSinkFunction

public static interface LogSinkFunction.WriteCallback

A callback interface that the user can implement to know the offset of the bucket when the request is complete.

Method Summary

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

Method Detail

onCompletion

void onCompletion(int bucket,
                  long offset)

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.