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.

Constructor Summary

Constructors

Constructor and Description
FlinkCatalogPropertiesUtil()

Method Summary

Modifier and Type	Method and Description
static String	compoundKey(Object... components)
static org.apache.flink.table.api.TableColumn	deserializeNonPhysicalColumn(Map<String,String> options, int index)
static org.apache.flink.table.api.WatermarkSpec	deserializeWatermarkSpec(Map<String,String> options)
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>	serializeNonPhysicalColumns(Map<String,Integer> indexMap, List<org.apache.flink.table.api.TableColumn> nonPhysicalColumns)
static Map<String,String>	serializeNonPhysicalNewColumns(org.apache.flink.table.catalog.ResolvedSchema schema) Serialize non-physical columns of new api.
static Map<String,String>	serializeWatermarkSpec(org.apache.flink.table.api.WatermarkSpec watermarkSpec)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkCatalogPropertiesUtil

public FlinkCatalogPropertiesUtil()

Method Detail

serializeNonPhysicalColumns

public static Map<String,String> serializeNonPhysicalColumns(Map<String,Integer> indexMap,
                                                             List<org.apache.flink.table.api.TableColumn> nonPhysicalColumns)

serializeNonPhysicalNewColumns

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

Serialize non-physical columns of new api.

serializeWatermarkSpec

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

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 org.apache.flink.table.api.TableColumn deserializeNonPhysicalColumn(Map<String,String> options,
                                                                                  int index)

deserializeWatermarkSpec

public static org.apache.flink.table.api.WatermarkSpec deserializeWatermarkSpec(Map<String,String> options)

compoundKey

public static String compoundKey(Object... components)