Class DebeziumOptions
- java.lang.Object
-
- org.apache.flink.cdc.debezium.table.DebeziumOptions
-
public class DebeziumOptions extends Object
Option utils for Debezium options.
-
-
Field Summary
Fields Modifier and Type Field Description static StringDEBEZIUM_OPTIONS_PREFIX
-
Constructor Summary
Constructors Constructor Description DebeziumOptions()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static PropertiesgetDebeziumProperties(Map<String,String> properties)
-
-
-
Field Detail
-
DEBEZIUM_OPTIONS_PREFIX
public static final String DEBEZIUM_OPTIONS_PREFIX
- See Also:
- Constant Field Values
-
-
Method Detail
-
getDebeziumProperties
public static Properties getDebeziumProperties(Map<String,String> properties)
-
-