类 OceanBaseDataSinkOptions
- java.lang.Object
-
- org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions
-
public class OceanBaseDataSinkOptions extends Object
Options forOceanBaseDataSink.
-
-
字段概要
字段 修饰符和类型 字段 说明 static org.apache.flink.cdc.common.configuration.ConfigOption<java.time.Duration>BUFFER_FLUSH_INTERVALstatic org.apache.flink.cdc.common.configuration.ConfigOption<Integer>BUFFER_SIZEstatic org.apache.flink.cdc.common.configuration.ConfigOption<String>DRIVER_CLASS_NAMEstatic org.apache.flink.cdc.common.configuration.ConfigOption<String>DRUID_PROPERTIESstatic org.apache.flink.cdc.common.configuration.ConfigOption<Integer>MAX_RETRIESstatic org.apache.flink.cdc.common.configuration.ConfigOption<Boolean>MEMSTORE_CHECK_ENABLEDstatic org.apache.flink.cdc.common.configuration.ConfigOption<java.time.Duration>MEMSTORE_CHECK_INTERVALstatic org.apache.flink.cdc.common.configuration.ConfigOption<Double>MEMSTORE_THRESHOLDstatic org.apache.flink.cdc.common.configuration.ConfigOption<Boolean>PARTITION_ENABLEDstatic org.apache.flink.cdc.common.configuration.ConfigOption<String>PASSWORDstatic org.apache.flink.cdc.common.configuration.ConfigOption<Boolean>SYNC_WRITEstatic org.apache.flink.cdc.common.configuration.ConfigOption<String>URLstatic org.apache.flink.cdc.common.configuration.ConfigOption<String>USERNAME
-
构造器概要
构造器 构造器 说明 OceanBaseDataSinkOptions()
-
-
-
字段详细资料
-
URL
public static final org.apache.flink.cdc.common.configuration.ConfigOption<String> URL
-
USERNAME
public static final org.apache.flink.cdc.common.configuration.ConfigOption<String> USERNAME
-
PASSWORD
public static final org.apache.flink.cdc.common.configuration.ConfigOption<String> PASSWORD
-
DRIVER_CLASS_NAME
public static final org.apache.flink.cdc.common.configuration.ConfigOption<String> DRIVER_CLASS_NAME
-
DRUID_PROPERTIES
public static final org.apache.flink.cdc.common.configuration.ConfigOption<String> DRUID_PROPERTIES
-
MEMSTORE_CHECK_ENABLED
public static final org.apache.flink.cdc.common.configuration.ConfigOption<Boolean> MEMSTORE_CHECK_ENABLED
-
MEMSTORE_THRESHOLD
public static final org.apache.flink.cdc.common.configuration.ConfigOption<Double> MEMSTORE_THRESHOLD
-
MEMSTORE_CHECK_INTERVAL
public static final org.apache.flink.cdc.common.configuration.ConfigOption<java.time.Duration> MEMSTORE_CHECK_INTERVAL
-
PARTITION_ENABLED
public static final org.apache.flink.cdc.common.configuration.ConfigOption<Boolean> PARTITION_ENABLED
-
SYNC_WRITE
public static final org.apache.flink.cdc.common.configuration.ConfigOption<Boolean> SYNC_WRITE
-
BUFFER_FLUSH_INTERVAL
public static final org.apache.flink.cdc.common.configuration.ConfigOption<java.time.Duration> BUFFER_FLUSH_INTERVAL
-
BUFFER_SIZE
public static final org.apache.flink.cdc.common.configuration.ConfigOption<Integer> BUFFER_SIZE
-
MAX_RETRIES
public static final org.apache.flink.cdc.common.configuration.ConfigOption<Integer> MAX_RETRIES
-
-