org.apache.giraph.ooc.persistence

Class InMemoryDataAccessor.InMemoryDataInputWrapper

java.lang.Object

org.apache.giraph.ooc.persistence.InMemoryDataAccessor.InMemoryDataInputWrapper

All Implemented Interfaces:

OutOfCoreDataAccessor.DataInputWrapper

Enclosing class:

InMemoryDataAccessor

public class InMemoryDataAccessor.InMemoryDataInputWrapper
extends Object
implements OutOfCoreDataAccessor.DataInputWrapper

DataInputWrapper implementation for InMemoryDataAccessor

Constructor Summary

Constructors

Constructor and Description
InMemoryDataInputWrapper(BigDataInput input, DataIndex index) Constructor

Method Summary

Modifier and Type	Method and Description
long	finalizeInput(boolean deleteOnClose) Finalize and close the DataInput used for persistence.
DataInput	getDataInput()

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryDataInputWrapper

public InMemoryDataInputWrapper(BigDataInput input,
                                DataIndex index)

Constructor

Parameters:

input - Input to read data from

index - DataIndex which this wrapper belongs to

Method Detail

getDataInput

public DataInput getDataInput()

Specified by:

getDataInput in interface OutOfCoreDataAccessor.DataInputWrapper

Returns:

the DataInput, should return the same instance every time it's called (not start from the beginning)

finalizeInput

public long finalizeInput(boolean deleteOnClose)

Description copied from interface: OutOfCoreDataAccessor.DataInputWrapper

Finalize and close the DataInput used for persistence.

Specified by:

finalizeInput in interface OutOfCoreDataAccessor.DataInputWrapper

Parameters:

deleteOnClose - whether the source of DataInput should be deleted on closing/finalizing

Returns:

number of bytes read from DataInput since it was opened