Package | Description |
---|---|
org.apache.giraph.ooc |
Package of out-of-core related classes.
|
org.apache.giraph.ooc.command |
Package of classes related to IO commands in out-of-core mechanism
|
org.apache.giraph.ooc.policy |
Package of classes related to out-of-core policy
|
Modifier and Type | Method and Description |
---|---|
IOCommand |
OutOfCoreIOScheduler.getNextIOCommand(int threadId)
Generate and return the next appropriate IO command for a given thread
|
Modifier and Type | Method and Description |
---|---|
void |
OutOfCoreIOScheduler.addIOCommand(IOCommand ioCommand)
Add an IO command to the scheduling queue of the IO scheduler
|
void |
OutOfCoreIOScheduler.ioCommandCompleted(IOCommand command)
Notify IO scheduler that the IO command is completed
|
void |
OutOfCoreEngine.ioCommandCompleted(IOCommand command)
Notify out-of-core engine that an IO command is completed by an IO thread
|
Modifier and Type | Class and Description |
---|---|
class |
LoadPartitionIOCommand
IOCommand to load partition data, edge data (if in INPUT_SUPERSTEP), and
message data (if in compute supersteps).
|
class |
StoreDataBufferIOCommand
IOCommand to store raw data buffers on disk.
|
class |
StoreIncomingMessageIOCommand
IOCommand to store incoming message of a particular partition.
|
class |
StorePartitionIOCommand
IOCommand to store partition data, edge data (if in INPUT_SUPERSTEP), and
message data (if in compute supersteps).
|
class |
WaitIOCommand
IOCommand to do nothing regarding moving data to/from disk.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SimpleGCMonitoringOracle.approve(IOCommand command) |
boolean |
MemoryEstimatorOracle.approve(IOCommand command) |
boolean |
ThresholdBasedOracle.approve(IOCommand command) |
boolean |
FixedPartitionsOracle.approve(IOCommand command) |
boolean |
OutOfCoreOracle.approve(IOCommand command)
Whether a command is appropriate to bring the memory to a more desired
state.
|
void |
SimpleGCMonitoringOracle.commandCompleted(IOCommand command) |
void |
MemoryEstimatorOracle.commandCompleted(IOCommand command) |
void |
ThresholdBasedOracle.commandCompleted(IOCommand command) |
void |
FixedPartitionsOracle.commandCompleted(IOCommand command) |
void |
OutOfCoreOracle.commandCompleted(IOCommand command)
Notification of command completion.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.