edu.iu.dsc.tws.data.memory

Class OperationMemoryManager

java.lang.Object

edu.iu.dsc.tws.data.memory.OperationMemoryManager

public class OperationMemoryManager
extends java.lang.Object

This controls the memory manager for a single operation. An example of an operation is a gather, reduce. Note: This class needs to implment all the methods in the Memory Manager interface without the operationID parameter

TODO: We can latter look into making the operation manager typed. Based on the messageType TODO: Then the get methods such as the iterator can directly return the typed objects

Constructor Summary

Constructors

Constructor and Description
OperationMemoryManager(int opID, DataMessageType type, DataMessageType keyType, MemoryManager parentMM)
OperationMemoryManager(int opID, DataMessageType type, MemoryManager parentMM)

Method Summary

Modifier and Type	Method and Description
boolean	append(java.nio.ByteBuffer key, java.nio.ByteBuffer value)
boolean	append(java.lang.String key, java.nio.ByteBuffer value)
boolean	close(java.nio.ByteBuffer key)
boolean	close(java.lang.String key)
boolean	containsKey(java.nio.ByteBuffer key)
boolean	containsKey(java.lang.String key)
boolean	delete(java.nio.ByteBuffer key)
boolean	delete(java.lang.String key)
boolean	flush()
boolean	flush(java.nio.ByteBuffer key)
boolean	flush(java.lang.String key)
java.nio.ByteBuffer	get(java.nio.ByteBuffer key)
java.nio.ByteBuffer	get(java.lang.String key)
DataMessageType	getKeyType()
MemoryManager	getMemoryManager()
DataMessageType	getMessageType()
int	getOperationID()
boolean	init()
boolean	isKeyed()
java.util.Iterator<java.lang.Object>	iterator() returns the deserialized data as a iterator if the operation is keyed the iterator will return a list of pairs if the operation is not keyed it will return a list of objects
java.util.Iterator<java.lang.Object>	iterator(java.nio.ByteOrder order)
boolean	put(byte[] key, byte[] data)
boolean	put(java.nio.ByteBuffer key, java.nio.ByteBuffer value)
boolean	put(java.lang.String key, java.nio.ByteBuffer value)
void	setKeyed(boolean keyed)
void	setKeyType(DataMessageType keyType)
void	setMemoryManager(MemoryManager memoryManager)
void	setMessageType(DataMessageType messageType)
void	setOperationID(int operationID)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationMemoryManager

public OperationMemoryManager(int opID,
                              DataMessageType type,
                              MemoryManager parentMM)

OperationMemoryManager

public OperationMemoryManager(int opID,
                              DataMessageType type,
                              DataMessageType keyType,
                              MemoryManager parentMM)

Method Detail

init

public boolean init()

append

public boolean append(java.nio.ByteBuffer key,
                      java.nio.ByteBuffer value)

append

public boolean append(java.lang.String key,
                      java.nio.ByteBuffer value)

put

public boolean put(java.nio.ByteBuffer key,
                   java.nio.ByteBuffer value)

put

public boolean put(byte[] key,
                   byte[] data)

put

public boolean put(java.lang.String key,
                   java.nio.ByteBuffer value)

get

public java.nio.ByteBuffer get(java.nio.ByteBuffer key)

get

public java.nio.ByteBuffer get(java.lang.String key)

containsKey

public boolean containsKey(java.nio.ByteBuffer key)

containsKey

public boolean containsKey(java.lang.String key)

delete

public boolean delete(java.nio.ByteBuffer key)

delete

public boolean delete(java.lang.String key)

flush

public boolean flush(java.nio.ByteBuffer key)

flush

public boolean flush()

flush

public boolean flush(java.lang.String key)

close

public boolean close(java.nio.ByteBuffer key)

close

public boolean close(java.lang.String key)

getOperationID

public int getOperationID()

setOperationID

public void setOperationID(int operationID)

getMemoryManager

public MemoryManager getMemoryManager()

setMemoryManager

public void setMemoryManager(MemoryManager memoryManager)

iterator

public java.util.Iterator<java.lang.Object> iterator()

returns the deserialized data as a iterator if the operation is keyed the iterator will return a list of pairs if the operation is not keyed it will return a list of objects

iterator

public java.util.Iterator<java.lang.Object> iterator(java.nio.ByteOrder order)

getKeyType

public DataMessageType getKeyType()

setKeyType

public void setKeyType(DataMessageType keyType)

getMessageType

public DataMessageType getMessageType()

setMessageType

public void setMessageType(DataMessageType messageType)

isKeyed

public boolean isKeyed()

setKeyed

public void setKeyed(boolean keyed)