Uses of Class
org.apache.flink.cdc.connectors.elasticsearch.v2.Operation

Packages that use Operation

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

Uses of Operation in org.apache.flink.cdc.connectors.elasticsearch.v2

Methods in org.apache.flink.cdc.connectors.elasticsearch.v2 that return Operation

Modifier and Type	Method	Description
Operation	Elasticsearch8AsyncSinkBuilder.OperationConverter.apply(T element, org.apache.flink.api.connector.sink2.SinkWriter.Context context)
Operation	OperationSerializer.deserialize(long requestSize, DataInputStream in)	Deserializes an Operation from the provided DataInputStream.
protected Operation	Elasticsearch8AsyncSinkSerializer.deserializeRequestFromStream(long requestSize, DataInputStream in)	Deserializes an Operation from the provided DataInputStream.

Methods in org.apache.flink.cdc.connectors.elasticsearch.v2 that return types with arguments of type Operation

Modifier and Type	Method	Description
org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>>	Elasticsearch8AsyncSink.getWriterStateSerializer()	Returns the serializer for the writer's state.
org.apache.flink.api.connector.sink2.StatefulSinkWriterAdapter<InputT,org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>>	Elasticsearch8AsyncSink.restoreWriterAdapter(org.apache.flink.api.connector.sink2.WriterInitContext context, Collection<org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>> recoveredState)	Restores a StatefulSinkWriterAdapter from a previously saved state.

Methods in org.apache.flink.cdc.connectors.elasticsearch.v2 with parameters of type Operation

Modifier and Type	Method	Description
protected long	Elasticsearch8AsyncWriter.getSizeInBytes(Operation requestEntry)
void	OperationSerializer.serialize(Operation request, DataOutputStream out)	Serializes the given Operation to the provided DataOutputStream.
protected void	Elasticsearch8AsyncSinkSerializer.serializeRequestToStream(Operation request, DataOutputStream out)	Serializes the given Operation to the provided DataOutputStream.
int	OperationSerializer.size(Operation operation)	Calculates the serialized size of the given Operation.

Method parameters in org.apache.flink.cdc.connectors.elasticsearch.v2 with type arguments of type Operation

Modifier and Type	Method	Description
org.apache.flink.api.connector.sink2.StatefulSinkWriterAdapter<InputT,org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>>	Elasticsearch8AsyncSink.restoreWriterAdapter(org.apache.flink.api.connector.sink2.WriterInitContext context, Collection<org.apache.flink.connector.base.sink.writer.BufferedRequestState<Operation>> recoveredState)	Restores a StatefulSinkWriterAdapter from a previously saved state.
protected void	Elasticsearch8AsyncWriter.submitRequestEntries(List<Operation> requestEntries, org.apache.flink.connector.base.sink.writer.ResultHandler<Operation> resultHandler)
protected void	Elasticsearch8AsyncWriter.submitRequestEntries(List<Operation> requestEntries, org.apache.flink.connector.base.sink.writer.ResultHandler<Operation> resultHandler)

Constructor parameters in org.apache.flink.cdc.connectors.elasticsearch.v2 with type arguments of type Operation

Constructor	Description
Elasticsearch8AsyncSink(org.apache.flink.connector.base.sink.writer.ElementConverter<InputT,Operation> converter, int maxBatchSize, int maxInFlightRequests, int maxBufferedRequests, long maxBatchSizeInBytes, long maxTimeInBufferMS, long maxRecordSizeInByte, NetworkConfig networkConfig)	Constructs an Elasticsearch8AsyncSink.
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)
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)