org.apache.flink.table.connector.source

Interface SourceFunctionProvider

All Superinterfaces:

ScanTableSource.ScanRuntimeProvider

@PublicEvolving
public interface SourceFunctionProvider
extends ScanTableSource.ScanRuntimeProvider

Provider of a SourceFunction instance as a runtime implementation for ScanTableSource.

Method Summary

Modifier and Type	Method and Description
SourceFunction<RowData>	createSourceFunction() Creates a SourceFunction instance.
static SourceFunctionProvider	of(SourceFunction<RowData> sourceFunction, boolean isBounded) Helper method for creating a static provider.

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

isBounded

Method Detail

of

static SourceFunctionProvider of(SourceFunction<RowData> sourceFunction,
                                 boolean isBounded)

Helper method for creating a static provider.

createSourceFunction

SourceFunction<RowData> createSourceFunction()

Creates a SourceFunction instance.