org.apache.paimon.flink.log

Interface LogSinkProvider

All Superinterfaces:

Serializable

All Known Implementing Classes:

KafkaLogSinkProvider

public interface LogSinkProvider
extends Serializable

A Serializable sink provider for log store.

Method Summary

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

Method Detail

createSink

LogSinkFunction createSink()

Creates a LogSinkFunction instance.