POC - CSV Sink#71

Open

rajuGT wants to merge 10 commits into

mainfrom

Commits on Jun 10, 2026

feat(sink): add SINK_CSV_* config constants for CSV sink

rajuGT
and
cursoragent
committed
feat(sink): add Flink FileSystem-backed storage client for CSV sink

rajuGT
and
cursoragent
committed
feat(sink): add APPEND/OVERWRITE write strategies for CSV sink

rajuGT
and
cursoragent
committed
feat(sink): add CsvSink and CsvSinkWriter for daily-rolling CSV output

rajuGT
and
cursoragent
committed
feat(sink): wire CSV sink into orchestrator with parallelism-1 guard

rajuGT
and
cursoragent
committed
docs: document CSV sink configuration and usage

rajuGT
and
cursoragent
committed
fix(sink): flush CSV sink on prepareCommit and add logging

rajuGT
and
cursoragent
committed

Commits on Jun 12, 2026

feat(sink): make CSV sink rolling pattern-driven via SINK_CSV_PARTITION_DATE_FORMAT

rajuGT
and
cursoragent
committed

Commits on Jun 16, 2026