org.apache.beam.sdk.io.kinesis
Classes
KinesisIO
KinesisIO.Read
KinesisRecord