voldemort.store.rebalancing
Class RebootstrappingStore

java.lang.Object
  voldemort.store.DelegatingStore<ByteArray,byte[],byte[]>
      voldemort.store.rebalancing.RebootstrappingStore

All Implemented Interfaces:

Store<ByteArray,byte[],byte[]>

public class RebootstrappingStore
extends DelegatingStore<ByteArray,byte[],byte[]>

The RebootstrappingStore catch all InvalidMetadataException and updates the routed store with latest cluster metadata, client rebootstrapping behavior same in DefaultStoreClient for server side routing

Constructor Summary

RebootstrappingStore(MetadataStore metadata, StoreRepository storeRepository, VoldemortConfig voldemortConfig, RoutedStore routedStore, SocketStoreFactory storeFactory)

Method Summary

boolean	delete(ByteArray key, Version version) Delete all entries prior to the given version
java.util.List<Versioned<byte[]>>	get(ByteArray key, byte[] transforms) Get the value associated with the given key
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms) Get the values associated with the given keys and returns them in a Map of keys to a list of versioned values.
java.util.List<Version>	getVersions(ByteArray key)
void	put(ByteArray key, Versioned<byte[]> versioned, byte[] transforms) Associate the value with the key and version in this store

Methods inherited from class voldemort.store.DelegatingStore

close, getCapability, getInnerStore, getName, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

RebootstrappingStore

public RebootstrappingStore(MetadataStore metadata,
                            StoreRepository storeRepository,
                            VoldemortConfig voldemortConfig,
                            RoutedStore routedStore,
                            SocketStoreFactory storeFactory)

Method Detail

delete

public boolean delete(ByteArray key,
                      Version version)

Description copied from interface: Store

Delete all entries prior to the given version

Specified by:

delete in interface Store<ByteArray,byte[],byte[]>

Overrides:

delete in class DelegatingStore<ByteArray,byte[],byte[]>

Parameters:

key - The key to delete

version - The current value of the key

Returns:

True if anything was deleted

getVersions

public java.util.List<Version> getVersions(ByteArray key)

Specified by:

getVersions in interface Store<ByteArray,byte[],byte[]>

Overrides:

getVersions in class DelegatingStore<ByteArray,byte[],byte[]>

get

public java.util.List<Versioned<byte[]>> get(ByteArray key,
                                             byte[] transforms)

Description copied from interface: Store

Get the value associated with the given key

Specified by:

get in interface Store<ByteArray,byte[],byte[]>

Overrides:

get in class DelegatingStore<ByteArray,byte[],byte[]>

Parameters:

key - The key to check for

Returns:

The value associated with the key or an empty list if no values are found.

getAll

public java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>> getAll(java.lang.Iterable<ByteArray> keys,
                                                                         java.util.Map<ByteArray,byte[]> transforms)

Description copied from interface: Store

Get the values associated with the given keys and returns them in a Map of keys to a list of versioned values. Note that the returned map will only contain entries for the keys which have a value associated with them.

Specified by:

getAll in interface Store<ByteArray,byte[],byte[]>

Overrides:

getAll in class DelegatingStore<ByteArray,byte[],byte[]>

Parameters:

keys - The keys to check for.

Returns:

A Map of keys to a list of versioned values.

put

public void put(ByteArray key,
                Versioned<byte[]> versioned,
                byte[] transforms)
         throws ObsoleteVersionException

Description copied from interface: Store

Associate the value with the key and version in this store

Specified by:

put in interface Store<ByteArray,byte[],byte[]>

Overrides:

put in class DelegatingStore<ByteArray,byte[],byte[]>

Parameters:

key - The key to use

versioned - The value to store and its version.

Throws:

ObsoleteVersionException