Thanks, I'll check it out.
On Sat 26 Jan, 2019, 10:48 PM Dawid Wysakowicz Hi,
>
> Generally speaking you can pass the batch size through RollingPolicy[1].
> Unfortunately BulkFormats uses OnCheckpointRollingPolicy and AFAIK it does
> not allow adjusting its behavior on part size. Maybe Kostas hav
Hi,
Generally speaking you can pass the batch size through RollingPolicy[1].
Unfortunately BulkFormats uses OnCheckpointRollingPolicy and AFAIK it
does not allow adjusting its behavior on part size. Maybe Kostas have an
idea how to do that in the least invasive way. How to do it for non bulk
forma
Can someone please help with this?
On Fri 25 Jan, 2019, 1:47 PM Taher Koitawala Hi All,
> Is there a way to specify *batch size* and *compression *properties
> when using StreamingFileSink just like we did in bucketing sink? The only
> parameters it is accepting is Inactivity bucket chec
