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

Class IcebergDataSinkOptions

java.lang.Object

org.apache.flink.cdc.connectors.iceberg.sink.IcebergDataSinkOptions

public class IcebergDataSinkOptions
extends Object

Config options for IcebergDataSink.

Field Summary

Fields

Modifier and Type	Field	Description
static ConfigOption<String>	CATALOG_IMPL
static ConfigOption<String>	CLIENT_REGION
static ConfigOption<String>	GLUE_ID
static ConfigOption<Boolean>	GLUE_SKIP_ARCHIVE
static ConfigOption<Boolean>	GLUE_SKIP_NAME_VALIDATION
static ConfigOption<String>	IO_IMPL
static ConfigOption<String>	JOB_ID_PREFIX
static ConfigOption<String>	PARTITION_KEY
static String	PREFIX_CATALOG_PROPERTIES
static String	PREFIX_HADOOP_CONF
static String	PREFIX_TABLE_PROPERTIES
static ConfigOption<Integer>	SINK_COMPACTION_COMMIT_INTERVAL
static ConfigOption<Boolean>	SINK_COMPACTION_ENABLED
static ConfigOption<Integer>	SINK_COMPACTION_PARALLELISM
static ConfigOption<String>	TYPE
static ConfigOption<String>	WAREHOUSE

Constructor Summary

Constructors

Constructor	Description
IcebergDataSinkOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

PREFIX_TABLE_PROPERTIES

public static final String PREFIX_TABLE_PROPERTIES

See Also:

Constant Field Values

PREFIX_CATALOG_PROPERTIES

public static final String PREFIX_CATALOG_PROPERTIES

See Also:

Constant Field Values

PREFIX_HADOOP_CONF

public static final String PREFIX_HADOOP_CONF

See Also:

Constant Field Values

TYPE

public static final ConfigOption<String> TYPE

CATALOG_IMPL

public static final ConfigOption<String> CATALOG_IMPL

IO_IMPL

public static final ConfigOption<String> IO_IMPL

GLUE_ID

public static final ConfigOption<String> GLUE_ID

GLUE_SKIP_ARCHIVE

public static final ConfigOption<Boolean> GLUE_SKIP_ARCHIVE

GLUE_SKIP_NAME_VALIDATION

public static final ConfigOption<Boolean> GLUE_SKIP_NAME_VALIDATION

CLIENT_REGION

public static final ConfigOption<String> CLIENT_REGION

WAREHOUSE

public static final ConfigOption<String> WAREHOUSE

PARTITION_KEY

public static final ConfigOption<String> PARTITION_KEY

SINK_COMPACTION_ENABLED

@Experimental
public static final ConfigOption<Boolean> SINK_COMPACTION_ENABLED

SINK_COMPACTION_COMMIT_INTERVAL

@Experimental
public static final ConfigOption<Integer> SINK_COMPACTION_COMMIT_INTERVAL

SINK_COMPACTION_PARALLELISM

@Experimental
public static final ConfigOption<Integer> SINK_COMPACTION_PARALLELISM

JOB_ID_PREFIX

@Experimental
public static final ConfigOption<String> JOB_ID_PREFIX

Constructor Detail

IcebergDataSinkOptions

public IcebergDataSinkOptions()