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

Class StarRocksDataSinkOptions

java.lang.Object

org.apache.flink.cdc.connectors.starrocks.sink.StarRocksDataSinkOptions

public class StarRocksDataSinkOptions
extends Object

Options for StarRocksDataSink.

Field Summary

Fields

Modifier and Type	Field	Description
static ConfigOption<String>	JDBC_URL
static ConfigOption<List<String>>	LOAD_URL
static ConfigOption<String>	PASSWORD
static ConfigOption<Boolean>	SINK_AT_LEAST_ONCE_USE_TRANSACTION_LOAD
static ConfigOption<Long>	SINK_BATCH_FLUSH_INTERVAL
static ConfigOption<Long>	SINK_BATCH_MAX_SIZE
static ConfigOption<Integer>	SINK_CONNECT_TIMEOUT
static ConfigOption<Integer>	SINK_IO_THREAD_COUNT
static ConfigOption<String>	SINK_LABEL_PREFIX
static ConfigOption<Integer>	SINK_METRIC_HISTOGRAM_WINDOW_SIZE
static String	SINK_PROPERTIES_PREFIX	The prefix for stream load properties, such as sink.properties.timeout.
static ConfigOption<Long>	SINK_SCAN_FREQUENCY
static ConfigOption<Integer>	SINK_SOCKET_TIMEOUT
static ConfigOption<Integer>	SINK_WAIT_FOR_CONTINUE_TIMEOUT
static ConfigOption<Integer>	TABLE_CREATE_NUM_BUCKETS
static String	TABLE_CREATE_PROPERTIES_PREFIX	The prefix for properties used for creating a table.
static ConfigOption<java.time.Duration>	TABLE_SCHEMA_CHANGE_TIMEOUT
static ConfigOption<Integer>	UNICODE_CHAR_MAX_BYTES
static ConfigOption<String>	USERNAME

Constructor Summary

Constructors

Constructor	Description
StarRocksDataSinkOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

JDBC_URL

public static final ConfigOption<String> JDBC_URL

LOAD_URL

public static final ConfigOption<List<String>> LOAD_URL

USERNAME

public static final ConfigOption<String> USERNAME

PASSWORD

public static final ConfigOption<String> PASSWORD

SINK_LABEL_PREFIX

public static final ConfigOption<String> SINK_LABEL_PREFIX

SINK_CONNECT_TIMEOUT

public static final ConfigOption<Integer> SINK_CONNECT_TIMEOUT

SINK_SOCKET_TIMEOUT

public static final ConfigOption<Integer> SINK_SOCKET_TIMEOUT

SINK_WAIT_FOR_CONTINUE_TIMEOUT

public static final ConfigOption<Integer> SINK_WAIT_FOR_CONTINUE_TIMEOUT

SINK_BATCH_MAX_SIZE

public static final ConfigOption<Long> SINK_BATCH_MAX_SIZE

SINK_BATCH_FLUSH_INTERVAL

public static final ConfigOption<Long> SINK_BATCH_FLUSH_INTERVAL

SINK_SCAN_FREQUENCY

public static final ConfigOption<Long> SINK_SCAN_FREQUENCY

SINK_IO_THREAD_COUNT

public static final ConfigOption<Integer> SINK_IO_THREAD_COUNT

SINK_AT_LEAST_ONCE_USE_TRANSACTION_LOAD

public static final ConfigOption<Boolean> SINK_AT_LEAST_ONCE_USE_TRANSACTION_LOAD

SINK_METRIC_HISTOGRAM_WINDOW_SIZE

public static final ConfigOption<Integer> SINK_METRIC_HISTOGRAM_WINDOW_SIZE

SINK_PROPERTIES_PREFIX

public static final String SINK_PROPERTIES_PREFIX

The prefix for stream load properties, such as sink.properties.timeout.

See Also:

Constant Field Values

TABLE_CREATE_PROPERTIES_PREFIX

public static final String TABLE_CREATE_PROPERTIES_PREFIX

The prefix for properties used for creating a table. You can refer to StarRocks documentation for the DDL. create-primary-key-table

See Also:

Constant Field Values

TABLE_CREATE_NUM_BUCKETS

public static final ConfigOption<Integer> TABLE_CREATE_NUM_BUCKETS

TABLE_SCHEMA_CHANGE_TIMEOUT

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

UNICODE_CHAR_MAX_BYTES

public static final ConfigOption<Integer> UNICODE_CHAR_MAX_BYTES

Constructor Detail

StarRocksDataSinkOptions

public StarRocksDataSinkOptions()