Package org.apache.beam.sdk.io.kinesis

Transforms for reading and writing from Amazon Kinesis.

See: Description

Interface Summary

Interface	Description
AWSClientsProvider	Provides instances of AWS clients.

Class Summary

Class	Description
KinesisIO	PTransforms for reading from Kinesis streams.
KinesisIO.Read	Implementation of KinesisIO.read().
KinesisRecord	UserRecord enhanced with utility methods.

Package org.apache.beam.sdk.io.kinesis Description

Transforms for reading and writing from Amazon Kinesis.