org.apache.paimon.flink.utils

Class FlinkDescriptorProperties

java.lang.Object

org.apache.paimon.flink.utils.FlinkDescriptorProperties

public class FlinkDescriptorProperties
extends Object

Utility class for having a unified string-based representation of Table API related classes such as Schema, TypeInformation, etc.

Note to implementers: Please try to reuse key names as much as possible. Key-names should be hierarchical and lower case. Use "-" instead of dots or camel case. E.g., connector.schema.start-from = from-earliest. Try not to use the higher level in a key-name. E.g., instead of connector.kafka.kafka-version use connector.kafka.version.

Properties with key normalization enabled contain only lower-case keys.

Field Summary

Fields

Modifier and Type	Field and Description
static String	COMMENT
static String	DATA_TYPE
static String	EXPR
static String	METADATA
static String	NAME
static String	PRIMARY_KEY_COLUMNS
static String	PRIMARY_KEY_NAME
static String	VIRTUAL
static String	WATERMARK
static String	WATERMARK_ROWTIME
static String	WATERMARK_STRATEGY
static String	WATERMARK_STRATEGY_DATA_TYPE
static String	WATERMARK_STRATEGY_EXPR

Constructor Summary

Constructors

Constructor and Description
FlinkDescriptorProperties()

Method Summary

Modifier and Type	Method and Description
static void	removeSchemaKeys(String key, org.apache.flink.table.api.Schema schema, Map<String,String> options)

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

DATA_TYPE

public static final String DATA_TYPE

See Also:

Constant Field Values

EXPR

public static final String EXPR

See Also:

Constant Field Values

METADATA

public static final String METADATA

See Also:

Constant Field Values

VIRTUAL

public static final String VIRTUAL

See Also:

Constant Field Values

WATERMARK

public static final String WATERMARK

See Also:

Constant Field Values

WATERMARK_ROWTIME

public static final String WATERMARK_ROWTIME

See Also:

Constant Field Values

WATERMARK_STRATEGY

public static final String WATERMARK_STRATEGY

See Also:

Constant Field Values

WATERMARK_STRATEGY_EXPR

public static final String WATERMARK_STRATEGY_EXPR

See Also:

Constant Field Values

WATERMARK_STRATEGY_DATA_TYPE

public static final String WATERMARK_STRATEGY_DATA_TYPE

See Also:

Constant Field Values

PRIMARY_KEY_NAME

public static final String PRIMARY_KEY_NAME

See Also:

Constant Field Values

PRIMARY_KEY_COLUMNS

public static final String PRIMARY_KEY_COLUMNS

See Also:

Constant Field Values

COMMENT

public static final String COMMENT

See Also:

Constant Field Values

Constructor Detail

FlinkDescriptorProperties

public FlinkDescriptorProperties()

Method Detail

removeSchemaKeys

public static void removeSchemaKeys(String key,
                                    org.apache.flink.table.api.Schema schema,
                                    Map<String,String> options)