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

Class IcebergCommitter

java.lang.Object

org.apache.flink.cdc.connectors.iceberg.sink.v2.IcebergCommitter

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.connector.sink2.Committer<WriteResultWrapper>

public class IcebergCommitter
extends Object
implements org.apache.flink.api.connector.sink2.Committer<WriteResultWrapper>

A Committer for Apache Iceberg.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.connector.sink2.Committer

org.apache.flink.api.connector.sink2.Committer.CommitRequest<CommT extends Object>

Field Summary

Fields

Modifier and Type	Field	Description
static String	NAMESPACE_GROUP_KEY
static String	SCHEMA_GROUP_KEY
static String	TABLE_GROUP_KEY

Constructor Summary

Constructors

Constructor	Description
IcebergCommitter(Map<String,String> catalogOptions, Map<String,String> hadoopConfOptions)
IcebergCommitter(Map<String,String> catalogOptions, org.apache.flink.metrics.groups.SinkCommitterMetricGroup metricGroup, Map<String,String> hadoopConfOptions)

Method Summary

Modifier and Type	Method	Description
void	close()
void	commit(Collection<org.apache.flink.api.connector.sink2.Committer.CommitRequest<WriteResultWrapper>> collection)

Methods inherited from class java.lang.Object

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

Field Detail

NAMESPACE_GROUP_KEY

public static final String NAMESPACE_GROUP_KEY

See Also:

Constant Field Values

SCHEMA_GROUP_KEY

public static final String SCHEMA_GROUP_KEY

See Also:

Constant Field Values

TABLE_GROUP_KEY

public static final String TABLE_GROUP_KEY

See Also:

Constant Field Values

Constructor Detail

IcebergCommitter

public IcebergCommitter(Map<String,String> catalogOptions,
                        Map<String,String> hadoopConfOptions)

IcebergCommitter

public IcebergCommitter(Map<String,String> catalogOptions,
                        org.apache.flink.metrics.groups.SinkCommitterMetricGroup metricGroup,
                        Map<String,String> hadoopConfOptions)

Method Detail

commit

public void commit(Collection<org.apache.flink.api.connector.sink2.Committer.CommitRequest<WriteResultWrapper>> collection)

Specified by:

commit in interface org.apache.flink.api.connector.sink2.Committer<WriteResultWrapper>

close

public void close()

Specified by:

close in interface AutoCloseable