org.apache.beam.sdk.io.kinesis

Interfaces

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

Classes

• KinesisIO
• KinesisIO.Read
• KinesisIO.Write
• KinesisRecord
• KinesisTransformRegistrar
• KinesisTransformRegistrar.ReadDataBuilder
• KinesisTransformRegistrar.ReadDataBuilder.Configuration
• KinesisTransformRegistrar.WriteBuilder
• KinesisTransformRegistrar.WriteBuilder.Configuration
• RateLimitPolicyFactory.DefaultRateLimiter
• RateLimitPolicyFactory.DelayIntervalRateLimiter
• WatermarkParameters
• WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy
• WatermarkPolicyFactory.CustomWatermarkPolicy
• WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy

Exceptions

• KinesisClientThrottledException