@Experimental(value=SOURCE_SINK)

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.
KinesisPartitioner	Kinesis interface for custom partitioner.
WatermarkPolicy	Implement this interface to define a custom watermark calculation heuristic.
WatermarkPolicyFactory	Implement this interface to create a WatermarkPolicy.

Class Summary

Class	Description
KinesisIO	PTransforms for reading from and writing to Kinesis streams.
KinesisIO.Read	Implementation of KinesisIO.read().
KinesisIO.Write	Implementation of KinesisIO.write().
KinesisRecord	UserRecord enhanced with utility methods.
WatermarkParameters	WatermarkParameters contains the parameters used for watermark computation.
WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy	ArrivalTimeWatermarkPolicy uses WatermarkPolicyFactory.CustomWatermarkPolicy for watermark computation.
WatermarkPolicyFactory.CustomWatermarkPolicy	CustomWatermarkPolicy uses parameters defined in WatermarkParameters to compute watermarks.
WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy	Watermark policy where the processing time is used as the event time.

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

Transforms for reading and writing from Amazon Kinesis.