Uses of Class
voldemort.utils.ByteArray

Packages that use ByteArray

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.pb	A protocol buffers based client-side request format.
voldemort.client.protocol.vold	Classes specific to our native Voldemort protocol.
voldemort.cluster.failuredetector	Classes associated with client side failure detectors.
voldemort.serialization	Code for mapping objects to bytes and bytes to objects.
voldemort.server	The Voldemort server.
voldemort.server.protocol	The server side of request RPC handling.
voldemort.server.protocol.admin	Server side implementation of admin based requests
voldemort.server.storage	The storage service which handles instantiating all the stores and their corresponding engines.
voldemort.store	The Store interface is the primary interface for Voldemort.
voldemort.store.bdb	A storage engine that persists data in BDB JE.
voldemort.store.compress	Classes associated with compression on the server ( storage ) side.
voldemort.store.http	HTTP based storage engine
voldemort.store.invalidmetadata	Server side store which checks whether the tuples coming to this node are valid.
voldemort.store.memory	An in-memory storage engine that serves data out of a non-persistent map.
voldemort.store.metadata	Our in-memory metadata store on the server which is backed by the configuration files.
voldemort.store.mysql	A storage engine that persists data in a mysql instance.
voldemort.store.nonblockingstore	Non-blocking store which deals with async requests.
voldemort.store.readonly	A storage engine that provides very efficient read-only access to large sorted files of data.
voldemort.store.readonly.chunk	Read-only store classes for understanding various format changes.
voldemort.store.rebalancing	Server side wrapper stores used for redirection during rebalancing.
voldemort.store.routed	A store implmentation that handles routing to nodes, and repairing obsolete values detected on those nodes.
voldemort.store.routed.action	Classes representing various states for the state based routing stores.
voldemort.store.serialized	A store implementation that handles serialization to bytes from rich objects.
voldemort.store.slop	A store implementation that falls back on storing values in additional nodes not in the preference list when nodes are unavailable.
voldemort.store.socket	A store implementation that works remotely over a tcp/ip socket interacting with a SocketServer on the the other side.
voldemort.store.socket.clientrequest	More classes related to how to parse client requests
voldemort.store.stats	Store wrappers which deal with statistics
voldemort.store.views	Classes related to Views and server side transforms
voldemort.utils	Basic helper functions.

Uses of ByteArray in voldemort.client

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

protected Store<ByteArray,byte[],byte[]>	SocketStoreClientFactory.getStore(java.lang.String storeName, java.lang.String host, int port, RequestFormatType type)
protected Store<ByteArray,byte[],byte[]>	HttpStoreClientFactory.getStore(java.lang.String name, java.lang.String host, int port, RequestFormatType type)
protected abstract Store<ByteArray,byte[],byte[]>	AbstractStoreClientFactory.getStore(java.lang.String storeName, java.lang.String host, int port, RequestFormatType type)

Uses of ByteArray in voldemort.client.protocol

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

java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>

RequestFormat.readGetAllResponse(java.io.DataInputStream stream)

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

void	RequestFormat.writeDeleteRequest(java.io.DataOutputStream output, java.lang.String storeName, ByteArray key, VectorClock version, RequestRoutingType routingType)
void	RequestFormat.writeGetRequest(java.io.DataOutputStream output, java.lang.String storeName, ByteArray key, byte[] transforms, RequestRoutingType routingType)
void	RequestFormat.writeGetVersionRequest(java.io.DataOutputStream output, java.lang.String storeName, ByteArray key, RequestRoutingType routingType)
void	RequestFormat.writePutRequest(java.io.DataOutputStream output, java.lang.String storeName, ByteArray key, byte[] value, byte[] transforms, VectorClock version, RequestRoutingType routingType)

Method parameters in voldemort.client.protocol with type arguments of type ByteArray

void	RequestFormat.writeGetAllRequest(java.io.DataOutputStream output, java.lang.String storeName, java.lang.Iterable<ByteArray> key, java.util.Map<ByteArray,byte[]> transforms, RequestRoutingType routingType)
void	RequestFormat.writeGetAllRequest(java.io.DataOutputStream output, java.lang.String storeName, java.lang.Iterable<ByteArray> key, java.util.Map<ByteArray,byte[]> transforms, RequestRoutingType routingType)

Uses of ByteArray in voldemort.client.protocol.admin

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

