Package org.apache.iceberg.connect

Class IcebergSinkConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

org.apache.iceberg.connect.IcebergSinkConfig

public class IcebergSinkConfig
extends org.apache.kafka.common.config.AbstractConfig

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.kafka.common.config.ConfigDef	CONFIG_DEF
static int	CREATE_TABLE_RETRIES
static java.lang.String	DEFAULT_CONTROL_GROUP_PREFIX
static java.lang.String	INTERNAL_TRANSACTIONAL_SUFFIX_PROP
static int	SCHEMA_UPDATE_RETRIES

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor	Description
IcebergSinkConfig(java.util.Map<java.lang.String,java.lang.String> originalProps)

Method Summary

Modifier and Type	Method	Description
boolean	autoCreateEnabled()
java.util.Map<java.lang.String,java.lang.String>	autoCreateProps()
java.lang.String	catalogName()
java.util.Map<java.lang.String,java.lang.String>	catalogProps()
int	commitIntervalMs()
int	commitThreads()
int	commitTimeoutMs()
java.lang.String	connectGroupId()
java.lang.String	connectorName()
java.lang.String	controlGroupId()
java.lang.String	controlTopic()
boolean	dynamicTablesEnabled()
boolean	evolveSchemaEnabled()
java.lang.String	hadoopConfDir()
java.util.Map<java.lang.String,java.lang.String>	hadoopProps()
org.apache.kafka.connect.json.JsonConverter	jsonConverter()
java.util.Map<java.lang.String,java.lang.String>	kafkaProps()
boolean	schemaCaseInsensitive()
boolean	schemaForceOptional()
TableSinkConfig	tableConfig(java.lang.String tableName)
java.util.List<java.lang.String>	tables()
java.lang.String	tablesDefaultCommitBranch()
java.lang.String	tablesDefaultIdColumns()
java.lang.String	tablesDefaultPartitionBy()
java.lang.String	tablesRouteField()
java.lang.String	transactionalSuffix()
static java.lang.String	version()
java.util.Map<java.lang.String,java.lang.String>	writeProps()

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object

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

Field Detail

INTERNAL_TRANSACTIONAL_SUFFIX_PROP

public static final java.lang.String INTERNAL_TRANSACTIONAL_SUFFIX_PROP

See Also:

Constant Field Values

DEFAULT_CONTROL_GROUP_PREFIX

public static final java.lang.String DEFAULT_CONTROL_GROUP_PREFIX

See Also:

Constant Field Values

SCHEMA_UPDATE_RETRIES

public static final int SCHEMA_UPDATE_RETRIES

See Also:

Constant Field Values

CREATE_TABLE_RETRIES

public static final int CREATE_TABLE_RETRIES

See Also:

Constant Field Values

CONFIG_DEF

public static final org.apache.kafka.common.config.ConfigDef CONFIG_DEF

Constructor Detail

IcebergSinkConfig

public IcebergSinkConfig(java.util.Map<java.lang.String,java.lang.String> originalProps)

Method Detail

version

public static java.lang.String version()

connectorName

public java.lang.String connectorName()

transactionalSuffix

public java.lang.String transactionalSuffix()

catalogProps

public java.util.Map<java.lang.String,java.lang.String> catalogProps()

hadoopProps

public java.util.Map<java.lang.String,java.lang.String> hadoopProps()

kafkaProps

public java.util.Map<java.lang.String,java.lang.String> kafkaProps()

autoCreateProps

public java.util.Map<java.lang.String,java.lang.String> autoCreateProps()

writeProps

public java.util.Map<java.lang.String,java.lang.String> writeProps()

catalogName

public java.lang.String catalogName()

tables

public java.util.List<java.lang.String> tables()

dynamicTablesEnabled

public boolean dynamicTablesEnabled()

tablesRouteField

public java.lang.String tablesRouteField()

tablesDefaultCommitBranch

public java.lang.String tablesDefaultCommitBranch()

tablesDefaultIdColumns

public java.lang.String tablesDefaultIdColumns()

tablesDefaultPartitionBy

public java.lang.String tablesDefaultPartitionBy()

tableConfig

public TableSinkConfig tableConfig(java.lang.String tableName)

controlTopic

public java.lang.String controlTopic()

controlGroupId

public java.lang.String controlGroupId()

connectGroupId

public java.lang.String connectGroupId()

commitIntervalMs

public int commitIntervalMs()

commitTimeoutMs

public int commitTimeoutMs()

commitThreads

public int commitThreads()

hadoopConfDir

public java.lang.String hadoopConfDir()

autoCreateEnabled

public boolean autoCreateEnabled()

evolveSchemaEnabled

public boolean evolveSchemaEnabled()

schemaForceOptional

public boolean schemaForceOptional()

schemaCaseInsensitive

public boolean schemaCaseInsensitive()

jsonConverter

public org.apache.kafka.connect.json.JsonConverter jsonConverter()