org.usergrid.mq.cassandra
Class QueueIndexUpdate

java.lang.Object
  extended by org.usergrid.mq.cassandra.QueueIndexUpdate

public class QueueIndexUpdate
extends Object


Nested Class Summary
 class QueueIndexUpdate.QueueIndexEntry
           
 
Field Summary
static int INDEX_STRING_VALUE_LENGTH
           
static byte VALUE_CODE_BYTES
           
static byte VALUE_CODE_INT
           
static byte VALUE_CODE_MAX
           
static byte VALUE_CODE_UTF8
           
static byte VALUE_CODE_UUID
           
 
Constructor Summary
QueueIndexUpdate(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch, String queuePath, UUID queueId, String entryName, Object entryValue, UUID timestampUuid)
           
 
Method Summary
 void addIndex(String index)
           
 void addNewEntry(String path, Object value)
           
 void addPrevEntry(String path, Object value, UUID timestamp)
           
static int compareIndexedValues(Object o1, Object o2)
           
 me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> getBatch()
           
 String getEntryName()
           
 Object getEntryValue()
           
 Set<String> getIndexesSet()
           
 List<QueueIndexUpdate.QueueIndexEntry> getNewEntries()
           
 List<QueueIndexUpdate.QueueIndexEntry> getPrevEntries()
           
 UUID getQueueId()
           
 String getQueuePath()
           
 long getTimestamp()
           
 UUID getTimestampUuid()
           
static byte indexValueCode(Object obj)
           
 void setBatch(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch)
           
 void setEntryName(String entryName)
           
 void setEntryValue(Object entryValue)
           
 void setQueueId(UUID queueId)
           
 void setQueuePath(String queuePath)
           
 void setTimestamp(long timestamp)
           
static Object toIndexableValue(Object obj)
           
static boolean validIndexableValue(Object obj)
           
static boolean validIndexableValueOrJson(Object obj)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

VALUE_CODE_BYTES

public static final byte VALUE_CODE_BYTES
See Also:
Constant Field Values

VALUE_CODE_UTF8

public static final byte VALUE_CODE_UTF8
See Also:
Constant Field Values

VALUE_CODE_UUID

public static final byte VALUE_CODE_UUID
See Also:
Constant Field Values

VALUE_CODE_INT

public static final byte VALUE_CODE_INT
See Also:
Constant Field Values

VALUE_CODE_MAX

public static final byte VALUE_CODE_MAX
See Also:
Constant Field Values

INDEX_STRING_VALUE_LENGTH

public static int INDEX_STRING_VALUE_LENGTH
Constructor Detail

QueueIndexUpdate

public QueueIndexUpdate(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
                        String queuePath,
                        UUID queueId,
                        String entryName,
                        Object entryValue,
                        UUID timestampUuid)
Method Detail

getBatch

public me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> getBatch()

setBatch

public void setBatch(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch)

getQueuePath

public String getQueuePath()

setQueuePath

public void setQueuePath(String queuePath)

getQueueId

public UUID getQueueId()

setQueueId

public void setQueueId(UUID queueId)

getEntryName

public String getEntryName()

setEntryName

public void setEntryName(String entryName)

getEntryValue

public Object getEntryValue()

setEntryValue

public void setEntryValue(Object entryValue)

getTimestamp

public long getTimestamp()

setTimestamp

public void setTimestamp(long timestamp)

getTimestampUuid

public UUID getTimestampUuid()

getPrevEntries

public List<QueueIndexUpdate.QueueIndexEntry> getPrevEntries()

addPrevEntry

public void addPrevEntry(String path,
                         Object value,
                         UUID timestamp)

getNewEntries

public List<QueueIndexUpdate.QueueIndexEntry> getNewEntries()

addNewEntry

public void addNewEntry(String path,
                        Object value)

getIndexesSet

public Set<String> getIndexesSet()

addIndex

public void addIndex(String index)

toIndexableValue

public static Object toIndexableValue(Object obj)
Parameters:
obj -
Returns:

validIndexableValue

public static boolean validIndexableValue(Object obj)

validIndexableValueOrJson

public static boolean validIndexableValueOrJson(Object obj)

indexValueCode

public static byte indexValueCode(Object obj)

compareIndexedValues

public static int compareIndexedValues(Object o1,
                                       Object o2)


Copyright © 2013. All Rights Reserved.