java.util.Iterator<Pair<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, Cluster initialCluster, long skipRecords) Fetch key/value tuples belonging to this map of replica type to partition list
java.util.Iterator<Pair<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<Pair<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.
java.util.Iterator<ByteArray>	AdminClient.fetchKeys(int nodeId, java.lang.String storeName, java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList, VoldemortFilter filter, boolean fetchMasterEntries, Cluster initialCluster, long skipRecords) Fetch all keys belonging to the map of replica type to partition list.
java.util.Iterator<ByteArray>	AdminClient.fetchKeys(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<ByteArray>	AdminClient.fetchKeys(int nodeId, java.lang.String storeName, java.util.List<java.lang.Integer> partitionList, VoldemortFilter filter, boolean fetchMasterEntries, long skipRecords) Legacy interface for fetching entries.

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

void	AdminClient.updateEntries(int nodeId, java.lang.String storeName, java.util.Iterator<Pair<ByteArray,Versioned<byte[]>>> entryIterator, VoldemortFilter filter) Update a stream of key/value entries at the given node.

Uses of ByteArray in voldemort.client.protocol.pb

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

static ByteArray

ProtoUtils.decodeBytes(com.google.protobuf.ByteString string)

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

java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>

ProtoBuffClientRequestFormat.readGetAllResponse(java.io.DataInputStream input)

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

static com.google.protobuf.ByteString	ProtoUtils.encodeBytes(ByteArray array)
void	ProtoBuffClientRequestFormat.writeDeleteRequest(java.io.DataOutputStream output, java.lang.String storeName, ByteArray key, VectorClock version, RequestRoutingType routingType)
void	ProtoBuffClientRequestFormat.writeGetRequest(java.io.DataOutputStream output, java.lang.String storeName, ByteArray key, byte[] transforms, RequestRoutingType routingType)
void	ProtoBuffClientRequestFormat.writeGetVersionRequest(java.io.DataOutputStream output, java.lang.String storeName, ByteArray key, RequestRoutingType routingType)
void	ProtoBuffClientRequestFormat.writePutRequest(java.io.DataOutputStream output, java.lang.String storeName, ByteArray key, byte[] value, byte[] transforms, VectorClock version, RequestRoutingType routingType)

Method parameters in voldemort.client.protocol.pb with type arguments of type ByteArray

void	ProtoBuffClientRequestFormat.writeGetAllRequest(java.io.DataOutputStream output, java.lang.String storeName, java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, RequestRoutingType routingType)
void	ProtoBuffClientRequestFormat.writeGetAllRequest(java.io.DataOutputStream output, java.lang.String storeName, java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, RequestRoutingType routingType)

Uses of ByteArray in voldemort.client.protocol.vold

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

java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>

VoldemortNativeClientRequestFormat.readGetAllResponse(java.io.DataInputStream stream)

Methods in voldemort.client.protocol.vold with parameters of type ByteArray

void	VoldemortNativeClientRequestFormat.writeDeleteRequest(java.io.DataOutputStream outputStream, java.lang.String storeName, ByteArray key, VectorClock version, RequestRoutingType routingType)
void	VoldemortNativeClientRequestFormat.writeGetRequest(java.io.DataOutputStream outputStream, java.lang.String storeName, ByteArray key, byte[] transforms, RequestRoutingType routingType)
void	VoldemortNativeClientRequestFormat.writeGetVersionRequest(java.io.DataOutputStream output, java.lang.String storeName, ByteArray key, RequestRoutingType routingType)
void	VoldemortNativeClientRequestFormat.writePutRequest(java.io.DataOutputStream outputStream, java.lang.String storeName, ByteArray key, byte[] value, byte[] transforms, VectorClock version, RequestRoutingType routingType)

Method parameters in voldemort.client.protocol.vold with type arguments of type ByteArray

void	VoldemortNativeClientRequestFormat.writeGetAllRequest(java.io.DataOutputStream output, java.lang.String storeName, java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, RequestRoutingType routingType)
void	VoldemortNativeClientRequestFormat.writeGetAllRequest(java.io.DataOutputStream output, java.lang.String storeName, java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, RequestRoutingType routingType)

Uses of ByteArray in voldemort.cluster.failuredetector

Fields in voldemort.cluster.failuredetector declared as ByteArray

static ByteArray

StoreVerifier.KEY

Methods in voldemort.cluster.failuredetector that return types with arguments of type ByteArray

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

ClientStoreVerifier.getStoreInternal(Node node)

Uses of ByteArray in voldemort.serialization

Methods in voldemort.serialization that return ByteArray

ByteArray

ByteArraySerializer.toObject(byte[] bytes)

Methods in voldemort.serialization with parameters of type ByteArray

byte[]

ByteArraySerializer.toBytes(ByteArray object)

Uses of ByteArray in voldemort.server

Methods in voldemort.server that return types with arguments of type ByteArray

java.util.List<Store<ByteArray,byte[],byte[]>>	StoreRepository.getAllLocalStores()
java.util.List<Pair<java.lang.Integer,Store<ByteArray,byte[],byte[]>>>	StoreRepository.getAllNodeStores()
java.util.List<Store<ByteArray,byte[],byte[]>>	StoreRepository.getAllRoutedStores()
java.util.List<StorageEngine<ByteArray,byte[],byte[]>>	StoreRepository.getAllStorageEngines()
Store<ByteArray,byte[],byte[]>	StoreRepository.getLocalStore(java.lang.String storeName)
Store<ByteArray,byte[],byte[]>	StoreRepository.getNodeStore(java.lang.String storeName, java.lang.Integer id)
Store<ByteArray,byte[],byte[]>	StoreRepository.getRedirectingSocketStore(java.lang.String storeName, java.lang.Integer id)
Store<ByteArray,byte[],byte[]>	StoreRepository.getRoutedStore(java.lang.String storeName)
StorageEngine<ByteArray,byte[],byte[]>	StoreRepository.getStorageEngine(java.lang.String storeName)
java.util.List<StorageEngine<ByteArray,byte[],byte[]>>	StoreRepository.getStorageEnginesByClass(java.lang.Class<? extends StorageEngine<?,?,?>> c)
Store<ByteArray,byte[],byte[]>	StoreRepository.removeLocalStore(java.lang.String storeName)
Store<ByteArray,byte[],byte[]>	StoreRepository.removeNodeStore(java.lang.String storeName, int nodeId)
Store<ByteArray,byte[],byte[]>	StoreRepository.removeRoutedStore(java.lang.String storeName)
Store<ByteArray,byte[],byte[]>	StoreRepository.removeStorageEngine(java.lang.String storeName)

Method parameters in voldemort.server with type arguments of type ByteArray

void	StoreRepository.addLocalStore(Store<ByteArray,byte[],byte[]> store)
void	StoreRepository.addNodeStore(int nodeId, Store<ByteArray,byte[],byte[]> store)
void	StoreRepository.addRedirectingSocketStore(int nodeId, Store<ByteArray,byte[],byte[]> store)
void	StoreRepository.addRoutedStore(Store<ByteArray,byte[],byte[]> store)
void	StoreRepository.addStorageEngine(StorageEngine<ByteArray,byte[],byte[]> engine)

Uses of ByteArray in voldemort.server.protocol

Methods in voldemort.server.protocol that return types with arguments of type ByteArray

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

AbstractRequestHandler.getStore(java.lang.String name, RequestRoutingType type)

Uses of ByteArray in voldemort.server.protocol.admin

Fields in voldemort.server.protocol.admin with type parameters of type ByteArray

protected ClosableIterator<ByteArray>	FetchStreamRequestHandler.keyIterator
protected StorageEngine<ByteArray,byte[],byte[]>	FetchStreamRequestHandler.storageEngine

Uses of ByteArray in voldemort.server.storage

Method parameters in voldemort.server.storage with type arguments of type ByteArray

void	StorageService.registerEngine(StorageEngine<ByteArray,byte[],byte[]> engine, boolean isReadOnly, java.lang.String storeType) Register the given engine with the storage repository
void	StorageService.unregisterEngine(StorageEngine<ByteArray,byte[],byte[]> engine, boolean isReadOnly, java.lang.String storeType) Unregister and remove the engine from the storage repository

Uses of ByteArray in voldemort.store

Methods in voldemort.store that return types with arguments of type ByteArray

StorageEngine<ByteArray,byte[],byte[]>

StorageConfiguration.getStore(java.lang.String name) Get an initialized storage implementation

Methods in voldemort.store with parameters of type ByteArray

static void

StoreUtils.assertValidMetadata(ByteArray key, RoutingStrategy routingStrategy, Node currentNode) Check if the current node is part of routing request based on cluster.xml or throw an exception.

Method parameters in voldemort.store with type arguments of type ByteArray

T	StoreRequest.request(Store<ByteArray,byte[],byte[]> store) Perform the request to the given Store.

Uses of ByteArray in voldemort.store.bdb

Methods in voldemort.store.bdb that return types with arguments of type ByteArray

ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	BdbStorageEngine.entries()
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	BdbStorageEngine.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
StorageEngine<ByteArray,byte[],byte[]>	BdbStorageConfiguration.getStore(java.lang.String storeName)
ClosableIterator<ByteArray>	BdbStorageEngine.keys()

Methods in voldemort.store.bdb with parameters of type ByteArray

boolean	BdbStorageEngine.delete(ByteArray key, Version version)
java.util.List<Versioned<byte[]>>	BdbStorageEngine.get(ByteArray key, byte[] transforms)
java.util.List<Version>	BdbStorageEngine.getVersions(ByteArray key)
void	BdbStorageEngine.put(ByteArray key, Versioned<byte[]> value, byte[] transforms)

Method parameters in voldemort.store.bdb with type arguments of type ByteArray

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

Uses of ByteArray in voldemort.store.compress

Methods in voldemort.store.compress that return types with arguments of type ByteArray

java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>

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

Methods in voldemort.store.compress with parameters of type ByteArray

boolean	CompressingStore.delete(ByteArray key, Version version)
java.util.List<Versioned<byte[]>>	CompressingStore.get(ByteArray key, byte[] transforms)
java.util.List<Version>	CompressingStore.getVersions(ByteArray key)
void	CompressingStore.put(ByteArray key, Versioned<byte[]> value, byte[] transforms)

Method parameters in voldemort.store.compress with type arguments of type ByteArray

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

Constructor parameters in voldemort.store.compress with type arguments of type ByteArray

CompressingStore(Store<ByteArray,byte[],byte[]> innerStore, CompressionStrategy keysCompressionStrategy, CompressionStrategy valuesCompressionStrategy)

Uses of ByteArray in voldemort.store.http

Methods in voldemort.store.http that return types with arguments of type ByteArray

java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>

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

Methods in voldemort.store.http with parameters of type ByteArray

boolean	HttpStore.delete(ByteArray key, Version version)
java.util.List<Versioned<byte[]>>	HttpStore.get(ByteArray key, byte[] transforms)
java.util.List<Version>	HttpStore.getVersions(ByteArray key)
void	HttpStore.put(ByteArray key, Versioned<byte[]> versioned, byte[] transforms)

Method parameters in voldemort.store.http with type arguments of type ByteArray

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

Uses of ByteArray in voldemort.store.invalidmetadata

Methods in voldemort.store.invalidmetadata that return types with arguments of type ByteArray

java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>

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

Methods in voldemort.store.invalidmetadata with parameters of type ByteArray

boolean	InvalidMetadataCheckingStore.delete(ByteArray key, Version version)
java.util.List<Versioned<byte[]>>	InvalidMetadataCheckingStore.get(ByteArray key, byte[] transforms)
void	InvalidMetadataCheckingStore.put(ByteArray key, Versioned<byte[]> value, byte[] transforms)

Method parameters in voldemort.store.invalidmetadata with type arguments of type ByteArray

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

Constructor parameters in voldemort.store.invalidmetadata with type arguments of type ByteArray

InvalidMetadataCheckingStore(int nodeId, Store<ByteArray,byte[],byte[]> innerStore, MetadataStore metadata)
Create a store which delegates its operations to its inner store and throws InvalidMetadataException if the partition for key requested should not lie with this node.

Uses of ByteArray in voldemort.store.memory

Methods in voldemort.store.memory that return types with arguments of type ByteArray

StorageEngine<ByteArray,byte[],byte[]>	InMemoryStorageConfiguration.getStore(java.lang.String name)
StorageEngine<ByteArray,byte[],byte[]>	CacheStorageConfiguration.getStore(java.lang.String name)

Uses of ByteArray in voldemort.store.metadata

Methods in voldemort.store.metadata that return types with arguments of type ByteArray

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

Methods in voldemort.store.metadata with parameters of type ByteArray

boolean	MetadataStore.delete(ByteArray key, Version version)
java.util.List<Versioned<byte[]>>	MetadataStore.get(ByteArray keyBytes, byte[] transforms)
java.util.List<Version>	MetadataStore.getVersions(ByteArray key)
void	MetadataStore.put(ByteArray keyBytes, Versioned<byte[]> valueBytes, byte[] transforms) A write through put to inner-store.

Method parameters in voldemort.store.metadata with type arguments of type ByteArray

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

Uses of ByteArray in voldemort.store.mysql

Methods in voldemort.store.mysql that return types with arguments of type ByteArray

ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	MysqlStorageEngine.entries()
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	MysqlStorageEngine.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
StorageEngine<ByteArray,byte[],byte[]>	MysqlStorageConfiguration.getStore(java.lang.String name)
ClosableIterator<ByteArray>	MysqlStorageEngine.keys()

Methods in voldemort.store.mysql with parameters of type ByteArray

boolean	MysqlStorageEngine.delete(ByteArray key, Version maxVersion)
java.util.List<Versioned<byte[]>>	MysqlStorageEngine.get(ByteArray key, byte[] transforms)
java.util.List<Version>	MysqlStorageEngine.getVersions(ByteArray key)
void	MysqlStorageEngine.put(ByteArray key, Versioned<byte[]> value, byte[] transforms)

Method parameters in voldemort.store.mysql with type arguments of type ByteArray

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

Uses of ByteArray in voldemort.store.nonblockingstore

Methods in voldemort.store.nonblockingstore with parameters of type ByteArray

void	ThreadPoolBasedNonblockingStoreImpl.submitDeleteRequest(ByteArray key, Version version, NonblockingStoreCallback callback, long timeoutMs)
void	NonblockingStore.submitDeleteRequest(ByteArray key, Version version, NonblockingStoreCallback callback, long timeoutMs)
void	ThreadPoolBasedNonblockingStoreImpl.submitGetRequest(ByteArray key, byte[] transforms, NonblockingStoreCallback callback, long timeoutMs)
void	NonblockingStore.submitGetRequest(ByteArray key, byte[] transforms, NonblockingStoreCallback callback, long timeoutMs)
void	ThreadPoolBasedNonblockingStoreImpl.submitGetVersionsRequest(ByteArray key, NonblockingStoreCallback callback, long timeoutMs)
void	NonblockingStore.submitGetVersionsRequest(ByteArray key, NonblockingStoreCallback callback, long timeoutMs)
void	ThreadPoolBasedNonblockingStoreImpl.submitPutRequest(ByteArray key, Versioned<byte[]> value, byte[] transforms, NonblockingStoreCallback callback, long timeoutMs)
void	NonblockingStore.submitPutRequest(ByteArray key, Versioned<byte[]> value, byte[] transforms, NonblockingStoreCallback callback, long timeoutMs)

Method parameters in voldemort.store.nonblockingstore with type arguments of type ByteArray

void	ThreadPoolBasedNonblockingStoreImpl.submitGetAllRequest(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, NonblockingStoreCallback callback, long timeoutMs)
void	ThreadPoolBasedNonblockingStoreImpl.submitGetAllRequest(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, NonblockingStoreCallback callback, long timeoutMs)
void	NonblockingStore.submitGetAllRequest(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, NonblockingStoreCallback callback, long timeoutMs)
void	NonblockingStore.submitGetAllRequest(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, NonblockingStoreCallback callback, long timeoutMs)

Constructor parameters in voldemort.store.nonblockingstore with type arguments of type ByteArray

ThreadPoolBasedNonblockingStoreImpl(java.util.concurrent.ExecutorService executor, Store<ByteArray,byte[],byte[]> innerStore)

Uses of ByteArray in voldemort.store.readonly

Methods in voldemort.store.readonly that return types with arguments of type ByteArray

ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	ReadOnlyStorageEngine.entries()
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	ReadOnlyStorageEngine.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
StorageEngine<ByteArray,byte[],byte[]>	ReadOnlyStorageConfiguration.getStore(java.lang.String name)
ClosableIterator<ByteArray>	ReadOnlyStorageEngine.keys()

Methods in voldemort.store.readonly with parameters of type ByteArray

boolean	ReadOnlyStorageEngine.delete(ByteArray key, Version version) Not supported, throws UnsupportedOperationException if called
java.util.List<Versioned<byte[]>>	ReadOnlyStorageEngine.get(ByteArray key, byte[] transforms)
java.util.List<Version>	ReadOnlyStorageEngine.getVersions(ByteArray key)
void	ReadOnlyStorageEngine.put(ByteArray key, Versioned<byte[]> value, byte[] transforms) Not supported, throws UnsupportedOperationException if called

Method parameters in voldemort.store.readonly with type arguments of type ByteArray

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

Uses of ByteArray in voldemort.store.readonly.chunk

Methods in voldemort.store.readonly.chunk that return ByteArray

ByteArray

ChunkedFileSet.ROKeyIterator.next()

Methods in voldemort.store.readonly.chunk that return types with arguments of type ByteArray

Pair<ByteArray,Versioned<byte[]>>

ChunkedFileSet.ROEntriesIterator.next()

Uses of ByteArray in voldemort.store.rebalancing

Methods in voldemort.store.rebalancing that return types with arguments of type ByteArray

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

Methods in voldemort.store.rebalancing with parameters of type ByteArray

boolean	RedirectingStore.delete(ByteArray key, Version version) TODO : Handle delete correctly.
boolean	RebootstrappingStore.delete(ByteArray key, Version version)
java.util.List<Versioned<byte[]>>	RedirectingStore.get(ByteArray key, byte[] transforms)
java.util.List<Versioned<byte[]>>	RebootstrappingStore.get(ByteArray key, byte[] transforms)
java.util.List<Version>	RedirectingStore.getVersions(ByteArray key)
java.util.List<Version>	RebootstrappingStore.getVersions(ByteArray key)
void	RedirectingStore.put(ByteArray key, Versioned<byte[]> value, byte[] transforms)
void	RebootstrappingStore.put(ByteArray key, Versioned<byte[]> versioned, byte[] transforms)

Method parameters in voldemort.store.rebalancing with type arguments of type ByteArray

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

Constructor parameters in voldemort.store.rebalancing with type arguments of type ByteArray

RedirectingStore(Store<ByteArray,byte[],byte[]> innerStore, MetadataStore metadata, StoreRepository storeRepository, FailureDetector detector, SocketStoreFactory storeFactory)

Uses of ByteArray in voldemort.store.routed

Fields in voldemort.store.routed with type parameters of type ByteArray

protected java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>>	RoutedStore.innerStores
protected ReadRepairer<ByteArray,byte[]>	RoutedStore.readRepairer

Methods in voldemort.store.routed that return types with arguments of type ByteArray

java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	ThreadPoolRoutedStore.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	PipelineRoutedStore.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>>	RoutedStore.getInnerStores()
java.util.Map<ByteArray,java.util.List<Node>>	GetAllPipelineData.getKeyToExtraNodesMap()
java.util.Map<ByteArray,java.util.HashSet<java.lang.Integer>>	GetAllPipelineData.getKeyToZoneResponse()
java.util.Map<Node,java.util.List<ByteArray>>	GetAllPipelineData.getNodeToKeysMap()
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	GetAllPipelineData.getResult()
java.util.Map<ByteArray,byte[]>	GetAllPipelineData.getTransforms()

Methods in voldemort.store.routed with parameters of type ByteArray

boolean	ThreadPoolRoutedStore.delete(ByteArray key, Version version)
boolean	PipelineRoutedStore.delete(ByteArray key, Version version)
java.util.List<Versioned<byte[]>>	ThreadPoolRoutedStore.get(ByteArray key, byte[] transforms)
java.util.List<Versioned<byte[]>>	PipelineRoutedStore.get(ByteArray key, byte[] transforms)
org.apache.commons.lang.mutable.MutableInt	GetAllPipelineData.getSuccessCount(ByteArray key)
java.util.List<Version>	ThreadPoolRoutedStore.getVersions(ByteArray key)
java.util.List<Version>	PipelineRoutedStore.getVersions(ByteArray key)
void	ThreadPoolRoutedStore.put(ByteArray key, Versioned<byte[]> versioned, byte[] transforms)
void	PipelineRoutedStore.put(ByteArray key, Versioned<byte[]> versioned, byte[] transforms)

Method parameters in voldemort.store.routed with type arguments of type ByteArray

RoutedStore	RoutedStoreFactory.create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, boolean repairReads, FailureDetector failureDetector)
RoutedStore	RoutedStoreFactory.create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, boolean repairReads, int clientZoneId, FailureDetector failureDetector)
RoutedStore	RoutedStoreFactory.create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, boolean repairReads, int clientZoneId, FailureDetector failureDetector)
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	ThreadPoolRoutedStore.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	ThreadPoolRoutedStore.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	PipelineRoutedStore.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	PipelineRoutedStore.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
void	GetAllPipelineData.setKeyToExtraNodesMap(java.util.Map<ByteArray,java.util.List<Node>> keyToExtraNodesMap)
void	GetAllPipelineData.setNodeToKeysMap(java.util.Map<Node,java.util.List<ByteArray>> nodeToKeysMap)
void	GetAllPipelineData.setTransforms(java.util.Map<ByteArray,byte[]> transforms)
NonblockingStore	RoutedStoreFactory.toNonblockingStore(Store<ByteArray,byte[],byte[]> store)

