Uses of Class
voldemort.versioning.Versioned

Packages that use Versioned

voldemort.client	The user facing interface to Voldemort.
voldemort.client.protocol	Classes that abstract the serialization format for Voldemort client requests.
voldemort.client.protocol.admin	Classes that abstract admin based Voldemort requests.
voldemort.client.protocol.admin.filter	Classes that deal with filters that can be used by our streaming API
voldemort.client.protocol.pb	A protocol buffers based client-side request format.
voldemort.client.protocol.vold	Classes specific to our native Voldemort protocol.
voldemort.serialization	Code for mapping objects to bytes and bytes to objects.
voldemort.versioning	Classes for operating on vector clocks and dealing with distributed state.

Uses of Versioned in voldemort.client

Methods in voldemort.client that return Versioned

Versioned<V>	StoreClient.get(K key) Get the versioned value associated with the given key or null if no value is associated with the key.
Versioned<V>	LazyStoreClient.get(K key)
Versioned<V>	DefaultStoreClient.get(K key)
Versioned<V>	StoreClient.get(K key, java.lang.Object transforms) Get the versioned value associated with the given key and apply the given transforms to it before returning the value.
Versioned<V>	LazyStoreClient.get(K key, java.lang.Object transforms)
Versioned<V>	DefaultStoreClient.get(K key, java.lang.Object transforms)
Versioned<V>	StoreClient.get(K key, Versioned<V> defaultValue) Get the versioned value associated with the given key or the defaultValue if no value is associated with the key.
Versioned<V>	LazyStoreClient.get(K key, Versioned<V> defaultValue)
Versioned<V>	DefaultStoreClient.get(K key, Versioned<V> defaultValue)
Versioned<V>	DefaultStoreClient.get(K key, Versioned<V> defaultValue, java.lang.Object transform)

Methods in voldemort.client that return types with arguments of type Versioned

java.util.Map<K,Versioned<V>>	StoreClient.getAll(java.lang.Iterable<K> keys) Gets the versioned values associated with the given keys and returns them in a Map of keys to versioned values.
java.util.Map<K,Versioned<V>>	LazyStoreClient.getAll(java.lang.Iterable<K> keys)
java.util.Map<K,Versioned<V>>	DefaultStoreClient.getAll(java.lang.Iterable<K> keys)
java.util.Map<K,Versioned<V>>	StoreClient.getAll(java.lang.Iterable<K> keys, java.util.Map<K,java.lang.Object> transforms) Like getAll, except that the transforms are applied on the value associated with each key before returning the results
java.util.Map<K,Versioned<V>>	LazyStoreClient.getAll(java.lang.Iterable<K> keys, java.util.Map<K,java.lang.Object> transforms)
java.util.Map<K,Versioned<V>>	DefaultStoreClient.getAll(java.lang.Iterable<K> keys, java.util.Map<K,java.lang.Object> transforms)
protected java.util.List<Versioned<java.lang.String>>	SocketStoreClientFactory.getRemoteMetadata(java.lang.String key, java.net.URI url)
protected java.util.List<Versioned<java.lang.String>>	AbstractStoreClientFactory.getRemoteMetadata(java.lang.String key, java.net.URI url)

Methods in voldemort.client with parameters of type Versioned

Versioned<V>	StoreClient.get(K key, Versioned<V> defaultValue) Get the versioned value associated with the given key or the defaultValue if no value is associated with the key.
Versioned<V>	LazyStoreClient.get(K key, Versioned<V> defaultValue)
Versioned<V>	DefaultStoreClient.get(K key, Versioned<V> defaultValue)
Versioned<V>	DefaultStoreClient.get(K key, Versioned<V> defaultValue, java.lang.Object transform)
Version	StoreClient.put(K key, Versioned<V> versioned) Put the given Versioned value into the store for the given key if the version is greater to or concurrent with existing values.
Version	LazyStoreClient.put(K key, Versioned<V> versioned)
Version	DefaultStoreClient.put(K key, Versioned<V> versioned)
Version	DefaultStoreClient.put(K key, Versioned<V> versioned, java.lang.Object transform)
boolean	StoreClient.putIfNotObsolete(K key, Versioned<V> versioned) Put the versioned value to the key, ignoring any ObsoleteVersionException that may be thrown
boolean	LazyStoreClient.putIfNotObsolete(K key, Versioned<V> versioned)
boolean	DefaultStoreClient.putIfNotObsolete(K key, Versioned<V> versioned)

