protected class GoraTestEdgeOutputFormat.GoraGEdgeEdgeWriter extends GoraEdgeOutputFormat.GoraEdgeWriter
Modifier | Constructor and Description |
---|---|
protected |
GoraGEdgeEdgeWriter() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.gora.persistency.Persistent |
getGoraEdge(org.apache.hadoop.io.LongWritable srcId,
org.apache.hadoop.io.DoubleWritable srcValue,
Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge) |
protected Object |
getGoraKey(org.apache.hadoop.io.LongWritable srcId,
org.apache.hadoop.io.DoubleWritable srcValue,
Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge) |
void |
writeEdge(org.apache.hadoop.io.LongWritable srcId,
org.apache.hadoop.io.DoubleWritable srcValue,
Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge) |
close, initialize
getConf, setConf
protected org.apache.gora.persistency.Persistent getGoraEdge(org.apache.hadoop.io.LongWritable srcId, org.apache.hadoop.io.DoubleWritable srcValue, Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge)
getGoraEdge
in class GoraEdgeOutputFormat.GoraEdgeWriter
protected Object getGoraKey(org.apache.hadoop.io.LongWritable srcId, org.apache.hadoop.io.DoubleWritable srcValue, Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge)
getGoraKey
in class GoraEdgeOutputFormat.GoraEdgeWriter
public void writeEdge(org.apache.hadoop.io.LongWritable srcId, org.apache.hadoop.io.DoubleWritable srcValue, Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge) throws IOException, InterruptedException
writeEdge
in class GoraEdgeOutputFormat.GoraEdgeWriter
IOException
InterruptedException
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.