I
- vertex id typeV
- vertex value typeE
- edge typepublic abstract class AccumuloVertexOutputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> extends VertexOutputFormat<I,V,E>
AccumuloVertexInputFormat
Modifier and Type | Class and Description |
---|---|
static class |
AccumuloVertexOutputFormat.AccumuloVertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Main abstraction point for vertex writers to persist back
to Accumulo tables.
|
Modifier and Type | Field and Description |
---|---|
protected org.apache.accumulo.core.client.mapreduce.AccumuloOutputFormat |
accumuloOutputFormat
Accumulo delegate for table output
|
static String |
OUTPUT_TABLE
Output table parameter
|
Constructor and Description |
---|
AccumuloVertexOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
checkOutputSpecs
|
org.apache.hadoop.mapreduce.OutputCommitter |
getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
getOutputCommitter
|
createVertexWriter
getConf, setConf
public static final String OUTPUT_TABLE
protected org.apache.accumulo.core.client.mapreduce.AccumuloOutputFormat accumuloOutputFormat
public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context) throws IOException, InterruptedException
checkOutputSpecs
in class VertexOutputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
context
- information about the jobIOException
InterruptedException
public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
getOutputCommitter
in class VertexOutputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
context
- the task contextIOException
InterruptedException
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.