public class AccumuloEdgeInputFormat extends AccumuloVertexInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
Modifier and Type | Class and Description |
---|---|
static class |
AccumuloEdgeInputFormat.AccumuloEdgeVertexReader |
AccumuloVertexInputFormat.AccumuloVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
accumuloInputFormat
Constructor and Description |
---|
AccumuloEdgeInputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkInputSpecs(org.apache.hadoop.conf.Configuration conf) |
VertexReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> |
createVertexReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
getSplits
readInputSplit, writeInputSplit
getConf, setConf
public void checkInputSpecs(org.apache.hadoop.conf.Configuration conf)
checkInputSpecs
in class GiraphInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
public VertexReader<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> createVertexReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
createVertexReader
in class VertexInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
IOException
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.