Class DebeziumJsonFormatOptions
- java.lang.Object
-
- org.apache.flink.formats.json.debezium.DebeziumJsonFormatOptions
-
@PublicEvolving public class DebeziumJsonFormatOptions extends Object
Option utils for debezium-json format.
-
-
Field Summary
Fields Modifier and Type Field Description static ConfigOption<Boolean>
IGNORE_PARSE_ERRORS
static ConfigOption<String>
JSON_MAP_NULL_KEY_LITERAL
static ConfigOption<String>
JSON_MAP_NULL_KEY_MODE
static ConfigOption<Boolean>
SCHEMA_INCLUDE
static ConfigOption<String>
TIMESTAMP_FORMAT
-
-
-
Field Detail
-
SCHEMA_INCLUDE
public static final ConfigOption<Boolean> SCHEMA_INCLUDE
-
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
-
-