Uses of Class
org.apache.flink.connector.base.sink.writer.BufferedRequestState

Packages that use BufferedRequestState

Package	Description
org.apache.flink.connector.base.sink.writer
org.apache.flink.connector.firehose.sink
org.apache.flink.connector.kinesis.sink

Uses of BufferedRequestState in org.apache.flink.connector.base.sink.writer

Methods in org.apache.flink.connector.base.sink.writer that return BufferedRequestState

Modifier and Type	Method and Description
BufferedRequestState<RequestEntryT>	AsyncSinkWriterStateSerializer.deserialize(int version, byte[] serialized)
static <T extends Serializable> BufferedRequestState<T>	BufferedRequestState.emptyState()

Methods in org.apache.flink.connector.base.sink.writer that return types with arguments of type BufferedRequestState

Modifier and Type	Method and Description
List<BufferedRequestState<RequestEntryT>>	AsyncSinkWriter.snapshotState(long checkpointId) All in-flight requests that are relevant for the snapshot have been completed, but there may still be request entries in the internal buffers that are yet to be sent to the endpoint.

Methods in org.apache.flink.connector.base.sink.writer with parameters of type BufferedRequestState

Modifier and Type	Method and Description
byte[]	AsyncSinkWriterStateSerializer.serialize(BufferedRequestState<RequestEntryT> obj) Serializes state in form of [DATA_IDENTIFIER,NUM_OF_ELEMENTS,SIZE1,REQUEST1,SIZE2,REQUEST2....].

Constructor parameters in org.apache.flink.connector.base.sink.writer with type arguments of type BufferedRequestState

Constructor and Description
AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter, Sink.InitContext context, int maxBatchSize, int maxInFlightRequests, int maxBufferedRequests, long maxBatchSizeInBytes, long maxTimeInBufferMS, long maxRecordSizeInBytes, Collection<BufferedRequestState<RequestEntryT>> states)

Uses of BufferedRequestState in org.apache.flink.connector.firehose.sink

Methods in org.apache.flink.connector.firehose.sink that return types with arguments of type BufferedRequestState

Modifier and Type	Method and Description
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>>	KinesisFirehoseSink.createWriter(Sink.InitContext context)
SimpleVersionedSerializer<BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>>	KinesisFirehoseSink.getWriterStateSerializer()
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>>	KinesisFirehoseSink.restoreWriter(Sink.InitContext context, Collection<BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> recoveredState)

Method parameters in org.apache.flink.connector.firehose.sink with type arguments of type BufferedRequestState

Modifier and Type	Method and Description
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>>	KinesisFirehoseSink.restoreWriter(Sink.InitContext context, Collection<BufferedRequestState<software.amazon.awssdk.services.firehose.model.Record>> recoveredState)

Uses of BufferedRequestState in org.apache.flink.connector.kinesis.sink

Methods in org.apache.flink.connector.kinesis.sink that return types with arguments of type BufferedRequestState

Modifier and Type	Method and Description
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>>	KinesisStreamsSink.createWriter(Sink.InitContext context)
SimpleVersionedSerializer<BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>>	KinesisStreamsSink.getWriterStateSerializer()
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>>	KinesisStreamsSink.restoreWriter(Sink.InitContext context, Collection<BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>> recoveredState)

Method parameters in org.apache.flink.connector.kinesis.sink with type arguments of type BufferedRequestState

Modifier and Type	Method and Description
StatefulSink.StatefulSinkWriter<InputT,BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>>	KinesisStreamsSink.restoreWriter(Sink.InitContext context, Collection<BufferedRequestState<software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>> recoveredState)