public class StoreIncomingMessageIOCommand extends IOCommand
IOCommand.IOCommandTypenumBytesTransferred, oocEngine, partitionId| Constructor and Description |
|---|
StoreIncomingMessageIOCommand(OutOfCoreEngine oocEngine,
int partitionId)
Constructor
|
| 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() |
bytesTransferred, getPartitionIdpublic StoreIncomingMessageIOCommand(OutOfCoreEngine oocEngine, int partitionId)
oocEngine - out-of-core enginepartitionId - id of the partition to store its incoming messagespublic boolean execute()
throws IOException
IOCommandexecute in class IOCommandIOExceptionpublic IOCommand.IOCommandType getType()
IOCommandCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.