PushConfig

Summary

The PushConfig class is used to configure the ingestion of records via the Stream Ingest API.

This class is used as an input to a :class:StreamSource's parameter stream_config. Declaring this configuration class alone will not register a Data Source. Instead, declare as a part of StreamSource that takes this configuration class instance as a parameter.

Example

from tecton import PushConfig

stream_config = PushConfig(log_offline=False)

Methods

__init__(...)

Instantiates a new PushConfig.

Parameters

• log_offline: If set to True, the Stream Ingest API will log the incoming records for the stream source to an offline table, which can later be used for training data generation.
• post_processor: An optional user-defined function that pre-processes records in the source.
• post_processor_mode: Execution mode for the post_processor, must be one of python or pandas
• input_schema: Input schema for the post_processor

Returns

A PushConfig class instance.