public static class AccumuloEdgeInputFormat.AccumuloEdgeVertexReader extends AccumuloVertexInputFormat.AccumuloVertexReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Modifier and Type | Field and Description |
---|---|
static Pattern |
commaPattern |
Constructor and Description |
---|
AccumuloEdgeVertexReader(org.apache.hadoop.mapreduce.RecordReader<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> recordReader) |
Modifier and Type | Method and Description |
---|---|
Vertex<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> |
getCurrentVertex() |
boolean |
nextVertex() |
close, getConfiguration, getContext, getProgress, getRecordReader, initialize
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public static final Pattern commaPattern
public AccumuloEdgeVertexReader(org.apache.hadoop.mapreduce.RecordReader<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> recordReader)
public boolean nextVertex() throws IOException, InterruptedException
nextVertex
in class VertexReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
IOException
InterruptedException
public Vertex<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> getCurrentVertex() throws IOException, InterruptedException
getCurrentVertex
in class VertexReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
IOException
InterruptedException
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.