org.apache.flink.table.connector.source

接口 SourceFunctionProvider

所有超级接口:

org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider

@PublicEvolving
public interface SourceFunctionProvider
extends org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider

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

方法概要

限定符和类型	方法和说明
org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.table.data.RowData>	createSourceFunction() Creates a SourceFunction instance.
static SourceFunctionProvider	of(org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.table.data.RowData> sourceFunction, boolean isBounded) Helper method for creating a static provider.

从接口继承的方法 org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider

isBounded

方法详细资料

of

static SourceFunctionProvider of(org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.table.data.RowData> sourceFunction,
                                 boolean isBounded)

Helper method for creating a static provider.

createSourceFunction

org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.table.data.RowData> createSourceFunction()

Creates a SourceFunction instance.