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

Class MaxComputeEventSink

java.lang.Object

org.apache.flink.cdc.connectors.maxcompute.sink.MaxComputeEventSink

All Implemented Interfaces:

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

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

A Sink of Event to MaxCompute.

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
MaxComputeEventSink(MaxComputeOptions options, MaxComputeWriteOptions writeOptions)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.streaming.api.datastream.DataStream<Event>	addPreWriteTopology(org.apache.flink.streaming.api.datastream.DataStream<Event> inputDataStream)
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

MaxComputeEventSink

public MaxComputeEventSink(MaxComputeOptions options,
                           MaxComputeWriteOptions writeOptions)

Method Detail

addPreWriteTopology

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

Specified by:

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

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