Modifier and Type | Field and Description |
---|---|
static String |
FLINK_PROPERTY_PREFIX
Globally reserved prefix for catalog properties.
|
static String |
IS_GENERIC
Flag to distinguish if a meta-object is a generic Flink object or not.
|
Modifier and Type | Method and Description |
---|---|
static CatalogTable |
deserializeCatalogTable(Map<String,String> properties)
Deserializes the given map of string properties into an unresolved
CatalogTable . |
static CatalogTable |
deserializeCatalogTable(Map<String,String> properties,
String fallbackKey)
Deserializes the given map of string properties into an unresolved
CatalogTable . |
static Map<String,String> |
serializeCatalogTable(ResolvedCatalogTable resolvedTable)
Serializes the given
ResolvedCatalogTable into a map of string properties. |
static Map<String,String> |
serializeCatalogView(ResolvedCatalogView resolvedView)
Serializes the given
ResolvedCatalogView into a map of string properties. |
public static final String IS_GENERIC
It is used to distinguish between Flink's generic connector discovery logic or specialized catalog connectors.
public static final String FLINK_PROPERTY_PREFIX
public static Map<String,String> serializeCatalogTable(ResolvedCatalogTable resolvedTable)
ResolvedCatalogTable
into a map of string properties.public static Map<String,String> serializeCatalogView(ResolvedCatalogView resolvedView)
ResolvedCatalogView
into a map of string properties.public static CatalogTable deserializeCatalogTable(Map<String,String> properties)
CatalogTable
.public static CatalogTable deserializeCatalogTable(Map<String,String> properties, @Nullable String fallbackKey)
CatalogTable
.properties
- The properties to deserialize fromfallbackKey
- The fallback key to get the schema properties. This is meant to support
the old table (1.10) deserializationCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.