org.apache.giraph.utils

Class AbstractVertexIdData<I extends org.apache.hadoop.io.WritableComparable,T>

java.lang.Object

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

Type Parameters:

I - vertexId type parameter

T - vertexData type parameter

All Implemented Interfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, VertexIdData<I,T>, org.apache.hadoop.io.Writable

Direct Known Subclasses:

ByteArrayVertexIdData

public abstract class AbstractVertexIdData<I extends org.apache.hadoop.io.WritableComparable,T>
extends Object
implements VertexIdData<I,T>

Partial implementation of vertexIdData

Field Summary

Fields

Modifier and Type	Field and Description
protected ExtendedDataOutput	extendedDataOutput Extended data output

Constructor Summary

Constructors

Constructor and Description
AbstractVertexIdData()

Method Summary

Modifier and Type	Method and Description
void	add(byte[] serializedId, int idPos, T data) Add a serialized vertex id and data.
void	add(I vertexId, T data) Add a vertex id and data pair to the collection.
void	clear() Clear the list.
ImmutableClassesGiraphConfiguration<I,?,?>	getConf() Return the configuration used by this object.
int	getSerializedSize() Get the size of this object in serialized form.
int	getSize() Get the number of bytes used.
ByteStructVertexIdDataIterator<I,T>	getVertexIdDataIterator() Get an iterator over the pairs.
void	initialize() Initialize the inner state.
void	initialize(int expectedSize) Initialize the inner state, with a known size.
boolean	isEmpty() Check if the list is empty.
void	readFields(DataInput dataInput)
void	setConf(ImmutableClassesGiraphConfiguration configuration) Set the configuration to be used by this object.
void	write(DataOutput output)

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

createData, readData, writeData

Field Detail

extendedDataOutput

protected ExtendedDataOutput extendedDataOutput

Extended data output

Constructor Detail

AbstractVertexIdData

public AbstractVertexIdData()

Method Detail

initialize

public void initialize()

Description copied from interface: VertexIdData

Initialize the inner state. Must be called before add() is called.

Specified by:

initialize in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,T>

initialize

public void initialize(int expectedSize)

Description copied from interface: VertexIdData

Initialize the inner state, with a known size. Must be called before add() is called.

Specified by:

initialize in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,T>

Parameters:

expectedSize - Number of bytes to be expected

add

public void add(I vertexId,
                T data)

Description copied from interface: VertexIdData

Add a vertex id and data pair to the collection.

Specified by:

add in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,T>

Parameters:

vertexId - Vertex id

data - Data

add

public void add(byte[] serializedId,
                int idPos,
                T data)

Description copied from interface: VertexIdData

Add a serialized vertex id and data.

Specified by:

add in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,T>

Parameters:

serializedId - The bye array which holds the serialized id.

idPos - The end position of the serialized id in the byte array.

data - Data

getSize

public int getSize()

Description copied from interface: VertexIdData

Get the number of bytes used.

Specified by:

getSize in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,T>

Returns:

Bytes used

getSerializedSize

public int getSerializedSize()

Description copied from interface: VertexIdData

Get the size of this object in serialized form.

Specified by:

getSerializedSize in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,T>

Returns:

The size (in bytes) of the serialized object

isEmpty

public boolean isEmpty()

Description copied from interface: VertexIdData

Check if the list is empty.

Specified by:

isEmpty in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,T>

Returns:

Whether the list is empty

clear

public void clear()

Description copied from interface: VertexIdData

Clear the list.

Specified by:

clear in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,T>

setConf

public void setConf(ImmutableClassesGiraphConfiguration configuration)

Description copied from interface: GiraphConfigurationSettable

Set the configuration to be used by this object.

Specified by:

setConf in interface GiraphConfigurationSettable

Parameters:

configuration - Set configuration

getConf

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

Description copied from interface: ImmutableClassesGiraphConfigurable

Return the configuration used by this object.

Specified by:

getConf in interface ImmutableClassesGiraphConfigurable

Returns:

Set configuration

getVertexIdDataIterator

public ByteStructVertexIdDataIterator<I,T> getVertexIdDataIterator()

Description copied from interface: VertexIdData

Get an iterator over the pairs.

Specified by:

getVertexIdDataIterator in interface VertexIdData<I extends org.apache.hadoop.io.WritableComparable,T>

Returns:

Iterator

write

public void write(DataOutput output)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

readFields

public void readFields(DataInput dataInput)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException