程序包 com.oceanbase.connector.flink.sink

类 OceanBaseSink<T>

java.lang.Object

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

所有已实现的接口:

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.

另请参阅:

序列化表格

嵌套类概要

从接口继承的嵌套类/接口 org.apache.flink.api.connector.sink2.Sink

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

构造器概要

构造器

构造器	说明
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)

方法概要

修饰符和类型	方法	说明
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)

从类继承的方法 java.lang.Object

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

构造器详细资料

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)

方法详细资料

createWriter

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

指定者:

createWriter 在接口中 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

指定者:

createWriter 在接口中 org.apache.flink.api.connector.sink2.Sink<T>

抛出:

IOException