From 15e16867e9918488d6ff7c7d2d392606bbdfcd83 Mon Sep 17 00:00:00 2001 From: Andreas Motl Date: Tue, 26 Nov 2024 02:11:39 +0100 Subject: [PATCH] Flink: Refactor examples to `framework/` folder --- ...ka-flink.yml => framework-flink-kafka-java.yml} | 14 +++++++------- .../flink/kafka-jdbcsink-java}/.env | 0 .../flink/kafka-jdbcsink-java}/.gitignore | 0 .../flink/kafka-jdbcsink-java}/Makefile | 0 .../flink/kafka-jdbcsink-java}/README.Unix.rst | 0 .../flink/kafka-jdbcsink-java}/README.Windows.rst | 0 .../flink/kafka-jdbcsink-java}/README.rst | 0 .../flink/kafka-jdbcsink-java}/backlog.rst | 0 .../flink/kafka-jdbcsink-java}/docker-compose.yml | 0 .../flink/kafka-jdbcsink-java}/notes.rst | 0 .../flink/kafka-jdbcsink-java}/test.sh | 0 .../flink/kafka-jdbcsink-python}/.env | 0 .../flink/kafka-jdbcsink-python}/Dockerfile | 0 .../flink/kafka-jdbcsink-python}/README.md | 0 .../kafka-jdbcsink-python}/docker-compose.yml | 0 .../flink/kafka-jdbcsink-python}/example.json | 0 .../flink/kafka-jdbcsink-python}/flink_consumer.py | 0 .../kafka-jdbcsink-python}/flink_job.Dockerfile | 0 .../flink/kafka-jdbcsink-python}/pyproject.toml | 0 .../flink/kafka-jdbcsink-python}/requirements.txt | 0 .../kafka-jdbcsink-python}/weather_producer.py | 0 21 files changed, 7 insertions(+), 7 deletions(-) rename .github/workflows/{application-apache-kafka-flink.yml => framework-flink-kafka-java.yml} (68%) rename {application/apache-kafka-flink => framework/flink/kafka-jdbcsink-java}/.env (100%) rename {application/apache-kafka-flink => framework/flink/kafka-jdbcsink-java}/.gitignore (100%) rename {application/apache-kafka-flink => framework/flink/kafka-jdbcsink-java}/Makefile (100%) rename {application/apache-kafka-flink => framework/flink/kafka-jdbcsink-java}/README.Unix.rst (100%) rename {application/apache-kafka-flink => framework/flink/kafka-jdbcsink-java}/README.Windows.rst (100%) rename {application/apache-kafka-flink => framework/flink/kafka-jdbcsink-java}/README.rst (100%) rename {application/apache-kafka-flink => framework/flink/kafka-jdbcsink-java}/backlog.rst (100%) rename {application/apache-kafka-flink => framework/flink/kafka-jdbcsink-java}/docker-compose.yml (100%) rename {application/apache-kafka-flink => framework/flink/kafka-jdbcsink-java}/notes.rst (100%) rename {application/apache-kafka-flink => framework/flink/kafka-jdbcsink-java}/test.sh (100%) rename {application/apache-kafka-flink-streaming => framework/flink/kafka-jdbcsink-python}/.env (100%) rename {application/apache-kafka-flink-streaming => framework/flink/kafka-jdbcsink-python}/Dockerfile (100%) rename {application/apache-kafka-flink-streaming => framework/flink/kafka-jdbcsink-python}/README.md (100%) rename {application/apache-kafka-flink-streaming => framework/flink/kafka-jdbcsink-python}/docker-compose.yml (100%) rename {application/apache-kafka-flink-streaming => framework/flink/kafka-jdbcsink-python}/example.json (100%) rename {application/apache-kafka-flink-streaming => framework/flink/kafka-jdbcsink-python}/flink_consumer.py (100%) rename {application/apache-kafka-flink-streaming => framework/flink/kafka-jdbcsink-python}/flink_job.Dockerfile (100%) rename {application/apache-kafka-flink-streaming => framework/flink/kafka-jdbcsink-python}/pyproject.toml (100%) rename {application/apache-kafka-flink-streaming => framework/flink/kafka-jdbcsink-python}/requirements.txt (100%) rename {application/apache-kafka-flink-streaming => framework/flink/kafka-jdbcsink-python}/weather_producer.py (100%) diff --git a/.github/workflows/application-apache-kafka-flink.yml b/.github/workflows/framework-flink-kafka-java.yml similarity index 68% rename from .github/workflows/application-apache-kafka-flink.yml rename to .github/workflows/framework-flink-kafka-java.yml index af096404..03417376 100644 --- a/.github/workflows/application-apache-kafka-flink.yml +++ b/.github/workflows/framework-flink-kafka-java.yml @@ -1,17 +1,17 @@ -name: Apache Kafka, Apache Flink +name: "Apache Flink: Kafka to JDBC sink (Java)" on: pull_request: branches: ~ paths: - - '.github/workflows/application-apache-kafka-flink.yml' - - 'application/apache-kafka-flink/**' + - '.github/workflows/framework-flink-kafka-java.yml' + - 'framework/flink/kafka-jdbcsink-java/**' - '/requirements.txt' push: branches: [ main ] paths: - - '.github/workflows/application-apache-kafka-flink.yml' - - 'application/apache-kafka-flink/**' + - '.github/workflows/framework-flink-kafka-java.yml' + - 'framework/flink/kafka-jdbcsink-java/**' - '/requirements.txt' # Allow job to be triggered manually. @@ -42,8 +42,8 @@ jobs: - name: Acquire sources uses: actions/checkout@v4 - - name: Validate application/apache-kafka-flink + - name: Validate framework/flink/kafka-jdbcsink-java run: | # TODO: Generalize invocation into `ngr` test runner. - cd application/apache-kafka-flink + cd framework/flink/kafka-jdbcsink-java bash test.sh diff --git a/application/apache-kafka-flink/.env b/framework/flink/kafka-jdbcsink-java/.env similarity index 100% rename from application/apache-kafka-flink/.env rename to framework/flink/kafka-jdbcsink-java/.env diff --git a/application/apache-kafka-flink/.gitignore b/framework/flink/kafka-jdbcsink-java/.gitignore similarity index 100% rename from application/apache-kafka-flink/.gitignore rename to framework/flink/kafka-jdbcsink-java/.gitignore diff --git a/application/apache-kafka-flink/Makefile b/framework/flink/kafka-jdbcsink-java/Makefile similarity index 100% rename from application/apache-kafka-flink/Makefile rename to framework/flink/kafka-jdbcsink-java/Makefile diff --git a/application/apache-kafka-flink/README.Unix.rst b/framework/flink/kafka-jdbcsink-java/README.Unix.rst similarity index 100% rename from application/apache-kafka-flink/README.Unix.rst rename to framework/flink/kafka-jdbcsink-java/README.Unix.rst diff --git a/application/apache-kafka-flink/README.Windows.rst b/framework/flink/kafka-jdbcsink-java/README.Windows.rst similarity index 100% rename from application/apache-kafka-flink/README.Windows.rst rename to framework/flink/kafka-jdbcsink-java/README.Windows.rst diff --git a/application/apache-kafka-flink/README.rst b/framework/flink/kafka-jdbcsink-java/README.rst similarity index 100% rename from application/apache-kafka-flink/README.rst rename to framework/flink/kafka-jdbcsink-java/README.rst diff --git a/application/apache-kafka-flink/backlog.rst b/framework/flink/kafka-jdbcsink-java/backlog.rst similarity index 100% rename from application/apache-kafka-flink/backlog.rst rename to framework/flink/kafka-jdbcsink-java/backlog.rst diff --git a/application/apache-kafka-flink/docker-compose.yml b/framework/flink/kafka-jdbcsink-java/docker-compose.yml similarity index 100% rename from application/apache-kafka-flink/docker-compose.yml rename to framework/flink/kafka-jdbcsink-java/docker-compose.yml diff --git a/application/apache-kafka-flink/notes.rst b/framework/flink/kafka-jdbcsink-java/notes.rst similarity index 100% rename from application/apache-kafka-flink/notes.rst rename to framework/flink/kafka-jdbcsink-java/notes.rst diff --git a/application/apache-kafka-flink/test.sh b/framework/flink/kafka-jdbcsink-java/test.sh similarity index 100% rename from application/apache-kafka-flink/test.sh rename to framework/flink/kafka-jdbcsink-java/test.sh diff --git a/application/apache-kafka-flink-streaming/.env b/framework/flink/kafka-jdbcsink-python/.env similarity index 100% rename from application/apache-kafka-flink-streaming/.env rename to framework/flink/kafka-jdbcsink-python/.env diff --git a/application/apache-kafka-flink-streaming/Dockerfile b/framework/flink/kafka-jdbcsink-python/Dockerfile similarity index 100% rename from application/apache-kafka-flink-streaming/Dockerfile rename to framework/flink/kafka-jdbcsink-python/Dockerfile diff --git a/application/apache-kafka-flink-streaming/README.md b/framework/flink/kafka-jdbcsink-python/README.md similarity index 100% rename from application/apache-kafka-flink-streaming/README.md rename to framework/flink/kafka-jdbcsink-python/README.md diff --git a/application/apache-kafka-flink-streaming/docker-compose.yml b/framework/flink/kafka-jdbcsink-python/docker-compose.yml similarity index 100% rename from application/apache-kafka-flink-streaming/docker-compose.yml rename to framework/flink/kafka-jdbcsink-python/docker-compose.yml diff --git a/application/apache-kafka-flink-streaming/example.json b/framework/flink/kafka-jdbcsink-python/example.json similarity index 100% rename from application/apache-kafka-flink-streaming/example.json rename to framework/flink/kafka-jdbcsink-python/example.json diff --git a/application/apache-kafka-flink-streaming/flink_consumer.py b/framework/flink/kafka-jdbcsink-python/flink_consumer.py similarity index 100% rename from application/apache-kafka-flink-streaming/flink_consumer.py rename to framework/flink/kafka-jdbcsink-python/flink_consumer.py diff --git a/application/apache-kafka-flink-streaming/flink_job.Dockerfile b/framework/flink/kafka-jdbcsink-python/flink_job.Dockerfile similarity index 100% rename from application/apache-kafka-flink-streaming/flink_job.Dockerfile rename to framework/flink/kafka-jdbcsink-python/flink_job.Dockerfile diff --git a/application/apache-kafka-flink-streaming/pyproject.toml b/framework/flink/kafka-jdbcsink-python/pyproject.toml similarity index 100% rename from application/apache-kafka-flink-streaming/pyproject.toml rename to framework/flink/kafka-jdbcsink-python/pyproject.toml diff --git a/application/apache-kafka-flink-streaming/requirements.txt b/framework/flink/kafka-jdbcsink-python/requirements.txt similarity index 100% rename from application/apache-kafka-flink-streaming/requirements.txt rename to framework/flink/kafka-jdbcsink-python/requirements.txt diff --git a/application/apache-kafka-flink-streaming/weather_producer.py b/framework/flink/kafka-jdbcsink-python/weather_producer.py similarity index 100% rename from application/apache-kafka-flink-streaming/weather_producer.py rename to framework/flink/kafka-jdbcsink-python/weather_producer.py