Constructor parameters in voldemort.store.routed with type arguments of type ByteArray

PipelineRoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, Cluster cluster, StoreDefinition storeDef, boolean repairReads, int clientZoneId, long timeoutMs, FailureDetector failureDetector)
Create a PipelineRoutedStore

PipelineRoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, Cluster cluster, StoreDefinition storeDef, boolean repairReads, int clientZoneId, long timeoutMs, FailureDetector failureDetector)
Create a PipelineRoutedStore

RoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, Cluster cluster, StoreDefinition storeDef, boolean repairReads, long timeoutMs, FailureDetector failureDetector, Time time)

ThreadPoolRoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, Cluster cluster, StoreDefinition storeDef, boolean repairReads, java.util.concurrent.ExecutorService threadPool, long timeoutMs, FailureDetector failureDetector, Time time)
Create a RoutedStoreClient

ThreadPoolRoutedStore(java.lang.String name, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, Cluster cluster, StoreDefinition storeDef, int numberOfThreads, boolean repairReads, long timeoutMs, FailureDetector failureDetector)
Create a RoutedStoreClient

Uses of ByteArray in voldemort.store.routed.action

Methods in voldemort.store.routed.action with parameters of type ByteArray

protected java.util.List<Node>	AbstractConfigureNodes.getNodes(ByteArray key)
protected void	AbstractReadRepair.insertNodeValue(Node node, ByteArray key, java.util.List<Versioned<byte[]>> value)

