org.apache.flink.table.connector.sink

Interface OutputFormatProvider

All Superinterfaces:

DynamicTableSink.SinkRuntimeProvider, ParallelismProvider

@PublicEvolving
public interface OutputFormatProvider
extends DynamicTableSink.SinkRuntimeProvider, ParallelismProvider

Provider of an OutputFormat instance as a runtime implementation for DynamicTableSink.

Method Summary

Modifier and Type	Method and Description
OutputFormat<RowData>	createOutputFormat() Creates an OutputFormat instance.
static OutputFormatProvider	of(OutputFormat<RowData> outputFormat) Helper method for creating a static provider.
static OutputFormatProvider	of(OutputFormat<RowData> outputFormat, Integer sinkParallelism) Helper method for creating a static provider with a provided sink parallelism.

Methods inherited from interface org.apache.flink.table.connector.ParallelismProvider

getParallelism

Method Detail

of

static OutputFormatProvider of(OutputFormat<RowData> outputFormat)

Helper method for creating a static provider.

of

static OutputFormatProvider of(OutputFormat<RowData> outputFormat,
                               Integer sinkParallelism)

Helper method for creating a static provider with a provided sink parallelism.

createOutputFormat

OutputFormat<RowData> createOutputFormat()

Creates an OutputFormat instance.