| data-orchestration/hm-prefect/workflows/ingest-data/src/tasks/copy_to_local.py | 11 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/ingest-data/src/tasks/get_missing_files.py | 25 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/ingest-data/src/tasks/write_to_delta_lake.py | 33 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/ingest-data/src/tasks/write_to_s3.py | 9 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/ingest-data/src/utils/write_data.py | 37 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/ingest-data/tools/set_up/config.py | 7 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/ingest-data/tools/set_up/main.py | 34 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/ingest-data/tools/set_up/utils/create_aws_credentials_block.py | 12 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/ingest-data/tools/set_up/utils/create_concurrency_limit.py | 9 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/ingest-data/tools/set_up/utils/create_kubernetes_job_block.py | 7 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/ingest-data/tools/set_up/utils/get_env_variable.py | 6 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/print-platform/Dockerfile | |
|
|
| data-orchestration/hm-prefect/workflows/print-platform/Makefile | |
|
|
| data-orchestration/hm-prefect/workflows/print-platform/add_kubernetes_job_block.py | 7 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/print-platform/poetry.lock | |
|
|
| data-orchestration/hm-prefect/workflows/print-platform/poetry.toml | |
|
|
| data-orchestration/hm-prefect/workflows/print-platform/pyproject.toml | |
|
|
| data-orchestration/hm-prefect/workflows/print-platform/src/dummy_test.py | 3 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/print-platform/src/main.py | 10 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/print-platform/tools/set_up/config.py | 1 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/print-platform/tools/set_up/main.py | 7 | A 0 mins |
|
| data-orchestration/hm-prefect/workflows/print-platform/tools/set_up/utils/create_kubernetes_job_block.py | 7 | A 0 mins |
|
| data-orchestration/temporal/Makefile | |
|
|
| data-processing/flink/applications/stream-tweets/Dockerfile | |
|
|
| data-processing/flink/applications/stream-tweets/Makefile | |
|
|
| data-processing/flink/applications/stream-tweets/bin/migrate_timescaledb_twitter_db.sh | |
|
|
| data-processing/flink/applications/stream-tweets/migrations/000001_create_twitter_user_table.down.sql | |
|
|
| data-processing/flink/applications/stream-tweets/migrations/000001_create_twitter_user_table.up.sql | |
|
|
| data-processing/flink/applications/stream-tweets/migrations/000002_create_tweet_table.down.sql | |
|
|
| data-processing/flink/applications/stream-tweets/migrations/000002_create_tweet_table.up.sql | |
|
|
| data-processing/flink/applications/stream-tweets/migrations/000003_create_hashtag_table.down.sql | |
|
|
| data-processing/flink/applications/stream-tweets/migrations/000003_create_hashtag_table.up.sql | |
|
|
| data-processing/flink/applications/stream-tweets/migrations/000004_create_tweet_hashtag_table.down.sql | |
|
|
| data-processing/flink/applications/stream-tweets/migrations/000004_create_tweet_hashtag_table.up.sql | |
|
|
| data-processing/flink/applications/stream-tweets/pom.xml | |
|
|
| data-processing/flink/applications/stream-tweets/src/main/java/com/hongbomiao/Main.java | 155 | B 5 hrs |
|
| data-processing/flink/applications/stream-tweets/src/main/java/com/hongbomiao/utils/Config.java | 29 | A 0 mins |
|
| data-processing/flink/applications/stream-tweets/src/main/java/com/hongbomiao/utils/Redis.java | 21 | A 0 mins |
|
| data-processing/flink/applications/stream-tweets/src/main/java/com/hongbomiao/utils/Tweet.java | 16 | A 0 mins |
|
| data-processing/flink/applications/stream-tweets/src/main/java/com/hongbomiao/utils/TwitterUser.java | 11 | A 0 mins |
|
| data-processing/flink/applications/stream-tweets/src/main/resources/application-development.properties.template | |
|
|
| data-processing/flink/applications/stream-tweets/src/main/resources/application-production.properties.template | |
|
|
| data-processing/flink/applications/stream-tweets/src/main/resources/log4j2.properties | |
|
|
| data-processing/hm-spark/Makefile | |
|
|
| data-processing/hm-spark/applications/analyze-coffee-customers/Makefile | |
|
|
| data-processing/hm-spark/applications/analyze-coffee-customers/poetry.lock | |
|
|
| data-processing/hm-spark/applications/analyze-coffee-customers/poetry.toml | |
|
|
| data-processing/hm-spark/applications/analyze-coffee-customers/pyproject.toml | |
|
|
| data-processing/hm-spark/applications/analyze-coffee-customers/src/dummy_test.py | 3 | A 0 mins |
|
| data-processing/hm-spark/applications/analyze-coffee-customers/src/main.py | 44 | A 0 mins |
|