Package org.apache.doris.flink.sink.batch

Class DorisBatchSink<IN>

java.lang.Object

org.apache.doris.flink.sink.batch.DorisBatchSink<IN>

All Implemented Interfaces:

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

@Deprecated
@PublicEvolving
public class DorisBatchSink<IN>
extends Object
implements org.apache.flink.api.connector.sink2.Sink<IN>

Deprecated.

Copy from DorisBatchSink to add createWriter(WriterInitContext)} method.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DorisBatchSink.Builder<IN>	Deprecated. build for DorisBatchSink.

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
DorisBatchSink(org.apache.doris.flink.cfg.DorisOptions dorisOptions, org.apache.doris.flink.cfg.DorisReadOptions dorisReadOptions, org.apache.doris.flink.cfg.DorisExecutionOptions dorisExecutionOptions, org.apache.doris.flink.sink.writer.serializer.DorisRecordSerializer<IN> serializer)	Deprecated.

Method Summary

Modifier and Type	Method	Description
static <IN> DorisBatchSink.Builder<IN>	builder()	Deprecated.
org.apache.flink.api.connector.sink2.SinkWriter<IN>	createWriter(org.apache.flink.api.connector.sink2.Sink.InitContext initContext)	Deprecated.
org.apache.flink.api.connector.sink2.SinkWriter<IN>	createWriter(org.apache.flink.api.connector.sink2.WriterInitContext context)	Deprecated.
org.apache.doris.flink.cfg.DorisReadOptions	getDorisReadOptions()	Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

DorisBatchSink

public DorisBatchSink(org.apache.doris.flink.cfg.DorisOptions dorisOptions,
                      org.apache.doris.flink.cfg.DorisReadOptions dorisReadOptions,
                      org.apache.doris.flink.cfg.DorisExecutionOptions dorisExecutionOptions,
                      org.apache.doris.flink.sink.writer.serializer.DorisRecordSerializer<IN> serializer)

Deprecated.

Method Detail

createWriter

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

Deprecated.

Specified by:

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

Throws:

IOException

createWriter

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

Deprecated.

Specified by:

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

Throws:

IOException

builder

public static <IN> DorisBatchSink.Builder<IN> builder()

Deprecated.

getDorisReadOptions

@VisibleForTesting
public org.apache.doris.flink.cfg.DorisReadOptions getDorisReadOptions()

Deprecated.