Skip to content
Permalink
Browse files
#35 - Factor out TestUtil API (#36)
  • Loading branch information
Manno15 authored and mikewalch committed Mar 11, 2019
1 parent 7664105 commit f89f33d8605b3d7602e38bb9259bb25003770109
Showing 2 changed files with 1 addition and 3 deletions.
@@ -37,7 +37,6 @@
<allow class="org.apache.accumulo.tracer.TraceDump"/>
<allow class="org.apache.accumulo.core.trace.DistributedTrace"/>
<allow class="org.apache.accumulo.core.util.format.DefaultFormatter"/>
<allow class="org.apache.accumulo.core.util.TextUtil"/>
<!-- End TODO section -->

<!-- disallow everything else coming from accumulo -->
@@ -25,7 +25,6 @@
import org.apache.accumulo.core.client.AccumuloClient;
import org.apache.accumulo.core.data.Key;
import org.apache.accumulo.core.data.Value;
import org.apache.accumulo.core.util.TextUtil;
import org.apache.accumulo.examples.cli.ClientOpts;
import org.apache.accumulo.hadoop.mapreduce.AccumuloFileOutputFormat;
import org.apache.accumulo.hadoop.mapreduce.partition.RangePartitioner;
@@ -122,7 +121,7 @@ public static void main(String[] args) throws Exception {
new BufferedOutputStream(fs.create(new Path(workDir + "/splits.txt"))))) {
Collection<Text> splits = client.tableOperations().listSplits(SetupTable.tableName, 100);
for (Text split : splits)
out.println(Base64.getEncoder().encodeToString(TextUtil.getBytes(split)));
out.println(Base64.getEncoder().encodeToString(split.copyBytes()));
job.setNumReduceTasks(splits.size() + 1);
}

0 comments on commit f89f33d

Please sign in to comment.