public static class TableEdgeOutputFormat.TableEdgeVertexWriter extends HBaseVertexOutputFormat.HBaseVertexWriter<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Constructor and Description |
---|
TableEdgeVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
void |
writeVertex(Vertex<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> vertex) |
close, getContext, getRecordWriter, initialize
getConf, setConf
public TableEdgeVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
IOException
InterruptedException
public void writeVertex(Vertex<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> vertex) throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.