org.apache.paimon.flink.utils

Class FlinkCatalogPropertiesUtil

java.lang.Object

org.apache.paimon.flink.utils.FlinkCatalogPropertiesUtil

public class FlinkCatalogPropertiesUtil
extends Object

Utilities for ser/deserializing non-physical columns and watermark into/from a map of string properties.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SCHEMA

Constructor Summary

Constructors

Constructor and Description
FlinkCatalogPropertiesUtil()

Method Summary

Modifier and Type	Method and Description
static String	compoundKey(Object... components)
static void	deserializeNonPhysicalColumn(Map<String,String> options, int index, org.apache.flink.table.api.Schema.Builder builder)
static void	deserializeWatermarkSpec(Map<String,String> options, org.apache.flink.table.api.Schema.Builder builder)
static boolean	isNonPhysicalColumnKey(String key)
static Map<String,Integer>	nonPhysicalColumns(Map<String,String> tableOptions, List<String> physicalColumns)
static int	nonPhysicalColumnsCount(Map<String,String> tableOptions, List<String> physicalColumns)
static Map<String,String>	serializeNewWatermarkSpec(org.apache.flink.table.catalog.WatermarkSpec watermarkSpec)
static Map<String,String>	serializeNonPhysicalNewColumns(org.apache.flink.table.catalog.ResolvedSchema schema) Serialize non-physical columns of new api.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SCHEMA

public static final String SCHEMA

See Also:

Constant Field Values

Constructor Detail

FlinkCatalogPropertiesUtil

public FlinkCatalogPropertiesUtil()

Method Detail

serializeNonPhysicalNewColumns

public static Map<String,String> serializeNonPhysicalNewColumns(org.apache.flink.table.catalog.ResolvedSchema schema)

Serialize non-physical columns of new api.

serializeNewWatermarkSpec

public static Map<String,String> serializeNewWatermarkSpec(org.apache.flink.table.catalog.WatermarkSpec watermarkSpec)

nonPhysicalColumnsCount

public static int nonPhysicalColumnsCount(Map<String,String> tableOptions,
                                          List<String> physicalColumns)

isNonPhysicalColumnKey

public static boolean isNonPhysicalColumnKey(String key)

nonPhysicalColumns

public static Map<String,Integer> nonPhysicalColumns(Map<String,String> tableOptions,
                                                     List<String> physicalColumns)

deserializeNonPhysicalColumn

public static void deserializeNonPhysicalColumn(Map<String,String> options,
                                                int index,
                                                org.apache.flink.table.api.Schema.Builder builder)

deserializeWatermarkSpec

public static void deserializeWatermarkSpec(Map<String,String> options,
                                            org.apache.flink.table.api.Schema.Builder builder)

compoundKey

public static String compoundKey(Object... components)