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

Class HudiSink

java.lang.Object

org.apache.flink.cdc.connectors.hudi.sink.v2.HudiSink

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.sink2.Sink<Event>, org.apache.flink.streaming.api.connector.sink2.SupportsPreWriteTopology<Event>, org.apache.flink.streaming.api.connector.sink2.WithPreWriteTopology<Event>

public class HudiSink
extends Object
implements org.apache.flink.api.connector.sink2.Sink<Event>, org.apache.flink.streaming.api.connector.sink2.WithPreWriteTopology<Event>

A Sink implementation for Apache Hudi.

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

Constructor Summary

Constructors

Constructor	Description
HudiSink(org.apache.flink.configuration.Configuration conf, 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.api.connector.sink2.SinkWriter<Event>	createWriter(org.apache.flink.api.connector.sink2.Sink.InitContext context)
org.apache.flink.api.connector.sink2.SinkWriter<Event>	createWriter(org.apache.flink.api.connector.sink2.WriterInitContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

HudiSink

public HudiSink(org.apache.flink.configuration.Configuration conf,
                String schemaOperatorUid,
                java.time.ZoneId zoneId)

Method Detail

createWriter

public org.apache.flink.api.connector.sink2.SinkWriter<Event> createWriter(org.apache.flink.api.connector.sink2.Sink.InitContext context)
                                                                    throws IOException

Specified by:

createWriter in interface org.apache.flink.api.connector.sink2.Sink<Event>

Throws:

IOException

createWriter

public org.apache.flink.api.connector.sink2.SinkWriter<Event> createWriter(org.apache.flink.api.connector.sink2.WriterInitContext context)
                                                                    throws IOException

Specified by:

createWriter in interface org.apache.flink.api.connector.sink2.Sink<Event>

Throws:

IOException

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>