Class | Description |
---|---|
DeltaSink<IN> |
A unified sink that emits its input elements to file system files within buckets using
Parquet format and commits those files to the
DeltaLog . |
RowDataDeltaSinkBuilder |
A builder class for
DeltaSink for a stream of RowData . |