org.apache.giraph.io.formats

Class TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.worker.WorkerAggregatorDelegator<I,V,E>

org.apache.giraph.io.VertexReader<I,V,E>

org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReader

org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<String[]>

org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader

org.apache.giraph.io.formats.TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage

Enclosing class:

TextDoubleDoubleAdjacencyListVertexInputFormat

protected class TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader
extends AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader

Vertex reader used with TextDoubleDoubleAdjacencyListVertexInputFormat

Constructor Summary

Constructors

Constructor and Description
TextDoubleDoubleAdjacencyListVertexReader(AdjacencyListTextVertexInputFormat.LineSanitizer lineSanitizer) Constructor with AdjacencyListTextVertexInputFormat.LineSanitizer.

Method Summary

Modifier and Type	Method and Description
Edge<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable>	decodeEdge(String s1, String s2) Decode an edge from the line into an instance of a correctly typed Edge
org.apache.hadoop.io.Text	decodeId(String s) Decode the id for this line into an instance of its correct type.
org.apache.hadoop.io.DoubleWritable	decodeValue(String s) Decode the value for this line into an instance of its correct type.

Methods inherited from class org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader

getEdges, getId, getValue, initialize, preprocessLine

Methods inherited from class org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReaderFromEachLineProcessed

getCurrentVertex, nextVertex

Methods inherited from class org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReader

close, createLineRecordReader, getContext, getProgress, getRecordReader

Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator

aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TextDoubleDoubleAdjacencyListVertexReader

public TextDoubleDoubleAdjacencyListVertexReader(AdjacencyListTextVertexInputFormat.LineSanitizer lineSanitizer)

Constructor with AdjacencyListTextVertexInputFormat.LineSanitizer.

Parameters:

lineSanitizer - the sanitizer to use for reading

Method Detail

decodeId

public org.apache.hadoop.io.Text decodeId(String s)

Description copied from class: AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader

Decode the id for this line into an instance of its correct type.

Specified by:

decodeId in class AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader

Parameters:

s - Id of vertex from line

Returns:

Vertex id

decodeValue

public org.apache.hadoop.io.DoubleWritable decodeValue(String s)

Description copied from class: AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader

Decode the value for this line into an instance of its correct type.

Specified by:

decodeValue in class AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader

Parameters:

s - Value from line

Returns:

Vertex value

decodeEdge

public Edge<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable> decodeEdge(String s1,
                                                                                      String s2)

Description copied from class: AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader

Decode an edge from the line into an instance of a correctly typed Edge

Specified by:

decodeEdge in class AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader

Parameters:

s1 - The edge's id from the line

s2 - The edge's value from the line

Returns:

Edge with given target id and value