org.apache.beam.sdk.io.aws2.kinesis
Interfaces
KinesisIOOptions
KinesisPartitioner
KinesisPartitioner.ExplicitPartitioner
RateLimitPolicy
RateLimitPolicyFactory
WatermarkPolicy
WatermarkPolicyFactory
Classes
KinesisIO
KinesisIO.Read
KinesisIO.RecordAggregation
KinesisIO.RecordAggregation.Builder
KinesisIO.Write
KinesisIO.Write.Result
KinesisIOOptions.KinesisIOOptionsRegistrar
KinesisIOOptions.MapFactory
KinesisRecord
RateLimitPolicyFactory.DefaultRateLimiter
RateLimitPolicyFactory.DelayIntervalRateLimiter
TimeUtil
WatermarkParameters
WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy
WatermarkPolicyFactory.CustomWatermarkPolicy
WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy
Exceptions
KinesisClientThrottledException