I
- Vertex idV
- Vertex valuepublic abstract class HCatalogVertexValueInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable> extends VertexValueInputFormat<I,V>
VertexValueInputFormat
for reading vertex values from
Hive/Pig.Modifier and Type | Class and Description |
---|---|
protected class |
HCatalogVertexValueInputFormat.HCatalogVertexValueReader
|
protected class |
HCatalogVertexValueInputFormat.SingleRowHCatalogVertexValueReader
HCatalogVertexValueInputFormat.HCatalogVertexValueReader for tables holding a complete vertex
value in each row. |
Constructor and Description |
---|
HCatalogVertexValueInputFormat() |
Modifier and Type | Method and Description |
---|---|
protected abstract HCatalogVertexValueInputFormat.HCatalogVertexValueReader |
createVertexValueReader()
Create
VertexValueReader . |
VertexValueReader<I,V> |
createVertexValueReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
Create a
VertexValueReader for a given split. |
List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext context,
int minSplitCountHint)
Get the list of input splits for the format.
|
createVertexReader
checkInputSpecs, readInputSplit, writeInputSplit
getConf, setConf
public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context, int minSplitCountHint) throws IOException, InterruptedException
GiraphInputFormat
getSplits
in class GiraphInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
context
- The job contextminSplitCountHint
- Minimum number of splits to create (hint)IOException
InterruptedException
protected abstract HCatalogVertexValueInputFormat.HCatalogVertexValueReader createVertexValueReader()
VertexValueReader
.HCatalogVertexValueInputFormat.HCatalogVertexValueReader
instance.public final VertexValueReader<I,V> createVertexValueReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
VertexValueInputFormat
VertexValueReader
for a given split. The framework will
call VertexValueReader.initialize(InputSplit,
TaskAttemptContext)
before the split is used.createVertexValueReader
in class VertexValueInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>
split
- The split to be readcontext
- The information about the taskIOException
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.