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 Map<String,String> |
serializeCatalogTable(ResolvedCatalogTable resolvedTable)
Serializes the given
ResolvedCatalogTable 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 CatalogTable deserializeCatalogTable(Map<String,String> properties)
CatalogTable
.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.