@PublicEvolving public interface DynamicTableSource
Dynamic tables are the core concept of Flink's Table & SQL API for processing both bounded and unbounded data in a unified fashion. By definition, a dynamic table can change over time.
When reading a dynamic table, the content can either be considered as:
ScanTableSource
for more information.
LookupTableSource
for more information.
Note: Both interfaces can be implemented at the same time. The planner decides about their usage depending on the specified query.
Instances of the above mentioned interfaces can be seen as factories that eventually produce concrete runtime implementation for reading the actual data.
Depending on the optionally declared abilities such as SupportsProjectionPushDown
or
SupportsFilterPushDown
, the planner might apply changes to an instance and thus mutates
the produced runtime implementation.
Modifier and Type | Interface and Description |
---|---|
static interface |
DynamicTableSource.Context
Base context for creating runtime implementation via a
ScanTableSource.ScanRuntimeProvider and LookupTableSource.LookupRuntimeProvider . |
static interface |
DynamicTableSource.DataStructureConverter
Converter for mapping between objects and Flink's internal data structures during runtime.
|
Modifier and Type | Method and Description |
---|---|
String |
asSummaryString()
Returns a string that summarizes this source for printing to a console or log.
|
DynamicTableSource |
copy()
Creates a copy of this instance during planning.
|
DynamicTableSource copy()
String asSummaryString()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.