Constructors in voldemort.store.routed.action with parameters of type ByteArray

AbstractHintedHandoffAction(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, HintedHandoff hintedHandoff)

ConfigureNodes(PD pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int required, RoutingStrategy routingStrategy, ByteArray key, Zone clientZone)

PerformDeleteHintedHandoff(BasicPipelineData<java.lang.Boolean> pipelineData, Pipeline.Event completeEvent, ByteArray key, Version version, HintedHandoff hintedHandoff)

PerformParallelDeleteRequests(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, FailureDetector failureDetector, int preferred, int required, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, HintedHandoff hintedHandoff, Version version)

PerformParallelPutRequests(PutPipelineData pipelineData, Pipeline.Event completeEvent, ByteArray key, byte[] transforms, FailureDetector failureDetector, int preferred, int required, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, HintedHandoff hintedHandoff)

PerformParallelRequests(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, byte[] transforms, FailureDetector failureDetector, int preferred, int required, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, Pipeline.Event insufficientSuccessesEvent, Pipeline.Event insufficientZonesEvent)

PerformPutHintedHandoff(PutPipelineData pipelineData, Pipeline.Event completeEvent, ByteArray key, Versioned<byte[]> versioned, byte[] transforms, HintedHandoff hintedHandoff, Time time)

PerformSerialPutRequests(PutPipelineData pipelineData, Pipeline.Event completeEvent, ByteArray key, byte[] transforms, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, int required, Versioned<byte[]> versioned, Time time, Pipeline.Event masterDeterminedEvent)

