public class AccumuloEdgeOutputFormat extends AccumuloVertexOutputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Modifier and Type | Class and Description |
---|---|
static class |
AccumuloEdgeOutputFormat.AccumuloEdgeVertexWriter |
AccumuloVertexOutputFormat.AccumuloVertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
accumuloOutputFormat, OUTPUT_TABLE
Constructor and Description |
---|
AccumuloEdgeOutputFormat() |
Modifier and Type | Method and Description |
---|---|
VertexWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> |
createVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
checkOutputSpecs, getOutputCommitter
getConf, setConf
public VertexWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> createVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
createVertexWriter
in class VertexOutputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
IOException
InterruptedException
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.