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

Class OceanBaseDataSinkOptions

java.lang.Object

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

public class OceanBaseDataSinkOptions
extends Object

Options for OceanBaseDataSink.

Field Summary

Fields

Modifier and Type	Field	Description
static ConfigOption<java.time.Duration>	BUFFER_FLUSH_INTERVAL
static ConfigOption<Integer>	BUFFER_SIZE
static ConfigOption<String>	DRIVER_CLASS_NAME
static ConfigOption<String>	DRUID_PROPERTIES
static ConfigOption<Integer>	MAX_RETRIES
static ConfigOption<Boolean>	MEMSTORE_CHECK_ENABLED
static ConfigOption<java.time.Duration>	MEMSTORE_CHECK_INTERVAL
static ConfigOption<Double>	MEMSTORE_THRESHOLD
static ConfigOption<Boolean>	PARTITION_ENABLED
static ConfigOption<String>	PASSWORD
static ConfigOption<Boolean>	SYNC_WRITE
static ConfigOption<String>	URL
static ConfigOption<String>	USERNAME

Constructor Summary

Constructors

Constructor	Description
OceanBaseDataSinkOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

URL

public static final ConfigOption<String> URL

USERNAME

public static final ConfigOption<String> USERNAME

PASSWORD

public static final ConfigOption<String> PASSWORD

DRIVER_CLASS_NAME

public static final ConfigOption<String> DRIVER_CLASS_NAME

DRUID_PROPERTIES

public static final ConfigOption<String> DRUID_PROPERTIES

MEMSTORE_CHECK_ENABLED

public static final ConfigOption<Boolean> MEMSTORE_CHECK_ENABLED

MEMSTORE_THRESHOLD

public static final ConfigOption<Double> MEMSTORE_THRESHOLD

MEMSTORE_CHECK_INTERVAL

public static final ConfigOption<java.time.Duration> MEMSTORE_CHECK_INTERVAL

PARTITION_ENABLED

public static final ConfigOption<Boolean> PARTITION_ENABLED

SYNC_WRITE

public static final ConfigOption<Boolean> SYNC_WRITE

BUFFER_FLUSH_INTERVAL

public static final ConfigOption<java.time.Duration> BUFFER_FLUSH_INTERVAL

BUFFER_SIZE

public static final ConfigOption<Integer> BUFFER_SIZE

MAX_RETRIES

public static final ConfigOption<Integer> MAX_RETRIES

Constructor Detail

OceanBaseDataSinkOptions

public OceanBaseDataSinkOptions()