org.apache.beam.sdk.io.aws2.kinesis

Interfaces

• AWSClientsProvider
• KinesisPartitioner
• KinesisPartitioner.ExplicitPartitioner
• RateLimitPolicy
• RateLimitPolicyFactory
• WatermarkPolicy
• WatermarkPolicyFactory

Classes

• KinesisIO
• KinesisIO.Read
• KinesisIO.RecordAggregation
• KinesisIO.RecordAggregation.Builder
• KinesisIO.Write
• KinesisIO.Write.Result
• KinesisRecord
• RateLimitPolicyFactory.DefaultRateLimiter
• RateLimitPolicyFactory.DelayIntervalRateLimiter
• TimeUtil
• WatermarkParameters
• WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy
• WatermarkPolicyFactory.CustomWatermarkPolicy
• WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy

Exceptions

• KinesisClientThrottledException