Functions — github.com/bmd1905/Customer-Purchase-Prediction-ML-System

hub / github.com/bmd1905/Customer-Purchase-Prediction-ML-System / functions

Functions136 in github.com/bmd1905/Customer-Purchase-Prediction-ML-System

⨍ Functions 136◇ Types & classes 25 ↳ Endpoints 2

Method__init__

(self, model_name: str, mlflow_uri: str)

src/serving/prediction_service.py:16

Method__init__

( self, feature_service: OnlineFeatureService, prediction_service: PredictionService,

src/serving/main.py:45

Method__post_init__

Validate the configuration

src/orchestration/include/config/data_pipeline_config.py:14

Method_ingest_stream_data

(self)

src/feature_stores/ingest_stream.py:352

Methodadmin_client

Lazy initialization of Kafka admin client.

src/streaming/jobs/schema_validation_job.py:251

Methodalert_handler

Handle alerts - you can customize this to send to different destinations

src/streaming/jobs/alert_invalid_events_job.py:48

Functioncategorize_price

Categorize price into tiers

src/orchestration/dags/data_pipeline/silver/transform_data.py:12

Functioncheck_prerequisites

Check all prerequisites before starting the layer

src/orchestration/dags/data_pipeline.py:49

Methodcoffee

(self)

src/observability/signoz/common/locust-scripts/locustfile.py:20

Methodcreate_pipeline

(self, env: StreamExecutionEnvironment)

src/streaming/jobs/alert_invalid_events_job.py:54

Methodcreate_pipeline

(self, env: StreamExecutionEnvironment)

src/streaming/jobs/schema_validation_job.py:272

Functiondebug_data

Debug task to inspect data between layers

src/orchestration/dags/data_pipeline.py:131

Methodexecute_query

Maintained for backwards compatibility

src/cdc/postgresql_client.py:35

Functionf

()

src/ray/ray_test.py:20

Functionformat_record

(row)

src/producer/produce.py:116

Methodget_columns

(self, table_name)

src/cdc/postgresql_client.py:43

Methodget_columns

Define the PostgreSQL table columns

src/orchestration/include/common/scripts/event_schema.py:14

Functionget_features

(request: FeatureRequest)

src/feature_stores/api.py:25

Functioningest_data

(config: DataPipelineConfig, valid: bool)

src/orchestration/dags/data_pipeline.py:63

Methodjapanese

(self)

src/observability/signoz/common/locust-scripts/locustfile.py:16

Methodjob_name

(self)

src/streaming/jobs/alert_invalid_events_job.py:23

Methodjob_name

Return the name of the job

src/streaming/jobs/base.py:16

Methodjob_name

(self)

src/streaming/jobs/schema_validation_job.py:247

Functionmain

()

src/observability/signoz/clickhouse-setup/user_scripts/histogramQuantile.go:194

Functionpreprocess_fn

Transform validated events and write to both online and offline stores.

src/feature_stores/ingest_stream.py:187

Methodprocess_invalid_event

Process invalid event and format alert message

src/streaming/jobs/alert_invalid_events_job.py:26

Functionprocess_s3_object

Process a single S3 object with performance tracking

src/orchestration/dags/data_pipeline/bronze/ingest_raw_data.py:65

Methodrachel

(self)

src/observability/signoz/common/locust-scripts/locustfile.py:8

Functionrender_sql_template

Load and render SQL template with variables

src/orchestration/include/common/scripts/sql_utils.py:13

Functionrun_materialization

Runs Feast materialize_incremental every hour, to sync data from offline to online store for historical completeness.

src/feature_stores/ingest_stream.py:395

Functionsplit_category_code

Split category code into L1, L2, L3 categories

src/orchestration/dags/data_pipeline/silver/transform_data.py:24

Functionstreaming_features

(df: DataFrame)

src/feature_stores/features_view.py:32

Functiontrain_xgboost

(config)

src/orchestration/dags/training_pipeline/hyperparameter_tuning.py:48

Methodtrom

(self)

src/observability/signoz/common/locust-scripts/locustfile.py:12

Functionvalidate_data

(raw_data: Dict[str, Any])

src/orchestration/dags/data_pipeline.py:72

Functionvalidate_schema

Validate a record against its schema.

src/streaming/jobs/schema_validation_job.py:122

← previous101–136 of 136, ranked by callers