PerformSerialRequests(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, int preferred, int required, StoreRequest<V> storeRequest, Pipeline.Event insufficientSuccessesEvent)

PerformZoneSerialRequests(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, StoreRequest<V> storeRequest)

Constructor parameters in voldemort.store.routed.action with type arguments of type ByteArray

AbstractReadRepair(PD pipelineData, Pipeline.Event completeEvent, int preferred, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, ReadRepairer<ByteArray,byte[]> readRepairer)

GetAllConfigureNodes(GetAllPipelineData pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int preferred, int required, RoutingStrategy routingStrategy, java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, Zone clientZone)

GetAllConfigureNodes(GetAllPipelineData pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, int preferred, int required, RoutingStrategy routingStrategy, java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, Zone clientZone)

GetAllReadRepair(GetAllPipelineData pipelineData, Pipeline.Event completeEvent, int preferred, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, ReadRepairer<ByteArray,byte[]> readRepairer)

PerformSerialGetAllRequests(GetAllPipelineData pipelineData, Pipeline.Event completeEvent, java.lang.Iterable<ByteArray> keys, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, int preferred, int required)

PerformSerialGetAllRequests(GetAllPipelineData pipelineData, Pipeline.Event completeEvent, java.lang.Iterable<ByteArray> keys, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, int preferred, int required)

