org.usergrid.mq.cassandra
Class QueueIndexUpdate
java.lang.Object
org.usergrid.mq.cassandra.QueueIndexUpdate
public class QueueIndexUpdate
- extends Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
QueueIndexUpdate
public QueueIndexUpdate(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
String queuePath,
UUID queueId,
String entryName,
Object entryValue,
UUID timestampUuid)
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.