the aggregator task shoul delete the sequence file after aggregation
This is absolute necessary in order to free disc space.
This can be achieved by changing the internal API from iostreams to files. Our logging system would also benefit from this mechanism since the aggregatorTask could output which file it is currently aggregating. This would help if there are any errors to be handled and also to see some progress
the aggregator task shoul delete the sequence file after aggregation
This is absolute necessary in order to free disc space.
This can be achieved by changing the internal API from iostreams to files. Our logging system would also benefit from this mechanism since the aggregatorTask could output which file it is currently aggregating. This would help if there are any errors to be handled and also to see some progress