Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
31 commits
Select commit Hold shift + click to select a range
c7f0503
Add "International Sales" to data generator
piotrpdev Jun 12, 2025
560916c
Add "CurrencyConverter" UDF code
piotrpdev Jun 12, 2025
981bff5
Add User Defined Function tutorial
piotrpdev Jun 12, 2025
ad2ae44
Make UDF `TEMPORARY`
piotrpdev Jun 13, 2025
c9fa11e
Persist query with UDF to Kafka
piotrpdev Jun 13, 2025
b80b7d2
Add note for Flink Archetype
piotrpdev Jun 13, 2025
073eadc
Change where UDF is mounted
piotrpdev Jun 13, 2025
8f72f9b
Apply suggestions from code review
piotrpdev Jun 17, 2025
ab382c5
Create `flink.version` pom property
piotrpdev Jun 17, 2025
0c7191c
Explain what first kafka-consumer command is doing
piotrpdev Jun 17, 2025
1ce56b3
Move solution after problem
piotrpdev Jun 17, 2025
cf0e74b
Ask for currency symbols
piotrpdev Jun 17, 2025
d43dc83
Change currency `Map` to `enum`
piotrpdev Jun 17, 2025
96ece59
Don't show `pom.xml`
piotrpdev Jun 17, 2025
adb7c80
Don't check Maven artefacts
piotrpdev Jun 17, 2025
4c9829d
Replace all `example` with `streamshub`
piotrpdev Jun 17, 2025
94563f7
Move separator to enum
piotrpdev Jun 18, 2025
676072c
Move parsing to `Currency.fromCurrencyAmount()`
piotrpdev Jun 18, 2025
72d5457
Combine `enum` and `Map` approaches
piotrpdev Jun 18, 2025
3b1d36a
Move all parsing logic to `enum`
piotrpdev Jun 18, 2025
8c3c961
Extract `enum` to separate file
piotrpdev Jun 18, 2025
54d5e90
Update tutorial with new code
piotrpdev Jun 18, 2025
52ff05d
Use latest flink docs everywhere
piotrpdev Jun 18, 2025
4f31fbb
Add UDF tests
piotrpdev Jun 18, 2025
fa5b023
Add `docker-maven-plugin`
piotrpdev Jun 18, 2025
b71320b
Add `FlinkDeployment`
piotrpdev Jun 18, 2025
144f477
Apply suggestions from code review
piotrpdev Jun 20, 2025
b76ef8b
Make tutorial code match example code better
piotrpdev Jun 23, 2025
6210b13
Change query for faster results
piotrpdev Jun 23, 2025
05a02e7
Build and push image in CI
piotrpdev Jun 23, 2025
b400a3b
Apply suggestions from code review
piotrpdev Jun 24, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
51 changes: 45 additions & 6 deletions .github/workflows/integration.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -41,18 +41,31 @@ jobs:
username: "${{ secrets.IMAGE_REPO_USERNAME }}"
password: "${{ secrets.IMAGE_REPO_PASSWORD }}"

- name: Build Image
- name: Generate Currency Converter Dockerfile
working-directory: tutorials/currency-converter
run: mvn -B docker:build -Ddocker.buildArchiveOnly # Skip building image, just create Dockerfile

- name: Build Data Generator Image
if: github.event_name != 'push'
uses: docker/build-push-action@v6
with:
context: tutorials/data-generator/
platforms: linux/amd64,linux/arm64
push: false
file: tutorials/data-generator/Dockerfile

- name: Build Currency Converter Image
if: github.event_name != 'push'
uses: docker/build-push-action@v6
with:
context: tutorials/currency-converter/target/docker/flink-sql-runner-with-flink-udf-currency-converter/build/
platforms: linux/amd64,linux/arm64
push: false
file: tutorials/currency-converter/target/docker/flink-sql-runner-with-flink-udf-currency-converter/build/Dockerfile

- name: Image metadata
- name: Data Generator Image metadata
if: github.event_name == 'push'
id: meta
id: data_generator_meta
uses: docker/metadata-action@v5
with:
images: |
Expand All @@ -65,13 +78,39 @@ jobs:
prefix=
suffix=

- name: Build and Push Image
- name: Currency Converter Image metadata
if: github.event_name == 'push'
id: currency_converter_meta
uses: docker/metadata-action@v5
with:
images: |
${{ secrets.IMAGE_REPO_HOSTNAME }}/${{ secrets.IMAGE_REPO_NAMESPACE }}/flink-sql-runner-with-flink-udf-currency-converter
tags: |
type=ref,event=branch
type=ref,event=tag
flavor: |
latest=false
prefix=
suffix=

- name: Build and Push Data Generator Image
if: github.event_name == 'push'
uses: docker/build-push-action@v6
with:
context: tutorials/data-generator/
platforms: linux/amd64,linux/arm64
push: true
file: tutorials/data-generator/Dockerfile
tags: ${{ steps.meta.outputs.tags }}
labels: ${{ steps.meta.outputs.labels }}
tags: ${{ steps.data_generator_meta.outputs.tags }}
labels: ${{ steps.data_generator_meta.outputs.labels }}

- name: Build and Push Currency Converter Image
if: github.event_name == 'push'
uses: docker/build-push-action@v6
with:
context: tutorials/currency-converter/target/docker/flink-sql-runner-with-flink-udf-currency-converter/build/
platforms: linux/amd64,linux/arm64
push: true
file: tutorials/currency-converter/target/docker/flink-sql-runner-with-flink-udf-currency-converter/build/Dockerfile
tags: ${{ steps.currency_converter_meta.outputs.tags }}
labels: ${{ steps.currency_converter_meta.outputs.labels }}
3 changes: 3 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -31,3 +31,6 @@ dependency-reduced-pom.xml

# Rendered Docs
*.html

# Maven Wrapper files
.mvn
Loading