pipelines/clickstream_analytics_java/src/main/java/com/google/cloud/dataflow/solutions/clickstream_analytics/ClickstreamPubSubToBq.java (2 lines): - line 114: // TODO: Bigtable enrichment with pubsub data task is still pending. - line 123: // TODO: Apply analytics to windowwed data pipelines/cdp/cdp_pipeline/customer_data_platform.py (2 lines): - line 27: # FIXME: This will not work in Dataflow, the schema should be passed as an option to the PTrasnform - line 47: "coupon_upc": # FIXME: Is this a dictionary? pipelines/marketing_intelligence/marketing_intelligence_pipeline/pipeline.py (1 line): - line 47: # TODO Add transformation for BigTable Enrichment pipelines/clickstream_analytics_java/src/main/java/com/google/cloud/dataflow/solutions/clickstream_analytics/BigTableEnrichment.java (1 line): - line 20: /*** TODO ***/