Package org.apache.flink.cdc.connectors.elasticsearch.v2

Class Elasticsearch8AsyncWriter<InputT>

java.lang.Object

org.apache.flink.connector.base.sink.writer.AsyncSinkWriter<InputT,RequestEntryT>

org.apache.flink.connector.base.sink.writer.AsyncSinkWriterAdapter<InputT,Operation>

org.apache.flink.cdc.connectors.elasticsearch.v2.Elasticsearch8AsyncWriter<InputT>

Type Parameters:

InputT - type of Operations

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.connector.sink2.SinkWriter<InputT>, org.apache.flink.api.connector.sink2.StatefulSink.StatefulSinkWriter<InputT,org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>>, org.apache.flink.api.connector.sink2.StatefulSinkWriter<InputT,org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>>, org.apache.flink.api.connector.sink2.StatefulSinkWriterAdapter<InputT,org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>>

public class Elasticsearch8AsyncWriter<InputT>
extends org.apache.flink.connector.base.sink.writer.AsyncSinkWriterAdapter<InputT,Operation>
implements org.apache.flink.api.connector.sink2.StatefulSinkWriterAdapter<InputT,org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>>

Elasticsearch8AsyncWriter Apache Flink's Async Sink Writer that submits Operations into an Elasticsearch cluster.

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

Elasticsearch8AsyncWriter(org.apache.flink.connector.base.sink.writer.ElementConverter<InputT,Operation> elementConverter, org.apache.flink.api.connector.sink2.Sink.InitContext context, int maxBatchSize, int maxInFlightRequests, int maxBufferedRequests, long maxBatchSizeInBytes, long maxTimeInBufferMS, long maxRecordSizeInBytes, NetworkConfig networkConfig, Collection<org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>> state)

Method Summary

Modifier and Type	Method	Description
void	close()
protected long	getSizeInBytes(Operation requestEntry)
protected void	submitRequestEntries(List<Operation> requestEntries, org.apache.flink.connector.base.sink.writer.ResultHandler<Operation> resultHandler)

Methods inherited from class org.apache.flink.connector.base.sink.writer.AsyncSinkWriter

flush, getFatalExceptionCons, snapshotState, submitRequestEntries, write

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

flush, write, writeWatermark

Methods inherited from interface org.apache.flink.api.connector.sink2.StatefulSinkWriter

snapshotState

Constructor Detail

Elasticsearch8AsyncWriter

public Elasticsearch8AsyncWriter(org.apache.flink.connector.base.sink.writer.ElementConverter<InputT,Operation> elementConverter,
                                 org.apache.flink.api.connector.sink2.Sink.InitContext context,
                                 int maxBatchSize,
                                 int maxInFlightRequests,
                                 int maxBufferedRequests,
                                 long maxBatchSizeInBytes,
                                 long maxTimeInBufferMS,
                                 long maxRecordSizeInBytes,
                                 NetworkConfig networkConfig,
                                 Collection<org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>> state)

Method Detail

submitRequestEntries

protected void submitRequestEntries(List<Operation> requestEntries,
                                    org.apache.flink.connector.base.sink.writer.ResultHandler<Operation> resultHandler)

Overrides:

submitRequestEntries in class org.apache.flink.connector.base.sink.writer.AsyncSinkWriter<InputT,Operation>

getSizeInBytes

protected long getSizeInBytes(Operation requestEntry)

Specified by:

getSizeInBytes in class org.apache.flink.connector.base.sink.writer.AsyncSinkWriter<InputT,Operation>

close

public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class org.apache.flink.connector.base.sink.writer.AsyncSinkWriter<InputT,Operation>