org.apache.flink.formats.json.canal

Class CanalJsonFormatOptions

java.lang.Object

org.apache.flink.formats.json.canal.CanalJsonFormatOptions

@PublicEvolving
public class CanalJsonFormatOptions
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

Method Summary

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