PerformSerialPutRequests(PutPipelineData pipelineData, Pipeline.Event completeEvent, ByteArray key, byte[] transforms, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, int required, Versioned<byte[]> versioned, Time time, Pipeline.Event masterDeterminedEvent)

PerformSerialRequests(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, int preferred, int required, StoreRequest<V> storeRequest, Pipeline.Event insufficientSuccessesEvent)

PerformZoneSerialRequests(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores, StoreRequest<V> storeRequest)

ReadRepair(PD pipelineData, Pipeline.Event completeEvent, int preferred, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, ReadRepairer<ByteArray,byte[]> readRepairer)

Uses of ByteArray in voldemort.store.serialized

Method parameters in voldemort.store.serialized with type arguments of type ByteArray

static <K1,V1,T1> SerializingStorageEngine<K1,V1,T1>	SerializingStorageEngine.wrap(StorageEngine<ByteArray,byte[],byte[]> s, Serializer<K1> k, Serializer<V1> v, Serializer<T1> t)
static <K1,V1,T1> SerializingStore<K1,V1,T1>	SerializingStore.wrap(Store<ByteArray,byte[],byte[]> s, Serializer<K1> k, Serializer<V1> v, Serializer<T1> t)

Constructor parameters in voldemort.store.serialized with type arguments of type ByteArray

