org.apache.giraph.ooc.persistence

Class InMemoryDataAccessor

java.lang.Object

org.apache.giraph.ooc.persistence.InMemoryDataAccessor

All Implemented Interfaces:

OutOfCoreDataAccessor

public class InMemoryDataAccessor
extends Object
implements OutOfCoreDataAccessor

Implementation of data accessor which keeps all the data serialized but in memory. Useful to keep the number of used objects under control.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	InMemoryDataAccessor.InMemoryDataInputWrapper DataInputWrapper implementation for InMemoryDataAccessor
static class	InMemoryDataAccessor.InMemoryDataOutputWrapper DataOutputWrapper implementation for InMemoryDataAccessor

Nested classes/interfaces inherited from interface org.apache.giraph.ooc.persistence.OutOfCoreDataAccessor

OutOfCoreDataAccessor.DataInputWrapper, OutOfCoreDataAccessor.DataOutputWrapper

Constructor Summary

Constructors

Constructor and Description
InMemoryDataAccessor(ImmutableClassesGiraphConfiguration<?,?,?> conf) Constructor

Method Summary

Modifier and Type	Method and Description
boolean	dataExist(int threadId, DataIndex index) Whether the data for the given thread and index chain exists?
int	getNumAccessorThreads()
void	initialize() Initialize the DAO
OutOfCoreDataAccessor.DataInputWrapper	prepareInput(int threadId, DataIndex index) Prepare a wrapper containing DataInput representation for a given thread involved in persistence for a given index chain for data.
OutOfCoreDataAccessor.DataOutputWrapper	prepareOutput(int threadId, DataIndex index, boolean shouldAppend) Prepare a wrapper containing DataOutput representation for a given thread involved in persistence for a given index chain for data.
void	shutdown() Shut down the DAO

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryDataAccessor

public InMemoryDataAccessor(ImmutableClassesGiraphConfiguration<?,?,?> conf)

Constructor

Parameters:

conf - Configuration

Method Detail

initialize

public void initialize()

Description copied from interface: OutOfCoreDataAccessor

Initialize the DAO

Specified by:

initialize in interface OutOfCoreDataAccessor

shutdown

public void shutdown()

Description copied from interface: OutOfCoreDataAccessor

Shut down the DAO

Specified by:

shutdown in interface OutOfCoreDataAccessor

getNumAccessorThreads

public int getNumAccessorThreads()

Specified by:

getNumAccessorThreads in interface OutOfCoreDataAccessor

Returns:

the number of threads involved in data persistence

prepareInput

public OutOfCoreDataAccessor.DataInputWrapper prepareInput(int threadId,
                                                           DataIndex index)
                                                    throws IOException

Description copied from interface: OutOfCoreDataAccessor

Prepare a wrapper containing DataInput representation for a given thread involved in persistence for a given index chain for data.

Specified by:

prepareInput in interface OutOfCoreDataAccessor

Parameters:

threadId - id of the thread involved in persistence

index - index chain of the data to access the serialized data form

Returns:

the wrapper for DataInput representation of data

Throws:

IOException

prepareOutput

public OutOfCoreDataAccessor.DataOutputWrapper prepareOutput(int threadId,
                                                             DataIndex index,
                                                             boolean shouldAppend)
                                                      throws IOException

Description copied from interface: OutOfCoreDataAccessor

Prepare a wrapper containing DataOutput representation for a given thread involved in persistence for a given index chain for data.

Specified by:

prepareOutput in interface OutOfCoreDataAccessor

Parameters:

threadId - id of the thread involved in persistence

index - index chain of the data to access the serialized data form

shouldAppend - whether the DataOutput should be used for appending to already existing data for the given index or the DataOutput should create new instance to store serialized data

Returns:

the wrapper for DataOutput representation of data

Throws:

IOException

dataExist

public boolean dataExist(int threadId,
                         DataIndex index)

Description copied from interface: OutOfCoreDataAccessor

Whether the data for the given thread and index chain exists?

Specified by:

dataExist in interface OutOfCoreDataAccessor

Parameters:

threadId - id of the thread involved in persistence

index - index chain used to access the data

Returns:

True if the data exists for the given index chain for the given thread, False otherwise