org.apache.paimon.flink.sink

Interface LogSinkFunction

All Superinterfaces:

org.apache.flink.api.common.functions.Function, Serializable, org.apache.flink.streaming.api.functions.sink.SinkFunction<SinkRecord>

All Known Implementing Classes:

KafkaSinkFunction

public interface LogSinkFunction
extends org.apache.flink.streaming.api.functions.sink.SinkFunction<SinkRecord>

Log SinkFunction with LogSinkFunction.WriteCallback.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	LogSinkFunction.WriteCallback A callback interface that the user can implement to know the offset of the bucket when the request is complete.

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.sink.SinkFunction

org.apache.flink.streaming.api.functions.sink.SinkFunction.Context

Method Summary

Modifier and Type	Method and Description
void	flush() Flush pending records.
void	setWriteCallback(LogSinkFunction.WriteCallback writeCallback)

Methods inherited from interface org.apache.flink.streaming.api.functions.sink.SinkFunction

finish, invoke, invoke, writeWatermark

Method Detail

setWriteCallback

void setWriteCallback(LogSinkFunction.WriteCallback writeCallback)

flush

void flush()
    throws Exception

Flush pending records.

Throws:

Exception