Uses of Interface
org.apache.paimon.flink.sink.LogSinkFunction

Packages that use LogSinkFunction

Package	Description
org.apache.paimon.flink.kafka
org.apache.paimon.flink.log
org.apache.paimon.flink.sink

Uses of LogSinkFunction in org.apache.paimon.flink.kafka

Classes in org.apache.paimon.flink.kafka that implement LogSinkFunction

Modifier and Type	Class and Description
class	KafkaSinkFunction A FlinkKafkaProducer which implements LogSinkFunction to register WriteCallback.

Methods in org.apache.paimon.flink.kafka that return LogSinkFunction

Modifier and Type	Method and Description
LogSinkFunction	KafkaLogSinkProvider.createSink()

Uses of LogSinkFunction in org.apache.paimon.flink.log

Methods in org.apache.paimon.flink.log that return LogSinkFunction

Modifier and Type	Method and Description
LogSinkFunction	LogSinkProvider.createSink() Creates a LogSinkFunction instance.

Uses of LogSinkFunction in org.apache.paimon.flink.sink

Fields in org.apache.paimon.flink.sink declared as LogSinkFunction

Modifier and Type	Field and Description
protected LogSinkFunction	UnawareBucketSink.logSinkFunction
protected LogSinkFunction	FlinkSinkBuilder.logSinkFunction

Constructors in org.apache.paimon.flink.sink with parameters of type LogSinkFunction

Constructor and Description
FixedBucketSink(FileStoreTable table, Map<String,String> overwritePartition, LogSinkFunction logSinkFunction)
RowDataStoreWriteOperator(FileStoreTable table, LogSinkFunction logSinkFunction, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
RowUnawareBucketSink(FileStoreTable table, Map<String,String> overwritePartitions, LogSinkFunction logSinkFunction, Integer parallelism)
UnawareBucketSink(FileStoreTable table, Map<String,String> overwritePartitions, LogSinkFunction logSinkFunction, Integer parallelism)