public class GoraTestVertexOutputFormat extends GoraVertexOutputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>
Modifier and Type | Class and Description |
---|---|
protected class |
GoraTestVertexOutputFormat.GoraGVertexVertexWriter
Gora vertex writer.
|
GoraVertexOutputFormat.GoraVertexWriter
Constructor and Description |
---|
GoraTestVertexOutputFormat()
DEfault constructor
|
Modifier and Type | Method and Description |
---|---|
VertexWriter<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> |
createVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
checkOutputSpecs, createDataStore, getDataStore, getDatastoreClass, getLogger, getOutputCommitter, setDataStore, setDatastoreClass
getConf, setConf
public GoraTestVertexOutputFormat()
public VertexWriter<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> createVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
createVertexWriter
in class VertexOutputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>
IOException
InterruptedException
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.