org.apache.giraph.ooc.command

Class StoreDataBufferIOCommand

java.lang.Object

org.apache.giraph.ooc.command.IOCommand

org.apache.giraph.ooc.command.StoreDataBufferIOCommand

public class StoreDataBufferIOCommand
extends IOCommand

IOCommand to store raw data buffers on disk.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StoreDataBufferIOCommand.DataBufferType Types of raw data buffer to offload to disk (either vertices/edges buffer in INPUT_SUPERSTEP or incoming message buffer).

Nested classes/interfaces inherited from class org.apache.giraph.ooc.command.IOCommand

IOCommand.IOCommandType

Field Summary

Fields inherited from class org.apache.giraph.ooc.command.IOCommand

numBytesTransferred, oocEngine, partitionId

Constructor Summary

Constructors

Constructor and Description
StoreDataBufferIOCommand(OutOfCoreEngine oocEngine, int partitionId, StoreDataBufferIOCommand.DataBufferType type) Constructor

Method Summary

Modifier and Type	Method and Description
boolean	execute() Execute (load/store of data) the IO command, and change the data stores appropriately based on the data loaded/stored.
IOCommand.IOCommandType	getType() Get the type of the command.
String	toString()

Methods inherited from class org.apache.giraph.ooc.command.IOCommand

bytesTransferred, getPartitionId

Methods inherited from class java.lang.Object

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

Constructor Detail

StoreDataBufferIOCommand

public StoreDataBufferIOCommand(OutOfCoreEngine oocEngine,
                                int partitionId,
                                StoreDataBufferIOCommand.DataBufferType type)

Constructor

Parameters:

oocEngine - out-of-core engine

partitionId - id of the partition to offload its buffers

type - type of the buffer to store on disk

Method Detail

execute

public boolean execute()
                throws IOException

Description copied from class: IOCommand

Execute (load/store of data) the IO command, and change the data stores appropriately based on the data loaded/stored. Return true iff the command is actually executed (resulted in loading or storing data).

Specified by:

execute in class IOCommand

Returns:

whether the command is actually executed

Throws:

IOException

getType

public IOCommand.IOCommandType getType()

Description copied from class: IOCommand

Get the type of the command.

Specified by:

getType in class IOCommand

Returns:

type of the command

toString

public String toString()

Overrides:

toString in class Object