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

Class FlussDataSinkOptions

java.lang.Object

org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions

public class FlussDataSinkOptions
extends Object

Options for FlussDataSink.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FlussDataSinkOptions.SinkPartitioningStrategy	The shuffle strategy for fluss sink.

Field Summary

Fields

Modifier and Type	Field	Description
static ConfigOption<String>	BOOTSTRAP_SERVERS
static ConfigOption<String>	BUCKET_KEY
static ConfigOption<String>	BUCKET_NUMBER
static String	CLIENT_PROPERTIES_PREFIX
static ConfigOption<FlussDataSinkOptions.SinkPartitioningStrategy>	SINK_PARTITIONING_STRATEGY
static String	TABLE_PROPERTIES_PREFIX

Constructor Summary

Constructors

Constructor	Description
FlussDataSinkOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

TABLE_PROPERTIES_PREFIX

public static final String TABLE_PROPERTIES_PREFIX

See Also:

Constant Field Values

CLIENT_PROPERTIES_PREFIX

public static final String CLIENT_PROPERTIES_PREFIX

See Also:

Constant Field Values

BOOTSTRAP_SERVERS

public static final ConfigOption<String> BOOTSTRAP_SERVERS

SINK_PARTITIONING_STRATEGY

public static final ConfigOption<FlussDataSinkOptions.SinkPartitioningStrategy> SINK_PARTITIONING_STRATEGY

BUCKET_KEY

public static final ConfigOption<String> BUCKET_KEY

BUCKET_NUMBER

public static final ConfigOption<String> BUCKET_NUMBER

Constructor Detail

FlussDataSinkOptions

public FlussDataSinkOptions()