Uses of Class
org.apache.flink.connector.base.sink.writer.BufferedRequestState
-
Packages that use BufferedRequestState Package Description org.apache.flink.connector.base.sink.writer -
-
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 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 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 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 Description AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter, org.apache.flink.api.connector.sink2.WriterInitContext context, AsyncSinkWriterConfiguration configuration, Collection<BufferedRequestState<RequestEntryT>> states)Deprecated.AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter, org.apache.flink.api.connector.sink2.WriterInitContext context, AsyncSinkWriterConfiguration configuration, Collection<BufferedRequestState<RequestEntryT>> states, BatchCreator<RequestEntryT> batchCreator, RequestBuffer<RequestEntryT> bufferedRequestEntries)
-