Repository navigation

fix(flink): run the engine on flink - #46

Merged

vim89 merged 9 commits into

mainfrom

fix/flink-engine

Oct 6, 2026

Merged

fix(flink): run the engine on flink#46
vim89 merged 9 commits into
mainfrom
fix/flink-engine

Commits on Oct 6, 2026
- build: make engines-flink resolve on scala 2.13
  vim89
  committed
  ae8a194
- feat(flink): run data operations as flink batch jobs
  vim89
  committed
  630f5c5
- fix(flink): move the demo off the deprecated scala api
  vim89
  committed
  24abf4f
- test(flink): compare the engine with the in-memory one
  vim89
  committed
  8fa1d15
- ci: run the engines-flink tests
  vim89
  committed
  d4d02c8
- docs: record what the flink engine does and does not do
  vim89
  committed
  3581eda
- style: format the new flink sources
  vim89
  committed
  7e4d7e9
- fix(flink): count rows in the job and skip the header line the file holds
  vim89
  committed
  310502b
- test(flink): pin one count per key and a padded header
  vim89
  committed
  bcc819b