SerializingStorageEngine(StorageEngine<ByteArray,byte[],byte[]> innerStorageEngine, Serializer<K> keySerializer, Serializer<V> valueSerializer, Serializer<T> transformsSerializer)

SerializingStore(Store<ByteArray,byte[],byte[]> store, Serializer<K> keySerializer, Serializer<V> valueSerializer, Serializer<T> transformsSerializer)

Uses of ByteArray in voldemort.store.slop

Methods in voldemort.store.slop that return ByteArray

ByteArray	Slop.getKey()
ByteArray	Slop.makeKey()

Methods in voldemort.store.slop that return types with arguments of type ByteArray

StorageEngine<ByteArray,Slop,byte[]>	SlopStorageEngine.asSlopStore()
ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	SlopStorageEngine.entries()
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	SlopStorageEngine.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
ClosableIterator<ByteArray>	SlopStorageEngine.keys()

Methods in voldemort.store.slop with parameters of type ByteArray

boolean	SlopStorageEngine.delete(ByteArray key, Version version)
java.util.List<Versioned<byte[]>>	SlopStorageEngine.get(ByteArray key, byte[] transforms)
java.util.List<Version>	SlopStorageEngine.getVersions(ByteArray key)
void	SlopStorageEngine.put(ByteArray key, Versioned<byte[]> value, byte[] transforms)

Method parameters in voldemort.store.slop with type arguments of type ByteArray

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

Constructors in voldemort.store.slop with parameters of type ByteArray

Slop(java.lang.String storeName, Slop.Operation operation, ByteArray key, byte[] value, byte[] transforms, int nodeId, java.util.Date arrived)

Constructor parameters in voldemort.store.slop with type arguments of type ByteArray

HintedHandoff(FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, HintedHandoffStrategy handoffStrategy, java.util.List<Node> failedNodes, long timeoutMs)
Create a Hinted Handoff object

SlopStorageEngine(StorageEngine<ByteArray,byte[],byte[]> slopEngine, Cluster cluster)

Uses of ByteArray in voldemort.store.socket

Methods in voldemort.store.socket that return types with arguments of type ByteArray

java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>

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

Methods in voldemort.store.socket with parameters of type ByteArray

boolean	SocketStore.delete(ByteArray key, Version version)
java.util.List<Versioned<byte[]>>	SocketStore.get(ByteArray key, byte[] transforms)
java.util.List<Version>	SocketStore.getVersions(ByteArray key)
void	SocketStore.put(ByteArray key, Versioned<byte[]> versioned, byte[] transforms)
void	SocketStore.submitDeleteRequest(ByteArray key, Version version, NonblockingStoreCallback callback, long timeoutMs)
void	SocketStore.submitGetRequest(ByteArray key, byte[] transforms, NonblockingStoreCallback callback, long timeoutMs)
void	SocketStore.submitGetVersionsRequest(ByteArray key, NonblockingStoreCallback callback, long timeoutMs)
void	SocketStore.submitPutRequest(ByteArray key, Versioned<byte[]> value, byte[] transforms, NonblockingStoreCallback callback, long timeoutMs)

Method parameters in voldemort.store.socket with type arguments of type ByteArray

java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	SocketStore.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	SocketStore.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
void	SocketStore.submitGetAllRequest(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, NonblockingStoreCallback callback, long timeoutMs)
void	SocketStore.submitGetAllRequest(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, NonblockingStoreCallback callback, long timeoutMs)

