protected class GoraTestVertexOutputFormat.GoraGVertexVertexWriter extends GoraVertexOutputFormat.GoraVertexWriter
Modifier | Constructor and Description |
---|---|
protected |
GoraGVertexVertexWriter() |
Modifier and Type | Method and Description |
---|---|
GVertexResult |
createVertex(String id,
Map<String,String> edges)
Creates a vertex using an id and a set of edges.
|
protected Object |
getGoraKey(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex) |
protected org.apache.gora.persistency.Persistent |
getGoraVertex(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex) |
void |
writeVertex(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex) |
close, initialize, process
getConf, setConf
protected org.apache.gora.persistency.Persistent getGoraVertex(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex)
getGoraVertex
in class GoraVertexOutputFormat.GoraVertexWriter
public void writeVertex(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex) throws IOException, InterruptedException
writeVertex
in interface SimpleVertexWriter<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>
writeVertex
in class GoraVertexOutputFormat.GoraVertexWriter
IOException
InterruptedException
public GVertexResult createVertex(String id, Map<String,String> edges)
id
- Vertex id.edges
- Set of edges.protected Object getGoraKey(Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex)
getGoraKey
in class GoraVertexOutputFormat.GoraVertexWriter
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.