parquet4s
parquet4s copied to clipboard
feat(akkaPekko): Retry mechanism for ParquetPartitioningFlow
Hi,
In the akkaPekko module, I noticed that there is no handling mechanism in ParquetPartitioningFlow when calling write
from the hadoop ParquetWriter which might throw an IOException. I thought it would also be neat to have a retrial mechanism in place for failed records so I created #350. I think this is something that would be nice to have, let me know if you agree.