org.usergrid.persistence.cassandra
Class IndexUpdate
java.lang.Object
org.usergrid.persistence.cassandra.IndexUpdate
public class IndexUpdate
- extends Object
Constructor Summary |
IndexUpdate(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
Entity entity,
String entryName,
Object entryValue,
boolean schemaHasProperty,
boolean isMultiValue,
boolean removeListEntry,
UUID timestampUuid)
|
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
IndexUpdate
public IndexUpdate(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
Entity entity,
String entryName,
Object entryValue,
boolean schemaHasProperty,
boolean isMultiValue,
boolean removeListEntry,
UUID timestampUuid)
getBatch
public me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> getBatch()
setBatch
public void setBatch(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch)
getEntity
public Entity getEntity()
setEntity
public void setEntity(Entity entity)
getId
public UUID getId()
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<IndexUpdate.IndexEntry> getPrevEntries()
addPrevEntry
public void addPrevEntry(String path,
Object value,
UUID timestamp,
ByteBuffer ledgerValue)
getNewEntries
public List<IndexUpdate.IndexEntry> getNewEntries()
addNewEntry
public void addNewEntry(String path,
Object value)
getIndexesSet
public Set<String> getIndexesSet()
addIndex
public void addIndex(String index)
isSchemaHasProperty
public boolean isSchemaHasProperty()
setSchemaHasProperty
public void setSchemaHasProperty(boolean schemaHasProperty)
isMultiValue
public boolean isMultiValue()
setMultiValue
public void setMultiValue(boolean isMultiValue)
isRemoveListEntry
public boolean isRemoveListEntry()
setRemoveListEntry
public void setRemoveListEntry(boolean removeListEntry)
setAssociatedId
public void setAssociatedId(UUID associatedId)
getAssociatedId
public UUID getAssociatedId()
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.