tecton.KinesisOutputStream

class tecton.KinesisOutputStream(stream_name, region, options=None, include_features=False)

Configuration used for a Kinesis output stream.

Methods

__init__

Instantiates a new KinesisOutputStream.
__init__(stream_name, region, options=None, include_features=False)

Instantiates a new KinesisOutputStream.

Parameters

  • stream_name (str) – Name of the Kinesis stream.

  • region (str) – AWS region of the stream, e.g: “us-west-2”.

  • options (Optional[Dict[str, str]]) – A map of additional Spark readStream options. Only roleArn is supported.

  • include_features (bool) – Return feature values in addition to entity keys. Not supported for window aggregate Feature Views.

Returns

A KinesisOutputStream object