Interface | Description |
---|---|
AsyncTableFunctionProvider<T> |
Provider of an
AsyncTableFunction instance as a runtime implementation for LookupTableSource . |
DataStreamScanProvider |
Provider that produces a Java
DataStream as a runtime implementation for ScanTableSource . |
DynamicTableSource |
Source of a dynamic table from an external storage system.
|
DynamicTableSource.Context |
Base context for creating runtime implementation via a
ScanTableSource.ScanRuntimeProvider and LookupTableSource.LookupRuntimeProvider . |
DynamicTableSource.DataStructureConverter |
Converter for mapping between objects and Flink's internal data structures during runtime.
|
InputFormatProvider |
Provider of an
InputFormat instance as a runtime implementation for ScanTableSource . |
LookupTableSource |
A
DynamicTableSource that looks up rows of an external storage system by one or more keys
during runtime. |
LookupTableSource.LookupContext |
Context for creating runtime implementation via a
LookupTableSource.LookupRuntimeProvider . |
LookupTableSource.LookupRuntimeProvider |
Provides actual runtime implementation for reading the data.
|
ScanTableSource |
A
DynamicTableSource that scans all rows from an external storage system during runtime. |
ScanTableSource.ScanContext |
Context for creating runtime implementation via a
ScanTableSource.ScanRuntimeProvider . |
ScanTableSource.ScanRuntimeProvider |
Provides actual runtime implementation for reading the data.
|
SourceFunctionProvider |
Provider of a
SourceFunction instance as a runtime implementation for ScanTableSource . |
SourceProvider |
Provider of a
Source instance as a runtime implementation for ScanTableSource . |
TableFunctionProvider<T> |
Provider of a
TableFunction instance as a runtime implementation for LookupTableSource . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.