org.apache.flink.formats.json.canal

Class CanalJsonOptions

java.lang.Object

org.apache.flink.formats.json.canal.CanalJsonOptions

public class CanalJsonOptions
extends Object

Option utils for canal-json format.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<String>	DATABASE_INCLUDE
static ConfigOption<Boolean>	IGNORE_PARSE_ERRORS
static ConfigOption<String>	JSON_MAP_NULL_KEY_LITERAL
static ConfigOption<String>	JSON_MAP_NULL_KEY_MODE
static ConfigOption<String>	TABLE_INCLUDE
static ConfigOption<String>	TIMESTAMP_FORMAT

Constructor Summary

Constructors

Constructor and Description
CanalJsonOptions()

Method Summary

Modifier and Type	Method and Description
static void	validateDecodingFormatOptions(ReadableConfig tableOptions) Validator for canal decoding format.
static void	validateEncodingFormatOptions(ReadableConfig tableOptions) Validator for canal encoding format.

Methods inherited from class java.lang.Object

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

Field Detail

IGNORE_PARSE_ERRORS

public static final ConfigOption<Boolean> IGNORE_PARSE_ERRORS

TIMESTAMP_FORMAT

public static final ConfigOption<String> TIMESTAMP_FORMAT

JSON_MAP_NULL_KEY_MODE

public static final ConfigOption<String> JSON_MAP_NULL_KEY_MODE

JSON_MAP_NULL_KEY_LITERAL

public static final ConfigOption<String> JSON_MAP_NULL_KEY_LITERAL

DATABASE_INCLUDE

public static final ConfigOption<String> DATABASE_INCLUDE

TABLE_INCLUDE

public static final ConfigOption<String> TABLE_INCLUDE

Constructor Detail

CanalJsonOptions

public CanalJsonOptions()

Method Detail

validateDecodingFormatOptions

public static void validateDecodingFormatOptions(ReadableConfig tableOptions)

Validator for canal decoding format.

validateEncodingFormatOptions

public static void validateEncodingFormatOptions(ReadableConfig tableOptions)

Validator for canal encoding format.