Expand description
File sink connector implementing SinkConnector.
Supports two modes:
- Append: writes directly to the output file, flushing on pre-commit.
- Rolling: creates a new
.tmpfile per epoch, atomically renamed on commit.
For bulk formats (Parquet), mid-epoch rotation is disabled — files are
written as a single unit on pre_commit().
Structs§
- File
Sink - File sink connector with append or rolling mode.