This interface specifies the mapping between elements of a stream to request entries that can be sent to the destination.
|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.
A wrapper that contains a
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.