| src/gcp/dags/gcp_smoke/gsob_extract_day.sql | |
|
|
| src/gcp/dags/support/__init__.py | 0 | A 0 mins |
|
| src/gcp/dags/support/schemas.py | 28 | A 0 mins |
|
| src/gcp/external/afgc-dataflow-java/build.gradle | |
|
|
| src/gcp/external/afgc-dataflow-java/gradle/wrapper/gradle-wrapper.jar | |
|
|
| src/gcp/external/afgc-dataflow-java/gradle/wrapper/gradle-wrapper.properties | |
|
|
| src/gcp/external/afgc-dataflow-java/gradlew | |
|
|
| src/gcp/external/afgc-dataflow-java/gradlew.bat | |
|
|
| src/gcp/external/afgc-dataflow-java/pipeline/build.gradle | |
|
|
| src/gcp/external/afgc-dataflow-java/pipeline/src/main/java/airflow/gcloud/pipeline/Bq2BqPipeline.java | 26 | A 0 mins |
|
| src/gcp/external/afgc-dataflow-java/pipeline/src/main/java/airflow/gcloud/pipeline/CopyPipeline.java | 24 | A 0 mins |
|
| src/gcp/external/afgc-dataflow-java/settings.gradle | |
|
|
| src/gcp/external/afgc-dataflow-java/transform/build.gradle | |
|
|
| src/gcp/external/afgc-dataflow-java/transform/src/main/java/airflow/gcloud/BqSchemaFor.java | 37 | A 1 hr |
|
| src/gcp/external/afgc-dataflow-java/transform/src/main/java/airflow/gcloud/data/convert/ConvertObjectToStringFn.java | 8 | A 0 mins |
|
| src/gcp/external/afgc-dataflow-java/transform/src/main/java/airflow/gcloud/model/EmailEvent.java | 9 | A 0 mins |
|
| src/gcp/external/afgc-dataflow-java/transform/src/main/java/airflow/gcloud/transform/NoopFn.java | 11 | A 0 mins |
|
| src/gcp/external/afgc-spark-scala/src/main/scala/luigi/gcloud/spark/Copy.scala | 15 | A 0 mins |
|
| src/gcp/img/airflow_connection.png | |
|
|
| src/gcp/img/airflow_variables.png | |
|
|
| src/gcp/img/console_service_account.png | |
|
|
| src/gcp/img/create_service_account.png | |
|
|
| src/plugins/README.md | |
|
|
| src/plugins/__init__.py | 12 | A 0 mins |
|
| src/plugins/blueprints/__init__.py | 1 | A 0 mins |
|
| src/plugins/blueprints/trigger_dag.py | 132 | A 0 mins |
|
| src/plugins/dags/book_data.py | 26 | A 0 mins |
|
| src/plugins/dags/daily_processing.py | 32 | A 0 mins |
|
| src/plugins/dags/diamond.py | 35 | A 0 mins |
|
| src/plugins/operators/__init__.py | 8 | A 0 mins |
|
| src/plugins/operators/book_data.py | 13 | A 55 mins |
|
| src/plugins/operators/decide.py | 28 | A 0 mins |
|
| src/plugins/operators/predict.py | 16 | A 55 mins |
|
| src/singer/dags/singer.py | 50 | A 2 hrs |
|
| src/singer/scripts/cleanup.py | 9 | A 0 mins |
|
| src/singer/scripts/downloadtoday.py | 27 | A 0 mins |
|
| src/singer/scripts/extractdownloads.py | 25 | A 0 mins |
|
| src/singer/scripts/generatesingerconfig.py | 21 | A 0 mins |
|
| src/tutorial/tutorial.py | 41 | A 55 mins |
|
