org.apache.flink.table.connector.source

Interface InputFormatProvider

All Superinterfaces:

ParallelismProvider, ScanTableSource.ScanRuntimeProvider

@PublicEvolving
public interface InputFormatProvider
extends ScanTableSource.ScanRuntimeProvider, ParallelismProvider

Provider of an InputFormat instance as a runtime implementation for ScanTableSource.

Method Summary

Modifier and Type	Method and Description
InputFormat<RowData,?>	createInputFormat() Creates an InputFormat instance.
static InputFormatProvider	of(InputFormat<RowData,?> inputFormat) Helper method for creating a static provider.
static InputFormatProvider	of(InputFormat<RowData,?> inputFormat, Integer sourceParallelism) Helper method for creating a static provider with a provided source parallelism.

Methods inherited from interface org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider

isBounded

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

getParallelism

Method Detail

of

static InputFormatProvider of(InputFormat<RowData,?> inputFormat)

Helper method for creating a static provider.

of

static InputFormatProvider of(InputFormat<RowData,?> inputFormat,
                              @Nullable
                              Integer sourceParallelism)

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

createInputFormat

InputFormat<RowData,?> createInputFormat()

Creates an InputFormat instance.