Package com.oceanbase.connector.flink.sink

Class OceanBaseSink<T>

java.lang.Object

com.oceanbase.connector.flink.sink.OceanBaseSink<T>

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.sink2.Sink<T>

public class OceanBaseSink<T>
extends Object
implements org.apache.flink.api.connector.sink2.Sink<T>

Copy from OceanBaseSink to add createWriter(WriterInitContext) method.

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
OceanBaseSink(com.oceanbase.connector.flink.ConnectorOptions options, org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer, com.oceanbase.connector.flink.table.RecordSerializationSchema<T> recordSerializer, com.oceanbase.connector.flink.table.DataChangeRecord.KeyExtractor keyExtractor, com.oceanbase.connector.flink.sink.RecordFlusher recordFlusher)
OceanBaseSink(com.oceanbase.connector.flink.ConnectorOptions options, org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer, com.oceanbase.connector.flink.table.RecordSerializationSchema<T> recordSerializer, com.oceanbase.connector.flink.table.DataChangeRecord.KeyExtractor keyExtractor, com.oceanbase.connector.flink.sink.RecordFlusher recordFlusher, com.oceanbase.connector.flink.sink.OceanBaseWriterEvent.Listener writerEventListener)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.connector.sink2.SinkWriter<T>	createWriter(org.apache.flink.api.connector.sink2.Sink.InitContext context)
org.apache.flink.api.connector.sink2.SinkWriter<T>	createWriter(org.apache.flink.api.connector.sink2.WriterInitContext writerInitContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

OceanBaseSink

public OceanBaseSink(com.oceanbase.connector.flink.ConnectorOptions options,
                     org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer,
                     com.oceanbase.connector.flink.table.RecordSerializationSchema<T> recordSerializer,
                     com.oceanbase.connector.flink.table.DataChangeRecord.KeyExtractor keyExtractor,
                     com.oceanbase.connector.flink.sink.RecordFlusher recordFlusher)

OceanBaseSink

public OceanBaseSink(com.oceanbase.connector.flink.ConnectorOptions options,
                     org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer,
                     com.oceanbase.connector.flink.table.RecordSerializationSchema<T> recordSerializer,
                     com.oceanbase.connector.flink.table.DataChangeRecord.KeyExtractor keyExtractor,
                     com.oceanbase.connector.flink.sink.RecordFlusher recordFlusher,
                     com.oceanbase.connector.flink.sink.OceanBaseWriterEvent.Listener writerEventListener)

Method Detail

createWriter

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

Specified by:

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

createWriter

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

Specified by:

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

Throws:

IOException