Instead of a dedicated mapper struct, in cases where on_batch_complete is not needed, a much simpler version that directly takes a closure may be sufficient?
Something like, reader.process_parallel(|record| { ... }).
But I suppose one benefit of the current approach is to accumulate per thread, in which case the mapper struct seems inevitable.
Instead of a dedicated mapper struct, in cases where
on_batch_completeis not needed, a much simpler version that directly takes a closure may be sufficient?Something like,
reader.process_parallel(|record| { ... }).But I suppose one benefit of the current approach is to accumulate per thread, in which case the mapper struct seems inevitable.