org.apache.beam.sdk.io.kinesis

Interfaces

• AWSClientsProvider
• KinesisPartitioner
• RateLimitPolicy
• RateLimitPolicyFactory
• WatermarkPolicy
• WatermarkPolicyFactory

Classes

• KinesisIO
• KinesisIO.Read
• KinesisIO.Write
• KinesisRecord
• RateLimitPolicyFactory.DelayIntervalRateLimiter
• WatermarkParameters
• WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy
• WatermarkPolicyFactory.CustomWatermarkPolicy
• WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy