org.apache.beam.sdk.io.aws2.kinesis
Interfaces
AWSClientsProvider
RateLimitPolicy
RateLimitPolicyFactory
WatermarkPolicy
WatermarkPolicyFactory
Classes
KinesisIO
KinesisIO.Read
KinesisRecord
RateLimitPolicyFactory.DelayIntervalRateLimiter
TimeUtil
WatermarkParameters
WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy
WatermarkPolicyFactory.CustomWatermarkPolicy
WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy
Exceptions
KinesisClientThrottledException