accumulo-testing
accumulo-testing copied to clipboard
Explore writng a specialized summarizer for bulk ingest
To debug a recent bulk ingest test I wrote the following summarizer. This summarizer counted the number of times each UUID was seen. I used to count the number of entries each map reduce job had created.
package test.ci;
import org.apache.accumulo.core.client.summary.CountingSummarizer;
public class CiUuidSummarizer extends CountingSummarizer<String>{
@Override
protected Converter<String> converter() {
return (k,v,c) -> c.accept(v.toString().split(":")[0]);
}
}