public class DynamicTableSourceSpec extends CatalogTableSpecBase
DynamicTableSourceSpec
describes how to serialize/deserialize dynamic table source table
and create DynamicTableSource
from the deserialization result.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_SOURCE_ABILITY_SPECS |
catalogTable, classLoader, configuration, FIELD_NAME_CATALOG_TABLE, FIELD_NAME_IDENTIFIER, objectIdentifier
Constructor and Description |
---|
DynamicTableSourceSpec(ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
List<SourceAbilitySpec> sourceAbilitySpecs) |
Modifier and Type | Method and Description |
---|---|
LookupTableSource |
getLookupTableSource(org.apache.flink.table.planner.delegation.PlannerBase planner) |
ScanTableSource |
getScanTableSource(org.apache.flink.table.planner.delegation.PlannerBase planner) |
List<SourceAbilitySpec> |
getSourceAbilitySpecs() |
void |
setTableSource(DynamicTableSource tableSource) |
equals, getCatalogTable, getClassLoader, getObjectIdentifier, getReadableConfig, hashCode, setClassLoader, setReadableConfig
public static final String FIELD_NAME_SOURCE_ABILITY_SPECS
public DynamicTableSourceSpec(ObjectIdentifier objectIdentifier, ResolvedCatalogTable catalogTable, @Nullable List<SourceAbilitySpec> sourceAbilitySpecs)
public ScanTableSource getScanTableSource(org.apache.flink.table.planner.delegation.PlannerBase planner)
public LookupTableSource getLookupTableSource(org.apache.flink.table.planner.delegation.PlannerBase planner)
public void setTableSource(DynamicTableSource tableSource)
@Nullable public List<SourceAbilitySpec> getSourceAbilitySpecs()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.