protected abstract class GoraEdgeOutputFormat.GoraEdgeWriter extends EdgeWriter<I,V,E>
Modifier | Constructor and Description |
---|---|
protected |
GoraEdgeWriter() |
Modifier and Type | Method and Description |
---|---|
void |
close(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
protected abstract org.apache.gora.persistency.Persistent |
getGoraEdge(I srcId,
V srcValue,
Edge<I,E> edge)
Each edge needs to be transformed into a Gora object to be sent to
a specific data store.
|
protected abstract Object |
getGoraKey(I srcId,
V srcValue,
Edge<I,E> edge)
Gets the correct key from a computed vertex.
|
void |
initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
void |
writeEdge(I srcId,
V srcValue,
Edge<I,E> edge) |
getConf, setConf
public void initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
initialize
in class EdgeWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
IOException
InterruptedException
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
close
in class EdgeWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
IOException
InterruptedException
public void writeEdge(I srcId, V srcValue, Edge<I,E> edge) throws IOException, InterruptedException
writeEdge
in class EdgeWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
IOException
InterruptedException
protected abstract org.apache.gora.persistency.Persistent getGoraEdge(I srcId, V srcValue, Edge<I,E> edge)
edge
- edge to be transformed into a Gora objectsrcId
- source vertex idsrcValue
- source vertex valueCopyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.