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

Class MaxComputeEventWriter

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.connector.sink2.SinkWriter<Event>

public class MaxComputeEventWriter
extends Object
implements org.apache.flink.api.connector.sink2.SinkWriter<Event>

a SinkWriter for Event for MaxCompute.

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
MaxComputeEventWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, org.apache.flink.api.connector.sink2.Sink.InitContext context)
MaxComputeEventWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, org.apache.flink.api.connector.sink2.WriterInitContext context)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush(boolean endOfInput)
void	write(Event element, 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

MaxComputeEventWriter

public MaxComputeEventWriter(MaxComputeOptions options,
                             MaxComputeWriteOptions writeOptions,
                             org.apache.flink.api.connector.sink2.Sink.InitContext context)

MaxComputeEventWriter

public MaxComputeEventWriter(MaxComputeOptions options,
                             MaxComputeWriteOptions writeOptions,
                             org.apache.flink.api.connector.sink2.WriterInitContext context)

Method Detail

write

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

Specified by:

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

Throws:

IOException

flush

public void flush(boolean endOfInput)
           throws IOException,
                  InterruptedException

Specified by:

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

Throws:

IOException

InterruptedException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception