This repository has been archived by the owner on Jun 30, 2022. It is now read-only.
Version 0.2.7
The 0.2.7 release includes the following changes:
- Introduce
OperationCounters.should_sample
for sampling for size estimation. - Implement fixed sharding in
TextFileSink
. - Use multiple file rename threads in
finalize_write
method. - Retry idempotent I/O operations on GCS timeout.