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 thepost_processor
, must be one ofpython
orpandas
input_schema
: Input schema for thepost_processor
Returns​
A PushConfig class instance.