org.apache.giraph.io.formats

Class LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader

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.LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader

All Implemented Interfaces:

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

Enclosing class:

LongDoubleDoubleAdjacencyListVertexInputFormat

protected class LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader
extends AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader

VertexReader associated with LongDoubleDoubleAdjacencyListVertexInputFormat.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Edge<org.apache.hadoop.io.LongWritable,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.LongWritable	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

LongDoubleDoubleAdjacencyListVertexReader

public LongDoubleDoubleAdjacencyListVertexReader(AdjacencyListTextVertexInputFormat.LineSanitizer lineSanitizer)

Constructor with AdjacencyListTextVertexInputFormat.LineSanitizer.

Parameters:

lineSanitizer - the sanitizer to use for reading

Method Detail

decodeId

public org.apache.hadoop.io.LongWritable 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.LongWritable,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