Flink: Refactor examples to framework/ folder

crate · Nov 26, 2024 · 15e1686 · 15e1686
1 parent 2fd3473
commit 15e1686
Show file tree

Hide file tree

Showing 21 changed files with 7 additions and 7 deletions.
diff --git a/...kflows/application-apache-kafka-flink.yml → .../workflows/framework-flink-kafka-java.yml b/...kflows/application-apache-kafka-flink.yml → .../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 → framework/flink/kafka-jdbcsink-java/.env b/application/apache-kafka-flink/.env → framework/flink/kafka-jdbcsink-java/.env
diff --git a/application/apache-kafka-flink/.gitignore → ...work/flink/kafka-jdbcsink-java/.gitignore b/application/apache-kafka-flink/.gitignore → ...work/flink/kafka-jdbcsink-java/.gitignore
diff --git a/application/apache-kafka-flink/Makefile → framework/flink/kafka-jdbcsink-java/Makefile b/application/apache-kafka-flink/Makefile → framework/flink/kafka-jdbcsink-java/Makefile
diff --git a/...cation/apache-kafka-flink/README.Unix.rst → ...flink/kafka-jdbcsink-java/README.Unix.rst b/...cation/apache-kafka-flink/README.Unix.rst → ...flink/kafka-jdbcsink-java/README.Unix.rst
diff --git a/...ion/apache-kafka-flink/README.Windows.rst → ...nk/kafka-jdbcsink-java/README.Windows.rst b/...ion/apache-kafka-flink/README.Windows.rst → ...nk/kafka-jdbcsink-java/README.Windows.rst
diff --git a/application/apache-kafka-flink/README.rst → ...work/flink/kafka-jdbcsink-java/README.rst b/application/apache-kafka-flink/README.rst → ...work/flink/kafka-jdbcsink-java/README.rst
diff --git a/application/apache-kafka-flink/backlog.rst → ...ork/flink/kafka-jdbcsink-java/backlog.rst b/application/apache-kafka-flink/backlog.rst → ...ork/flink/kafka-jdbcsink-java/backlog.rst
diff --git a/...ion/apache-kafka-flink/docker-compose.yml → ...nk/kafka-jdbcsink-java/docker-compose.yml b/...ion/apache-kafka-flink/docker-compose.yml → ...nk/kafka-jdbcsink-java/docker-compose.yml
diff --git a/application/apache-kafka-flink/notes.rst → ...ework/flink/kafka-jdbcsink-java/notes.rst b/application/apache-kafka-flink/notes.rst → ...ework/flink/kafka-jdbcsink-java/notes.rst
diff --git a/application/apache-kafka-flink/test.sh → framework/flink/kafka-jdbcsink-java/test.sh b/application/apache-kafka-flink/test.sh → framework/flink/kafka-jdbcsink-java/test.sh
diff --git a/...ication/apache-kafka-flink-streaming/.env → framework/flink/kafka-jdbcsink-python/.env b/...ication/apache-kafka-flink-streaming/.env → framework/flink/kafka-jdbcsink-python/.env
diff --git a/...n/apache-kafka-flink-streaming/Dockerfile → ...rk/flink/kafka-jdbcsink-python/Dockerfile b/...n/apache-kafka-flink-streaming/Dockerfile → ...rk/flink/kafka-jdbcsink-python/Dockerfile
diff --git a/...on/apache-kafka-flink-streaming/README.md → ...ork/flink/kafka-jdbcsink-python/README.md b/...on/apache-kafka-flink-streaming/README.md → ...ork/flink/kafka-jdbcsink-python/README.md
diff --git a/...-kafka-flink-streaming/docker-compose.yml → .../kafka-jdbcsink-python/docker-compose.yml b/...-kafka-flink-streaming/docker-compose.yml → .../kafka-jdbcsink-python/docker-compose.yml
diff --git a/...apache-kafka-flink-streaming/example.json → .../flink/kafka-jdbcsink-python/example.json b/...apache-kafka-flink-streaming/example.json → .../flink/kafka-jdbcsink-python/example.json
diff --git a/...e-kafka-flink-streaming/flink_consumer.py → ...k/kafka-jdbcsink-python/flink_consumer.py b/...e-kafka-flink-streaming/flink_consumer.py → ...k/kafka-jdbcsink-python/flink_consumer.py
diff --git a/...afka-flink-streaming/flink_job.Dockerfile → ...afka-jdbcsink-python/flink_job.Dockerfile b/...afka-flink-streaming/flink_job.Dockerfile → ...afka-jdbcsink-python/flink_job.Dockerfile
diff --git a/...ache-kafka-flink-streaming/pyproject.toml → ...link/kafka-jdbcsink-python/pyproject.toml b/...ache-kafka-flink-streaming/pyproject.toml → ...link/kafka-jdbcsink-python/pyproject.toml
diff --git a/...he-kafka-flink-streaming/requirements.txt → ...nk/kafka-jdbcsink-python/requirements.txt b/...he-kafka-flink-streaming/requirements.txt → ...nk/kafka-jdbcsink-python/requirements.txt
diff --git a/...kafka-flink-streaming/weather_producer.py → ...kafka-jdbcsink-python/weather_producer.py b/...kafka-flink-streaming/weather_producer.py → ...kafka-jdbcsink-python/weather_producer.py