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

Class PaimonEventSink

java.lang.Object

org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonSink<Event>

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.sink2.Sink<Event>, org.apache.flink.api.connector.sink2.SupportsCommitter<org.apache.paimon.flink.sink.MultiTableCommittable>, org.apache.flink.api.connector.sink2.SupportsWriterState<Event,PaimonWriterState>, org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<Event,org.apache.paimon.flink.sink.MultiTableCommittable>, org.apache.flink.streaming.api.connector.sink2.SupportsPreCommitTopology<org.apache.paimon.flink.sink.MultiTableCommittable,org.apache.paimon.flink.sink.MultiTableCommittable>, org.apache.flink.streaming.api.connector.sink2.SupportsPreWriteTopology<Event>

public class PaimonEventSink
extends PaimonSink<Event>
implements org.apache.flink.streaming.api.connector.sink2.SupportsPreWriteTopology<Event>

A PaimonSink to process Event.

See Also:

Serialized Form

Nested Class Summary

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

org.apache.flink.api.connector.sink2.Sink.InitContext, org.apache.flink.api.connector.sink2.Sink.InitContextWrapper

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

org.apache.flink.api.connector.sink2.SupportsWriterState.WithCompatibleState

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

org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT extends Object,CommT extends Object>

Field Summary

Fields

Modifier and Type	Field	Description
String	schemaOperatorUid
java.time.ZoneId	zoneId

Fields inherited from class org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonSink

catalogOptions, commitUser, DEFAULT_COMMIT_USER

Constructor Summary

Constructors

Constructor	Description
PaimonEventSink(org.apache.paimon.options.Options catalogOptions, String commitUser, PaimonRecordSerializer<Event> serializer, String schemaOperatorUid, java.time.ZoneId zoneId)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	addPreWriteTopology(org.apache.flink.streaming.api.datastream.DataStream<Event> dataStream)
org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.paimon.flink.sink.MultiTableCommittable>	getWriteResultSerializer()

Methods inherited from class org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonSink

addPreCommitTopology, createCommitter, createCommitter, createWriter, createWriter, getCommittableSerializer, getWriterStateSerializer, restoreWriter

Methods inherited from class java.lang.Object

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

Field Detail

schemaOperatorUid

public final String schemaOperatorUid

zoneId

public final java.time.ZoneId zoneId

Constructor Detail

PaimonEventSink

public PaimonEventSink(org.apache.paimon.options.Options catalogOptions,
                       String commitUser,
                       PaimonRecordSerializer<Event> serializer,
                       String schemaOperatorUid,
                       java.time.ZoneId zoneId)

Method Detail

addPreWriteTopology

public org.apache.flink.streaming.api.datastream.DataStream<Event> addPreWriteTopology(org.apache.flink.streaming.api.datastream.DataStream<Event> dataStream)

Specified by:

addPreWriteTopology in interface org.apache.flink.streaming.api.connector.sink2.SupportsPreWriteTopology<Event>

getWriteResultSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.paimon.flink.sink.MultiTableCommittable> getWriteResultSerializer()

Specified by:

getWriteResultSerializer in interface org.apache.flink.streaming.api.connector.sink2.SupportsPreCommitTopology<org.apache.paimon.flink.sink.MultiTableCommittable,org.apache.paimon.flink.sink.MultiTableCommittable>

Overrides:

getWriteResultSerializer in class PaimonSink<Event>