org.apache.beam.sdk.io.kinesis
Interfaces
AWSClientsProvider
KinesisPartitioner
WatermarkPolicy
WatermarkPolicyFactory
Classes
KinesisIO
KinesisIO.Read
KinesisIO.Write
KinesisRecord
WatermarkParameters
WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy
WatermarkPolicyFactory.CustomWatermarkPolicy
WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy