Data Sources

Tecton Objects

tecton.BatchSource

A Tecton BatchSource, used to read batch data into Tecton for use in a BatchFeatureView.

tecton.StreamSource

A Tecton StreamSource, used to unify stream and batch data into Tecton for use in a StreamFeatureView.

tecton.PushSource

A Tecton PushSource, used to configure the Tecton Online Ingest API for use in a StreamFeatureView.

Constructors

tecton.spark_batch_config

Declare a tecton.SparkBatchConfig for configuring a Batch Source with a Data Source Function.

tecton.spark_stream_config

Declare a tecton.SparkStreamConfig for configuring a Stream Source with a Data Source Function.

Config Classes and Helpers

tecton.DatetimePartitionColumn

Helper class to tell Tecton how underlying flat files are date/time partitioned for Hive/Glue data sources.

tecton.FileConfig

Configuration used to reference a file or directory (S3, etc.)

tecton.FilterContext

FilterContext is passed as an argument to Data Source Function for time filtering.

tecton.HiveConfig

Configuration used to reference a Hive table.

tecton.KafkaConfig

Configuration used to reference a Kafka stream.

tecton.KinesisConfig

Configuration used to reference a Kinesis stream.

tecton.RedshiftConfig

Configuration used to reference a Redshift table or query.

tecton.RequestSource

Declare a RequestSource, for using request-time data in an OnDemandFeatureView.

tecton.SnowflakeConfig

Configuration used to reference a Snowflake table or query.

tecton.SparkBatchConfig

Configuration used to define a batch source using a Data Source Function.

tecton.SparkStreamConfig

Configuration used to define a stream source using a Data Source Function.

Fetch Applied Objects

tecton.Workspace.get_data_source

Returns a Data Source that has been applied to a workspace.

tecton.Workspace.list_data_sources

Returns a list of all registered Data Sources within a workspace.