Method parameters in voldemort.client with type arguments of type Versioned

<K,V,T> voldemort.store.Store<K,V,T>	StoreClientFactory.getRawStore(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver) Get the underlying store, not the public StoreClient interface
<K,V,T> voldemort.store.Store<K,V,T>	CachingStoreClientFactory.getRawStore(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver)
<K,V,T> voldemort.store.Store<K,V,T>	AbstractStoreClientFactory.getRawStore(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver)
<K1,V1,T1> voldemort.store.Store<K1,V1,T1>	MockStoreClientFactory.getRawStore(java.lang.String storeName, InconsistencyResolver<Versioned<V1>> resolver)
<K,V> StoreClient<K,V>	StoreClientFactory.getStoreClient(java.lang.String storeName, InconsistencyResolver<Versioned<V>> inconsistencyResolver) Get a StoreClient for the given store.
<K,V> StoreClient<K,V>	SocketStoreClientFactory.getStoreClient(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver)
<K,V> StoreClient<K,V>	MockStoreClientFactory.getStoreClient(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver)
<K,V> StoreClient<K,V>	CachingStoreClientFactory.getStoreClient(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver)
<K,V> StoreClient<K,V>	AbstractStoreClientFactory.getStoreClient(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver)

Constructor parameters in voldemort.client with type arguments of type Versioned

DefaultStoreClient(java.lang.String storeName, InconsistencyResolver<Versioned<V>> resolver, StoreClientFactory storeFactory, int maxMetadataRefreshAttempts)

Uses of Versioned in voldemort.client.protocol

Methods in voldemort.client.protocol that return types with arguments of type Versioned

java.util.Map<voldemort.utils.ByteArray,java.util.List<Versioned<byte[]>>>	RequestFormat.readGetAllResponse(java.io.DataInputStream stream)
java.util.List<Versioned<byte[]>>	RequestFormat.readGetResponse(java.io.DataInputStream stream)

Methods in voldemort.client.protocol with parameters of type Versioned

boolean

VoldemortFilter.accept(java.lang.Object key, Versioned<?> value) Extend this function to implement custom filter strategies.

Uses of Versioned in voldemort.client.protocol.admin

Methods in voldemort.client.protocol.admin that return Versioned

Versioned<voldemort.cluster.Cluster>	AdminClient.getRemoteCluster(int nodeId) Get the cluster information from a remote node.
Versioned<java.lang.String>	AdminClient.getRemoteMetadata(int remoteNodeId, java.lang.String key) Get the metadata on a remote node.
Versioned<voldemort.store.metadata.MetadataStore.VoldemortState>	AdminClient.getRemoteServerState(int nodeId) Retrieve the server state from a remote node.
Versioned<java.util.List<voldemort.store.StoreDefinition>>	AdminClient.getRemoteStoreDefList(int nodeId) Retrieve the store definitions from a remote node.

Methods in voldemort.client.protocol.admin that return types with arguments of type Versioned

java.util.Iterator<voldemort.utils.Pair<voldemort.utils.ByteArray,Versioned<byte[]>>>	AdminClient.fetchEntries(int nodeId, java.lang.String storeName, java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList, VoldemortFilter filter, boolean fetchMasterEntries, voldemort.cluster.Cluster initialCluster, long skipRecords) Fetch key/value tuples belonging to this map of replica type to partition list
java.util.Iterator<voldemort.utils.Pair<voldemort.utils.ByteArray,Versioned<byte[]>>>	AdminClient.fetchEntries(int nodeId, java.lang.String storeName, java.util.List<java.lang.Integer> partitionList, VoldemortFilter filter, boolean fetchMasterEntries) Legacy interface for fetching entries.
java.util.Iterator<voldemort.utils.Pair<voldemort.utils.ByteArray,Versioned<byte[]>>>	AdminClient.fetchEntries(int nodeId, java.lang.String storeName, java.util.List<java.lang.Integer> partitionList, VoldemortFilter filter, boolean fetchMasterEntries, long skipRecords) Legacy interface for fetching entries.

Methods in voldemort.client.protocol.admin with parameters of type Versioned

void	AdminClient.updateRemoteMetadata(int remoteNodeId, java.lang.String key, Versioned<java.lang.String> value) Update metadata at the given remoteNodeId.

