Package | Description |
---|---|
org.apache.flink.table.catalog | |
org.apache.flink.table.planner.catalog |
Modifier and Type | Method and Description |
---|---|
static CatalogManager.TableLookupResult |
CatalogManager.TableLookupResult.permanent(Catalog catalog,
ResolvedCatalogBaseTable<?> resolvedTable) |
static CatalogManager.TableLookupResult |
CatalogManager.TableLookupResult.temporary(ResolvedCatalogBaseTable<?> resolvedTable) |
Modifier and Type | Method and Description |
---|---|
Optional<CatalogManager.TableLookupResult> |
CatalogManager.getTable(ObjectIdentifier objectIdentifier)
Retrieves a fully qualified table.
|
Constructor and Description |
---|
CatalogSchemaTable(ObjectIdentifier tableIdentifier,
CatalogManager.TableLookupResult lookupResult,
org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic,
boolean isStreaming)
Create a CatalogSchemaTable instance.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.