See: Description
Interface | Description |
---|---|
AWSClientsProvider |
Provides instances of AWS clients.
|
KinesisPartitioner |
Kinesis interface for custom partitioner.
|
RateLimitPolicy | |
RateLimitPolicyFactory |
Implement this interface to create a
RateLimitPolicy . |
WatermarkPolicy |
Implement this interface to define a custom watermark calculation heuristic.
|
WatermarkPolicyFactory |
Implement this interface to create a
WatermarkPolicy . |
Class | Description |
---|---|
KinesisIO | Deprecated
Module
beam-sdks-java-io-kinesis is deprecated and will be eventually
removed. |
KinesisIO.Read<T> |
Implementation of
KinesisIO.read() . |
KinesisIO.Write |
Implementation of
KinesisIO.write() . |
KinesisRecord |
UserRecord enhanced with utility methods. |
KinesisTransformRegistrar |
Exposes
KinesisIO.Write and KinesisIO.Read as an external transform for
cross-language usage. |
KinesisTransformRegistrar.ReadDataBuilder | |
KinesisTransformRegistrar.ReadDataBuilder.Configuration | |
KinesisTransformRegistrar.WriteBuilder | |
KinesisTransformRegistrar.WriteBuilder.Configuration | |
RateLimitPolicyFactory.DefaultRateLimiter |
Default rate limiter that throttles reading from a shard using an exponential backoff if the
response is empty or if the consumer is throttled by AWS.
|
RateLimitPolicyFactory.DelayIntervalRateLimiter | |
WatermarkParameters |
WatermarkParameters contains the parameters used for watermark computation. |
WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy |
ArrivalTimeWatermarkPolicy uses
WatermarkPolicyFactory.CustomWatermarkPolicy for watermark computation. |
WatermarkPolicyFactory.CustomWatermarkPolicy |
CustomWatermarkPolicy uses parameters defined in
WatermarkParameters to compute
watermarks. |
WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy |
Watermark policy where the processing time is used as the event time.
|
Exception | Description |
---|---|
KinesisClientThrottledException |
Thrown when the Kinesis client was throttled due to rate limits.
|