Interface | Description |
---|---|
ElementConverter<InputT,RequestEntryT> |
This interface specifies the mapping between elements of a stream to request entries that can be
sent to the destination.
|
Class | Description |
---|---|
AsyncSinkFatalExceptionClassifiers |
Common retry exception classifiers needed for common errors.
|
AsyncSinkWriter<InputT,RequestEntryT extends Serializable> |
A generic sink writer that handles the general behaviour of a sink such as batching and flushing,
and allows extenders to implement the logic for persisting individual request elements, with
allowance for retries.
|
AsyncSinkWriterStateSerializer<RequestEntryT extends Serializable> |
Serializer class for
AsyncSinkWriter state. |
BufferedRequestState<RequestEntryT extends Serializable> |
Class holding state of
AsyncSinkWriter needed at taking a snapshot. |
RequestEntryWrapper<RequestEntryT> |
A wrapper that contains a
RequestEntryT ready to be written by the Sink Writer class,
along with the size of that entry as defined by the method getSizeInBytes(RequestEntryT)
of the AsyncSinkWriter . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.