| src/etl/examples/etl-example/sql/select_product.sql | |
|
|
| src/etl/examples/file-ingest/acme/__init__.py | 0 | A 0 mins |
|
| src/etl/examples/file-ingest/acme/operators/__init__.py | 0 | A 0 mins |
|
| src/etl/examples/file-ingest/acme/operators/file_operators.py | 93 | B 5 hrs |
|
| src/etl/examples/file-ingest/create_files.sh | |
|
|
| src/etl/examples/file-ingest/file_ingest.py | 34 | A 30 mins |
|
| src/etl/examples/hive-example/core-site.xml | |
|
|
| src/etl/examples/hive-example/dags/acme/__init__.py | 0 | A 0 mins |
|
| src/etl/examples/hive-example/dags/acme/hooks/__init__.py | 0 | A 0 mins |
|
| src/etl/examples/hive-example/dags/acme/hooks/hive_hooks.py | 664 | F 4 days |
|
| src/etl/examples/hive-example/dags/acme/operators/__init__.py | 0 | A 0 mins |
|
| src/etl/examples/hive-example/dags/acme/operators/hive_operators.py | 112 | A 1 hr |
|
| src/etl/examples/hive-example/dags/init_hive_example.py | 67 | A 0 mins |
|
| src/etl/examples/hive-example/dags/process_hive_dwh.py | 74 | A 0 mins |
|
| src/etl/examples/hive-example/dags/staging-oltp.py | 64 | B 5 hrs |
|
| src/etl/examples/hive-example/hdfs-site.xml | |
|
|
| src/etl/examples/hive-example/hql/customer/step_1.hql | |
|
|
| src/etl/examples/hive-example/hql/customer/step_2.hql | |
|
|
| src/etl/examples/hive-example/hql/order/step_1.hql | |
|
|
| src/etl/examples/hive-example/hql/order/step_2.hql | |
|
|
| src/etl/examples/hive-example/hql/product/step_1.hql | |
|
|
| src/etl/examples/hive-example/hql/product/step_2.hql | |
|
|
| src/etl/examples/hive-example/mapred-site.xml | |
|
|
| src/etl/examples/hive-example/sql/select_customer.sql | |
|
|
| src/etl/examples/hive-example/sql/select_order_info.sql | |
|
|
| src/etl/examples/hive-example/sql/select_orderline.sql | |
|
|
| src/etl/examples/hive-example/sql/select_product.sql | |
|
|
| src/etl/ideas.rst | |
|
|
| src/etl/run_hive_example.sh | |
|
|
| src/examples/example_bash_operator.py | 33 | A 0 mins |
|
| src/examples/example_branch_operator.py | 32 | A 0 mins |
|
| src/examples/example_branch_python_dop_operator_3.py | 30 | A 0 mins |
|
| src/examples/example_docker_operator.py | 41 | A 0 mins |
|
| src/examples/example_http_operator.py | 67 | A 0 mins |
|
| src/examples/example_latest_only.py | 17 | A 45 mins |
|
| src/examples/example_latest_only_with_trigger.py | 23 | A 45 mins |
|
| src/examples/example_passing_params_via_test_command.py | 33 | A 0 mins |
|
| src/examples/example_python_operator.py | 33 | A 0 mins |
|
| src/examples/example_short_circuit_operator.py | 18 | A 1 hr |
|
| src/examples/example_skip_dag.py | 23 | A 0 mins |
|
| src/examples/example_subdag_operator.py | 46 | A 0 mins |
|
| src/examples/example_trigger_controller_dag.py | 38 | A 0 mins |
|
| src/examples/example_trigger_target_dag.py | 25 | A 0 mins |
|
| src/examples/example_xcom.py | 34 | A 0 mins |
|
| src/gcp/LICENSE | |
|
|
| src/gcp/README.md | |
|
|
| src/gcp/dags/__init__.py | 0 | A 0 mins |
|
| src/gcp/dags/bigquery.py | 77 | A 30 mins |
|
| src/gcp/dags/cloud_storage.py | 30 | A 30 mins |
|
| src/gcp/dags/dataproc.py | 62 | A 30 mins |
|