Modifier and Type | Method and Description |
---|---|
protected ElementConverter<InputT,RequestEntryT> |
AsyncSinkBase.getElementConverter() |
Constructor and Description |
---|
AsyncSinkBase(ElementConverter<InputT,RequestEntryT> elementConverter,
int maxBatchSize,
int maxInFlightRequests,
int maxBufferedRequests,
long maxBatchSizeInBytes,
long maxTimeInBufferMS,
long maxRecordSizeInBytes) |
Constructor and Description |
---|
AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter,
Sink.InitContext context,
AsyncSinkWriterConfiguration configuration,
Collection<BufferedRequestState<RequestEntryT>> states) |
AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter,
Sink.InitContext context,
int maxBatchSize,
int maxInFlightRequests,
int maxBufferedRequests,
long maxBatchSizeInBytes,
long maxTimeInBufferMS,
long maxRecordSizeInBytes)
Deprecated.
|
AsyncSinkWriter(ElementConverter<InputT,RequestEntryT> elementConverter,
Sink.InitContext context,
int maxBatchSize,
int maxInFlightRequests,
int maxBufferedRequests,
long maxBatchSizeInBytes,
long maxTimeInBufferMS,
long maxRecordSizeInBytes,
Collection<BufferedRequestState<RequestEntryT>> states)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
KinesisFirehoseSinkElementConverter<InputT>
An implementation of the
ElementConverter that uses the AWS Kinesis SDK v2. |
Modifier and Type | Class and Description |
---|---|
class |
KinesisStreamsSinkElementConverter<InputT>
An implementation of the
ElementConverter that uses the AWS Kinesis SDK v2. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.