org.apache.giraph.utils

Class ByteArrayVertexIdEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.utils.AbstractVertexIdData<I,T>

org.apache.giraph.utils.ByteArrayVertexIdData<I,Edge<I,E>>

org.apache.giraph.utils.ByteArrayVertexIdEdges<I,E>

Type Parameters:

I - Vertex id

E - Edge value

All Implemented Interfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, VertexIdData<I,Edge<I,E>>, VertexIdEdges<I,E>, org.apache.hadoop.io.Writable

public class ByteArrayVertexIdEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
extends ByteArrayVertexIdData<I,Edge<I,E>>
implements VertexIdEdges<I,E>

Stores vertex id and edge pairs in a single byte array.

Field Summary

Fields inherited from class org.apache.giraph.utils.AbstractVertexIdData

extendedDataOutput

Constructor Summary

Constructors

Constructor and Description
ByteArrayVertexIdEdges()

Method Summary

Modifier and Type	Method and Description
Edge<I,E>	createData() Create a new data object.
ImmutableClassesGiraphConfiguration<I,?,E>	getConf() Cast the ImmutableClassesGiraphConfiguration so it can be used to generate edge objects.
ByteStructVertexIdEdgeIterator<I,E>	getVertexIdEdgeIterator() Get an iterator over the pairs.
void	readData(ExtendedDataInput in, Edge<I,E> edge) Read a data object's fields from an ExtendedDataInput.
void	writeData(ExtendedDataOutput out, Edge<I,E> edge) Write a data object to an ExtendedDataOutput.

Methods inherited from class org.apache.giraph.utils.ByteArrayVertexIdData

getByteArray, readFields, write

Methods inherited from class org.apache.giraph.utils.AbstractVertexIdData

add, add, clear, getSerializedSize, getSize, getVertexIdDataIterator, initialize, initialize, isEmpty, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.giraph.utils.VertexIdData

add, add, clear, getSerializedSize, getSize, getVertexIdDataIterator, initialize, initialize, isEmpty

Methods inherited from interface org.apache.giraph.conf.GiraphConfigurationSettable

setConf

Methods inherited from interface org.apache.hadoop.io.Writable

readFields, write

Constructor Detail

ByteArrayVertexIdEdges

public ByteArrayVertexIdEdges()

Method Detail

getConf

public ImmutableClassesGiraphConfiguration<I,?,E> getConf()

Cast the ImmutableClassesGiraphConfiguration so it can be used to generate edge objects.

Specified by:

getConf in interface ImmutableClassesGiraphConfigurable

Overrides:

getConf in class AbstractVertexIdData<I extends org.apache.hadoop.io.WritableComparable,Edge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>>

Returns:

Casted configuration

createData

public Edge<I,E> createData()

Description copied from interface: VertexIdData

Create a new data object.

Specified by:

createData in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,Edge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>>

Returns:

Newly-created data object.

writeData

public void writeData(ExtendedDataOutput out,
                      Edge<I,E> edge)
               throws IOException

Description copied from interface: VertexIdData

Write a data object to an ExtendedDataOutput.

Specified by:

writeData in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,Edge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>>

Parameters:

out - ExtendedDataOutput

edge - Data object to write

Throws:

IOException

readData

public void readData(ExtendedDataInput in,
                     Edge<I,E> edge)
              throws IOException

Description copied from interface: VertexIdData

Read a data object's fields from an ExtendedDataInput.

Specified by:

readData in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,Edge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>>

Parameters:

in - ExtendedDataInput

edge - Data object to fill in-place

Throws:

IOException

getVertexIdEdgeIterator

public ByteStructVertexIdEdgeIterator<I,E> getVertexIdEdgeIterator()

Description copied from interface: VertexIdEdges

Get an iterator over the pairs.

Specified by:

getVertexIdEdgeIterator in interface VertexIdEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

Returns:

Iterator