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

Class PaimonWriter<InputT>

java.lang.Object

org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonWriter<InputT>

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.connector.sink2.CommittingSinkWriter<InputT,org.apache.paimon.flink.sink.MultiTableCommittable>, org.apache.flink.api.connector.sink2.SinkWriter<InputT>, org.apache.flink.api.connector.sink2.StatefulSinkWriter<InputT,PaimonWriterState>

public class PaimonWriter<InputT>
extends Object
implements org.apache.flink.api.connector.sink2.CommittingSinkWriter<InputT,org.apache.paimon.flink.sink.MultiTableCommittable>, org.apache.flink.api.connector.sink2.StatefulSinkWriter<InputT,PaimonWriterState>

A Sink to write DataChangeEvent to Paimon storage.

Nested Class Summary

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

org.apache.flink.api.connector.sink2.SinkWriter.Context

Constructor Summary

Constructors

Constructor	Description
PaimonWriter(org.apache.paimon.options.Options catalogOptions, org.apache.flink.metrics.MetricGroup metricGroup, String commitUser, PaimonRecordSerializer<InputT> serializer, long lastCheckpointId)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush(boolean endOfInput)
Collection<org.apache.paimon.flink.sink.MultiTableCommittable>	prepareCommit()
List<PaimonWriterState>	snapshotState(long checkpointId)
void	write(InputT event, org.apache.flink.api.connector.sink2.SinkWriter.Context context)

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.api.connector.sink2.SinkWriter

writeWatermark

Constructor Detail

PaimonWriter

public PaimonWriter(org.apache.paimon.options.Options catalogOptions,
                    org.apache.flink.metrics.MetricGroup metricGroup,
                    String commitUser,
                    PaimonRecordSerializer<InputT> serializer,
                    long lastCheckpointId)

Method Detail

prepareCommit

public Collection<org.apache.paimon.flink.sink.MultiTableCommittable> prepareCommit()

Specified by:

prepareCommit in interface org.apache.flink.api.connector.sink2.CommittingSinkWriter<InputT,org.apache.paimon.flink.sink.MultiTableCommittable>

write

public void write(InputT event,
                  org.apache.flink.api.connector.sink2.SinkWriter.Context context)
           throws IOException

Specified by:

write in interface org.apache.flink.api.connector.sink2.SinkWriter<InputT>

Throws:

IOException

flush

public void flush(boolean endOfInput)

Specified by:

flush in interface org.apache.flink.api.connector.sink2.SinkWriter<InputT>

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

snapshotState

public List<PaimonWriterState> snapshotState(long checkpointId)

Specified by:

snapshotState in interface org.apache.flink.api.connector.sink2.StatefulSinkWriter<InputT,PaimonWriterState>