Class and Description |
---|
KinesisProxyInterface
Interface for a Kinesis proxy that operates on multiple Kinesis streams within the same AWS
service region.
|
KinesisProxyV2Interface
Interface for a Kinesis proxy using AWS SDK v2.x operating on multiple Kinesis streams within the
same AWS service region.
|
Class and Description |
---|
FullJitterBackoff
Used to calculate full jitter backoff sleep durations.
|
KinesisProxyV2Interface
Interface for a Kinesis proxy using AWS SDK v2.x operating on multiple Kinesis streams within the
same AWS service region.
|
Class and Description |
---|
FullJitterBackoff
Used to calculate full jitter backoff sleep durations.
|
GetShardListResult
Basic model class to bundle the shards retrieved from Kinesis on a
KinesisProxyInterface.getShardList(Map) call. |
KinesisProxy
Kinesis proxy implementation - a utility class that is used as a proxy to make calls to AWS
Kinesis for several functions, such as getting a list of shards and fetching a batch of data
records starting from a specified record sequence number.
|
KinesisProxyInterface
Interface for a Kinesis proxy that operates on multiple Kinesis streams within the same AWS
service region.
|
KinesisProxyV2Interface
Interface for a Kinesis proxy using AWS SDK v2.x operating on multiple Kinesis streams within the
same AWS service region.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.