Method parameters in voldemort.client.protocol.admin with type arguments of type Versioned

void	AdminClient.updateEntries(int nodeId, java.lang.String storeName, java.util.Iterator<voldemort.utils.Pair<voldemort.utils.ByteArray,Versioned<byte[]>>> entryIterator, VoldemortFilter filter) Update a stream of key/value entries at the given node.
void	AdminClient.updateSlopEntries(int nodeId, java.util.Iterator<Versioned<voldemort.store.slop.Slop>> entryIterator) Update slops which may be meant for multiple stores

Uses of Versioned in voldemort.client.protocol.admin.filter

Methods in voldemort.client.protocol.admin.filter with parameters of type Versioned

boolean

DefaultVoldemortFilter.accept(java.lang.Object key, Versioned<?> value)

Uses of Versioned in voldemort.client.protocol.pb

Methods in voldemort.client.protocol.pb that return Versioned

static Versioned<byte[]>

ProtoUtils.decodeVersioned(VProto.Versioned versioned)

Methods in voldemort.client.protocol.pb that return types with arguments of type Versioned

static java.util.List<Versioned<byte[]>>	ProtoUtils.decodeVersions(java.util.List<VProto.Versioned> versioned)
java.util.Map<voldemort.utils.ByteArray,java.util.List<Versioned<byte[]>>>	ProtoBuffClientRequestFormat.readGetAllResponse(java.io.DataInputStream input)
java.util.List<Versioned<byte[]>>	ProtoBuffClientRequestFormat.readGetResponse(java.io.DataInputStream input)

Methods in voldemort.client.protocol.pb with parameters of type Versioned

static VProto.Versioned.Builder

ProtoUtils.encodeVersioned(Versioned<byte[]> versioned)

Uses of Versioned in voldemort.client.protocol.vold

Methods in voldemort.client.protocol.vold that return types with arguments of type Versioned

java.util.Map<voldemort.utils.ByteArray,java.util.List<Versioned<byte[]>>>	VoldemortNativeClientRequestFormat.readGetAllResponse(java.io.DataInputStream stream)
java.util.List<Versioned<byte[]>>	VoldemortNativeClientRequestFormat.readGetResponse(java.io.DataInputStream inputStream)

Uses of Versioned in voldemort.serialization

Methods in voldemort.serialization that return Versioned

Versioned<T>

VersionedSerializer.toObject(byte[] bytes)

Methods in voldemort.serialization with parameters of type Versioned

VoldemortOperation	VoldemortOperation.makePutOperation(java.lang.String key, Versioned<byte[]> versioned)
byte[]	VersionedSerializer.toBytes(Versioned<T> versioned)

Uses of Versioned in voldemort.versioning

Methods in voldemort.versioning that return Versioned

Versioned<T>	Versioned.cloneVersioned() Create a clone of this Versioned object such that the object pointed to is the same, but the VectorClock and Versioned wrapper is a shallow copy.
static <S> Versioned<S>	Versioned.value(S s)
static <S> Versioned<S>	Versioned.value(S s, Version v)

Methods in voldemort.versioning that return types with arguments of type Versioned

java.util.List<Versioned<T>>	VectorClockInconsistencyResolver.resolveConflicts(java.util.List<Versioned<T>> items)
java.util.List<Versioned<T>>	TimeBasedInconsistencyResolver.resolveConflicts(java.util.List<Versioned<T>> items)
java.util.List<Versioned<T>>	MergingInconsistencyResolver.resolveConflicts(java.util.List<Versioned<T>> items)

Methods in voldemort.versioning with parameters of type Versioned

int	Versioned.HappenedBeforeComparator.compare(Versioned<S> v1, Versioned<S> v2)
int	Versioned.HappenedBeforeComparator.compare(Versioned<S> v1, Versioned<S> v2)

Method parameters in voldemort.versioning with type arguments of type Versioned

java.util.List<Versioned<T>>	VectorClockInconsistencyResolver.resolveConflicts(java.util.List<Versioned<T>> items)
java.util.List<Versioned<T>>	TimeBasedInconsistencyResolver.resolveConflicts(java.util.List<Versioned<T>> items)
java.util.List<Versioned<T>>	MergingInconsistencyResolver.resolveConflicts(java.util.List<Versioned<T>> items)