kinesis_dataset: Creates a 'KinesisDataset'.

In tfio: Interface to 'TensorFlow IO'

Description

Kinesis is a managed service provided by AWS for data streaming. This dataset reads messages from Kinesis with each message presented as a tf.string.

Usage

kinesis_dataset(stream, shard = "", read_indefinitely = TRUE, interval = 1e+05)

Arguments

stream	A tf.string tensor containing the name of the stream.
shard	A tf.string tensor containing the id of the shard.
read_indefinitely	If True, the Kinesis dataset will keep retry again on EOF after the interval period. If False, then the dataset will stop on EOF. The default value is True.
interval	The interval for the Kinesis Client to wait before it tries to get records again (in millisecond).

tfio documentation built on Dec. 25, 2019, 5:06 p.m.