Uses of ByteArray in voldemort.store.socket.clientrequest

Methods in voldemort.store.socket.clientrequest that return types with arguments of type ByteArray

protected java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>

GetAllClientRequest.parseResponseInternal(java.io.DataInputStream inputStream)

Constructors in voldemort.store.socket.clientrequest with parameters of type ByteArray

DeleteClientRequest(java.lang.String storeName, RequestFormat requestFormat, RequestRoutingType requestRoutingType, ByteArray key, Version version)

GetClientRequest(java.lang.String storeName, RequestFormat requestFormat, RequestRoutingType requestRoutingType, ByteArray key, byte[] transforms)

GetVersionsClientRequest(java.lang.String storeName, RequestFormat requestFormat, RequestRoutingType requestRoutingType, ByteArray key)

PutClientRequest(java.lang.String storeName, RequestFormat requestFormat, RequestRoutingType requestRoutingType, ByteArray key, Versioned<byte[]> versioned, byte[] transforms)

Constructor parameters in voldemort.store.socket.clientrequest with type arguments of type ByteArray

GetAllClientRequest(java.lang.String storeName, RequestFormat requestFormat, RequestRoutingType requestRoutingType, java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)

GetAllClientRequest(java.lang.String storeName, RequestFormat requestFormat, RequestRoutingType requestRoutingType, java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)

Uses of ByteArray in voldemort.store.stats

Methods in voldemort.store.stats that return types with arguments of type ByteArray

java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>

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

Methods in voldemort.store.stats with parameters of type ByteArray

boolean	StatTrackingStore.delete(ByteArray key, Version version)
java.util.List<Versioned<byte[]>>	StatTrackingStore.get(ByteArray key, byte[] transforms)
void	StatTrackingStore.put(ByteArray key, Versioned<byte[]> value, byte[] transforms)

Method parameters in voldemort.store.stats with type arguments of type ByteArray

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

Constructor parameters in voldemort.store.stats with type arguments of type ByteArray

StatTrackingStore(Store<ByteArray,byte[],byte[]> innerStore, StoreStats parentStats)

Uses of ByteArray in voldemort.store.views

Methods in voldemort.store.views that return types with arguments of type ByteArray

ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	ViewStorageEngine.entries()
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>	ViewStorageEngine.getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms)
StorageEngine<ByteArray,byte[],byte[]>	ViewStorageConfiguration.getStore(java.lang.String name)
ClosableIterator<ByteArray>	ViewStorageEngine.keys()

Methods in voldemort.store.views with parameters of type ByteArray

boolean	ViewStorageEngine.delete(ByteArray key, Version version)
java.util.List<Versioned<byte[]>>	ViewStorageEngine.get(ByteArray key, byte[] transforms)
java.util.List<Version>	ViewStorageEngine.getVersions(ByteArray key)
void	ViewStorageEngine.put(ByteArray key, Versioned<byte[]> value, byte[] transforms)

Method parameters in voldemort.store.views with type arguments of type ByteArray

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

Constructor parameters in voldemort.store.views with type arguments of type ByteArray

ViewStorageEngine(java.lang.String name, StorageEngine<ByteArray,byte[],byte[]> target, Serializer<?> valSerializer, Serializer<?> transformSerializer, Serializer<?> targetKeySerializer, Serializer<?> targetValSerializer, CompressionStrategy valueCompressionStrategy, View<?,?,?,?> valueTrans)

Uses of ByteArray in voldemort.utils

Fields in voldemort.utils declared as ByteArray

static ByteArray

ByteArray.EMPTY

Methods in voldemort.utils that return types with arguments of type ByteArray

static java.util.List<ByteArray>

KeyDistributionGenerator.generateKeys(int numKeys)

Method parameters in voldemort.utils with type arguments of type ByteArray

static java.util.HashMap<java.lang.Integer,java.lang.Double>	KeyDistributionGenerator.generateDistribution(Cluster cluster, StoreDefinition storeDef, java.util.List<ByteArray> keys) Generates distribution for a specific store definition
static java.util.HashMap<java.lang.Integer,java.lang.Double>	KeyDistributionGenerator.generateOverallDistribution(Cluster cluster, java.util.List<StoreDefinition> storeDefs, java.util.List<ByteArray> keys)
static java.util.HashMap<java.lang.Integer,java.lang.Double>	KeyDistributionGenerator.generateOverallDistributionWithUniqueStores(Cluster cluster, java.util.HashMap<StoreDefinition,java.lang.Integer> uniqueStoreDefsWithCount, java.util.List<ByteArray> keys)
static java.lang.String	KeyDistributionGenerator.printOverallDistribution(Cluster cluster, java.util.List<StoreDefinition> storeDefs, java.util.List<ByteArray> keys) Given the cluster metadata and list of store definitions, presents a string of the distribution
static java.lang.String	KeyDistributionGenerator.printStoreWiseDistribution(Cluster cluster, java.util.List<StoreDefinition> storeDefs, java.util.List<ByteArray> keys) Given the cluster metadata and list of store definitions, presents a string of the store wise distribution