I
- vertex id typeV
- vertex value typeE
- edge typepublic abstract static class AccumuloVertexInputFormat.AccumuloVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> extends VertexReader<I,V,E>
Constructor and Description |
---|
AccumuloVertexReader(org.apache.hadoop.mapreduce.RecordReader<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> reader)
Constructor used to pass Record Reader instance
|
Modifier and Type | Method and Description |
---|---|
void |
close()
close
|
ImmutableClassesGiraphConfiguration<I,V,E> |
getConfiguration() |
protected org.apache.hadoop.mapreduce.TaskAttemptContext |
getContext()
getContext
|
float |
getProgress()
getProgress
|
protected org.apache.hadoop.mapreduce.RecordReader<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> |
getRecordReader()
Get the result record reader
|
void |
initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
initialize the reader.
|
getCurrentVertex, nextVertex
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public AccumuloVertexReader(org.apache.hadoop.mapreduce.RecordReader<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> reader)
reader
- Accumulo record readerpublic ImmutableClassesGiraphConfiguration<I,V,E> getConfiguration()
public void initialize(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
initialize
in class VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
inputSplit
- Input split to be used for reading vertices.context
- Context from the task.IOException
InterruptedException
public void close() throws IOException
close
in class VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
IOException
public float getProgress() throws IOException, InterruptedException
getProgress
in class VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
IOException
InterruptedException
protected org.apache.hadoop.mapreduce.RecordReader<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> getRecordReader()
protected org.apache.hadoop.mapreduce.TaskAttemptContext getContext()
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.