org.apache.beam.sdk.io.kinesis

Interfaces

• AWSClientsProvider
• KinesisPartitioner

Classes

• KinesisIO
• KinesisIO.Read
• KinesisIO.Write
• KinesisRecord