public abstract class HadoopElementIterator<E extends Element> extends Object implements Iterator<E>
Modifier and Type | Field and Description |
---|---|
protected HadoopGraph |
graph |
protected Queue<org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,VertexWritable>> |
readers |
Constructor and Description |
---|
HadoopElementIterator(HadoopGraph graph) |
HadoopElementIterator(HadoopGraph graph,
org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,VertexWritable> inputFormat,
org.apache.hadoop.fs.Path path) |
protected final HadoopGraph graph
protected final Queue<org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,VertexWritable>> readers
public HadoopElementIterator(HadoopGraph graph, org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,VertexWritable> inputFormat, org.apache.hadoop.fs.Path path) throws IOException, InterruptedException
IOException
InterruptedException
public HadoopElementIterator(HadoopGraph graph) throws IOException
IOException
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.