@PublicEvolving public interface SourceFunctionProvider extends ScanTableSource.ScanRuntimeProvider
SourceFunction
instance as a runtime implementation for ScanTableSource
.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.
|
isBounded
static SourceFunctionProvider of(SourceFunction<RowData> sourceFunction, boolean isBounded)
SourceFunction<RowData> createSourceFunction()
SourceFunction
instance.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.