path	# lines of code
pipelines/clickstream_analytics_java/src/main/java/com/google/cloud/dataflow/solutions/clickstream_analytics/JsonToTableRows.java	57
pipelines/clickstream_analytics_java/src/main/java/com/google/cloud/dataflow/solutions/clickstream_analytics/BigTableEnrichment.java	3
pipelines/clickstream_analytics_java/src/main/java/com/google/cloud/dataflow/solutions/clickstream_analytics/ClickstreamPubSubToBq.java	133
pipelines/clickstream_analytics_java/src/main/java/com/google/cloud/dataflow/solutions/clickstream_analytics/Metrics.java	12
pipelines/ml_ai_python/ml_ai_pipeline/pipeline.py	29
pipelines/ml_ai_python/ml_ai_pipeline/__init__.py	1
pipelines/ml_ai_python/ml_ai_pipeline/options.py	8
pipelines/ml_ai_python/ml_ai_pipeline/model_handlers.py	22
pipelines/ml_ai_python/MANIFEST.in	1
pipelines/ml_ai_python/setup.py	10
pipelines/ml_ai_python/cloudbuild.yaml	18
pipelines/ml_ai_python/main.py	16
pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/ETLIntegration.java	41
pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/options/SpannerPublisherOptions.java	22
pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/data/SchemaUtils.java	22
pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/data/TaxiObjects.java	66
pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/transform/TaxiEventProcessor.java	219
pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/transform/RowToError.java	49
pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/load/Spanner.java	74
pipelines/iot_analytics/scripts/create_data.py	41
pipelines/iot_analytics/scripts/publish_on_pubsub.py	20
pipelines/iot_analytics/scripts/vehicle_data.jsonl	10
pipelines/iot_analytics/scripts/create_and_populate_bigtable.py	69
pipelines/iot_analytics/scripts/maintenance_data.jsonl	10
pipelines/iot_analytics/scripts/model.py	43
pipelines/iot_analytics/MANIFEST.in	1
pipelines/iot_analytics/setup.py	9
pipelines/iot_analytics/cloudbuild.yaml	11
pipelines/iot_analytics/main.py	16
pipelines/iot_analytics/iot_analytics_pipeline/pipeline.py	68
pipelines/iot_analytics/iot_analytics_pipeline/__init__.py	1
pipelines/iot_analytics/iot_analytics_pipeline/options.py	24
pipelines/iot_analytics/iot_analytics_pipeline/trigger_inference.py	20
pipelines/iot_analytics/iot_analytics_pipeline/aggregate_metrics.py	67
pipelines/iot_analytics/iot_analytics_pipeline/parse_timestamp.py	24
pipelines/marketing_intelligence/MANIFEST.in	1
pipelines/marketing_intelligence/setup.py	10
pipelines/marketing_intelligence/cloudbuild.yaml	12
pipelines/marketing_intelligence/main.py	16
pipelines/marketing_intelligence/marketing_intelligence_pipeline/pipeline.py	38
pipelines/marketing_intelligence/marketing_intelligence_pipeline/__init__.py	1
pipelines/marketing_intelligence/marketing_intelligence_pipeline/options.py	10
pipelines/anomaly_detection/MANIFEST.in	1
pipelines/anomaly_detection/setup.py	10
pipelines/anomaly_detection/cloudbuild.yaml	12
pipelines/anomaly_detection/main.py	16
pipelines/anomaly_detection/anomaly_detection_pipeline/pipeline.py	34
pipelines/anomaly_detection/anomaly_detection_pipeline/__init__.py	1
pipelines/anomaly_detection/anomaly_detection_pipeline/options.py	10
pipelines/cdp/cdp_pipeline/__init__.py	1
pipelines/cdp/cdp_pipeline/customer_data_platform.py	78
pipelines/cdp/cdp_pipeline/options.py	11
pipelines/cdp/cdp_pipeline/generate_transaction_data.py	46
pipelines/cdp/MANIFEST.in	1
pipelines/cdp/setup.py	10
pipelines/cdp/cloudbuild.yaml	11
pipelines/cdp/main.py	15
terraform/ml_ai/main.tf	158
terraform/ml_ai/variables.tf	32
terraform/iot_analytics/main.tf	156
terraform/iot_analytics/variables.tf	37
terraform/clickstream_analytics/main.tf	160
terraform/clickstream_analytics/variables.tf	32
terraform/marketing_intelligence/main.tf	185
terraform/marketing_intelligence/variables.tf	42
terraform/anomaly_detection/main.tf	184
terraform/anomaly_detection/variables.tf	42
terraform/log_replication_splunk/main.tf	166
terraform/log_replication_splunk/variables.tf	47
terraform/etl_integration/main.tf	211
terraform/etl_integration/variables.tf	37
terraform/cdp/main.tf	170
terraform/cdp/variables.tf	47