public class LongDoubleFloatTextInputFormat extends TextVertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> implements ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>
VertexInputFormat
for
weighted graphs with long ids. Each line consists of: vertex neighbor1:weight
neighbor2:weight ...Modifier and Type | Class and Description |
---|---|
class |
LongDoubleFloatTextInputFormat.LongDoubleFloatVertexReader
Vertex reader associated with
LongDoubleDoubleTextInputFormat . |
TextVertexInputFormat.TextVertexReader, TextVertexInputFormat.TextVertexReaderFromEachLine, TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<T>, TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions<T,X extends Throwable>
textInputFormat
Constructor and Description |
---|
LongDoubleFloatTextInputFormat() |
Modifier and Type | Method and Description |
---|---|
TextVertexInputFormat.TextVertexReader |
createVertexReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
The factory method which produces the
TextVertexInputFormat.TextVertexReader used by this
input format. |
ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> |
getConf()
Return the configuration used by this object.
|
void |
setConf(ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> configuration)
Set the configuration to be used by this object.
|
checkInputSpecs, getSplits
readInputSplit, writeInputSplit
public TextVertexInputFormat.TextVertexReader createVertexReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
TextVertexInputFormat
TextVertexInputFormat.TextVertexReader
used by this
input format.createVertexReader
in class TextVertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>
split
- the split to be readcontext
- the information about the taskIOException
public void setConf(ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> configuration)
GiraphConfigurationSettable
setConf
in interface GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>
setConf
in class DefaultImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>
configuration
- Set configurationpublic ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> getConf()
ImmutableClassesGiraphConfigurable
getConf
in interface ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>
getConf
in class DefaultImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.