public static class TableEdgeInputFormat.TableEdgeVertexReader extends HBaseVertexInputFormat.HBaseVertexReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Constructor and Description |
---|
TableEdgeVertexReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
Vertex<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> |
getCurrentVertex()
For each row, create a vertex with the row ID as a text,
and it's 'children' qualifier as a single edge.
|
boolean |
nextVertex() |
close, getContext, getProgress, getRecordReader, initialize
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
getConf, setConf
public TableEdgeVertexReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
IOException
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.