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

Class IcebergDataSink

java.lang.Object

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

All Implemented Interfaces:

Serializable, DataSink

public class IcebergDataSink
extends Object
implements DataSink, Serializable

A DataSink for Apache Iceberg.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
CompactionOptions	compactionOptions
String	jobIdPrefix
String	schemaOperatorUid

Constructor Summary

Constructors

Constructor	Description
IcebergDataSink(Map<String,String> catalogOptions, Map<String,String> tableOptions, Map<TableId,List<String>> partitionMaps, java.time.ZoneId zoneId, String schemaOperatorUid, CompactionOptions compactionOptions, String jobIdPrefix, Map<String,String> hadoopConfOptions)

Method Summary

Modifier and Type	Method	Description
EventSinkProvider	getEventSinkProvider()	Get the EventSinkProvider for writing changed data to external systems.
Map<String,String>	getHadoopConfOptions()
MetadataApplier	getMetadataApplier()	Get the MetadataApplier for applying metadata changes to external systems.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.cdc.common.sink.DataSink

getDataChangeEventHashFunctionProvider, getDataChangeEventHashFunctionProvider

Field Detail

schemaOperatorUid

public final String schemaOperatorUid

compactionOptions

public final CompactionOptions compactionOptions

jobIdPrefix

public final String jobIdPrefix

Constructor Detail

IcebergDataSink

public IcebergDataSink(Map<String,String> catalogOptions,
                       Map<String,String> tableOptions,
                       Map<TableId,List<String>> partitionMaps,
                       java.time.ZoneId zoneId,
                       String schemaOperatorUid,
                       CompactionOptions compactionOptions,
                       String jobIdPrefix,
                       Map<String,String> hadoopConfOptions)

Method Detail

getEventSinkProvider

public EventSinkProvider getEventSinkProvider()

Description copied from interface: DataSink

Get the EventSinkProvider for writing changed data to external systems.

Specified by:

getEventSinkProvider in interface DataSink

getMetadataApplier

public MetadataApplier getMetadataApplier()

Description copied from interface: DataSink

Get the MetadataApplier for applying metadata changes to external systems.

Specified by:

getMetadataApplier in interface DataSink

getHadoopConfOptions

public Map<String,String> getHadoopConfOptions()