org.apache.flink.cdc.connectors.oceanbase.sink

类 OceanBaseDataSinkOptions

java.lang.Object

org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

public class OceanBaseDataSinkOptions
extends Object

Options for OceanBaseDataSink.

字段概要

字段

限定符和类型	字段和说明
static org.apache.flink.cdc.common.configuration.ConfigOption<java.time.Duration>	BUFFER_FLUSH_INTERVAL
static org.apache.flink.cdc.common.configuration.ConfigOption<Integer>	BUFFER_SIZE
static org.apache.flink.cdc.common.configuration.ConfigOption<String>	DRIVER_CLASS_NAME
static org.apache.flink.cdc.common.configuration.ConfigOption<String>	DRUID_PROPERTIES
static org.apache.flink.cdc.common.configuration.ConfigOption<Integer>	MAX_RETRIES
static org.apache.flink.cdc.common.configuration.ConfigOption<Boolean>	MEMSTORE_CHECK_ENABLED
static org.apache.flink.cdc.common.configuration.ConfigOption<java.time.Duration>	MEMSTORE_CHECK_INTERVAL
static org.apache.flink.cdc.common.configuration.ConfigOption<Double>	MEMSTORE_THRESHOLD
static org.apache.flink.cdc.common.configuration.ConfigOption<Boolean>	PARTITION_ENABLED
static org.apache.flink.cdc.common.configuration.ConfigOption<String>	PASSWORD
static org.apache.flink.cdc.common.configuration.ConfigOption<Boolean>	SYNC_WRITE
static org.apache.flink.cdc.common.configuration.ConfigOption<String>	URL
static org.apache.flink.cdc.common.configuration.ConfigOption<String>	USERNAME

构造器概要

构造器

构造器和说明
OceanBaseDataSinkOptions()

方法概要

从类继承的方法 java.lang.Object

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

字段详细资料

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

构造器详细资料

OceanBaseDataSinkOptions

public OceanBaseDataSinkOptions()