Uses of Class
voldemort.utils.Pair

Packages that use Pair

voldemort.client.protocol.admin	Classes that abstract admin based Voldemort requests.
voldemort.server	The Voldemort server.
voldemort.server.protocol.admin	Server side implementation of admin based requests
voldemort.server.rebalance.async
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.configuration	A storage engine to persist metadata on a server.
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.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.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.views	Classes related to Views and server side transforms
voldemort.utils	Basic helper functions.

Uses of Pair in voldemort.client.protocol.admin

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

java.util.Iterator<Pair<ByteArray,Versioned<byte[]>>>	AdminClient.BulkStreamingFetchOperations.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.BulkStreamingFetchOperations.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.BulkStreamingFetchOperations.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<Pair<ByteArray,Versioned<byte[]>>>	AdminClient.BulkStreamingFetchOperations.fetchOrphanedEntries(int nodeId, java.lang.String storeName) Fetches entries that don't belong to the node, based on current metadata and yet persisted on the node
java.util.Iterator<Pair<ByteArray,Pair<java.util.List<Versioned<byte[]>>,java.lang.Exception>>>	AdminClient.StreamingStoreOperations.queryKeys(int nodeId, java.lang.String storeName, java.util.Iterator<ByteArray> keys) Fetch key/value tuples belonging to a node with given key values
java.util.Iterator<Pair<ByteArray,Pair<java.util.List<Versioned<byte[]>>,java.lang.Exception>>>	AdminClient.StreamingStoreOperations.queryKeys(int nodeId, java.lang.String storeName, java.util.Iterator<ByteArray> keys) Fetch key/value tuples belonging to a node with given key values

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

void	AdminClient.StreamingStoreOperations.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 Pair in voldemort.server

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

java.util.List<Pair<java.lang.Integer,Store<ByteArray,byte[],byte[]>>>

StoreRepository.getAllNodeStores()

Uses of Pair in voldemort.server.protocol.admin

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

protected ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>

FetchPartitionEntriesStreamRequestHandler.entriesPartitionIterator

Uses of Pair in voldemort.server.rebalance.async

Fields in voldemort.server.rebalance.async declared as Pair

static Pair<ByteArray,Versioned<byte[]>>	DonorBasedRebalanceAsyncOperation.BREAK
static Pair<ByteArray,Versioned<byte[]>>	DonorBasedRebalanceAsyncOperation.END

Constructor parameters in voldemort.server.rebalance.async with type arguments of type Pair

DonorBasedRebalancePusherSlave(int nodeId, java.util.concurrent.BlockingQueue<Pair<ByteArray,Versioned<byte[]>>> queue, java.lang.String storeName, AdminClient adminClient)

Uses of Pair in voldemort.store

Methods in voldemort.store that return Pair

Pair<ByteArray,Versioned<byte[]>>

PartitionListIterator.next()

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

ClosableIterator<Pair<K,Versioned<V>>>	StorageEngine.entries() Get an iterator over pairs of entries in the store.
ClosableIterator<Pair<K,Versioned<V>>>	StorageEngine.entries(int partition) Get an iterator over pairs of entries in a store's partition.

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

static <K,V> ClosableIterator<K>

StoreUtils.keys(ClosableIterator<Pair<K,V>> values)

Uses of Pair in voldemort.store.bdb

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

ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	BdbStorageEngine.entries()
ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	PartitionPrefixedBdbStorageEngine.entries(int partition)
ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	BdbStorageEngine.entries(int partition)

Uses of Pair in voldemort.store.configuration

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

ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	FileBackedCachingStorageEngine.entries()
ClosableIterator<Pair<java.lang.String,Versioned<java.lang.String>>>	ConfigurationStorageEngine.entries()
ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	FileBackedCachingStorageEngine.entries(int partition)
ClosableIterator<Pair<java.lang.String,Versioned<java.lang.String>>>	ConfigurationStorageEngine.entries(int partition)

Uses of Pair in voldemort.store.memory

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

ClosableIterator<Pair<K,Versioned<V>>>	InMemoryStorageEngine.entries()
ClosableIterator<Pair<K,Versioned<V>>>	InMemoryStorageEngine.entries(int partition)

Uses of Pair in voldemort.store.metadata

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

ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	MetadataStore.entries()
ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	MetadataStore.entries(int partition)

Uses of Pair in voldemort.store.mysql

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

ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	MysqlStorageEngine.entries()
ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	MysqlStorageEngine.entries(int partition)

Uses of Pair in voldemort.store.readonly

Methods in voldemort.store.readonly that return Pair

static Pair<java.lang.Integer,java.lang.Integer>

ReadOnlyUtils.getPartitionReplicaTuple(java.lang.String fileName) Given a file name first checks whether it belongs to storage format v2 and then retieves the tuple of out of it.

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

ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	ReadOnlyStorageEngine.entries()
ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	ReadOnlyStorageEngine.entries(int partition)

Uses of Pair in voldemort.store.readonly.chunk

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

Pair<ByteArray,Versioned<byte[]>>	ChunkedFileSet.ROEntriesIterator.next()
Pair<java.nio.ByteBuffer,java.nio.ByteBuffer>	ChunkedFileSet.ROCollidedEntriesIterator.next()

Uses of Pair in voldemort.store.serialized

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

ClosableIterator<Pair<K,Versioned<V>>>	SerializingStorageEngine.entries()
ClosableIterator<Pair<K,Versioned<V>>>	SerializingStorageEngine.entries(int partition)

Uses of Pair in voldemort.store.slop

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

ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	SlopStorageEngine.entries()
ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	SlopStorageEngine.entries(int partition)

Uses of Pair in voldemort.store.views

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

ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	ViewStorageEngine.entries()
ClosableIterator<Pair<ByteArray,Versioned<byte[]>>>	ViewStorageEngine.entries(int partition)

Uses of Pair in voldemort.utils

Methods in voldemort.utils that return Pair

static <F,S> Pair<F,S>	Pair.create(F first, S second) Static factory method that, unlike the constructor, performs generic inference saving some typing.
static Pair<Cluster,java.lang.Integer>	RebalanceUtils.generateMinCluster(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs) Takes the current cluster metadata and target cluster metadata ( which contains all the nodes of current cluster + new nodes with empty partitions ), and generates a new cluster with some partitions moved to the new node

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

static java.util.Set<Pair<java.lang.Integer,java.lang.Integer>>	RebalanceUtils.flattenPartitionTuples(java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList) Given a map of replica_type to partition mapping gives back a set of tuples of [replica_type, partition]
static java.util.Map<java.lang.Integer,java.util.Set<Pair<java.lang.Integer,java.lang.Integer>>>	RebalanceUtils.getNodeIdToAllPartitions(Cluster cluster, StoreDefinition storeDef, boolean includePrimary) For a particular cluster creates a mapping of node id to their corresponding list of [ replicaType, partition ] tuple
static java.util.Map<java.lang.Integer,java.util.Set<Pair<java.lang.Integer,java.lang.Integer>>>	RebalanceUtils.getStolenPartitionTuples(Cluster currentCluster, Cluster targetCluster, StoreDefinition storeDef) Find all [replica_type, partition] tuples to be stolen

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

static java.util.List<java.lang.Integer>	RebalanceUtils.checkKeyBelongsToPartition(byte[] key, java.util.Set<Pair<java.lang.Integer,java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>>>> stealerNodeToMappingTuples, Cluster cluster, StoreDefinition storeDef) Given a key and a list of steal infos give back a list of stealer node ids which will steal this.
static void	RebalanceUtils.combinePartitionTuples(java.util.Map<java.lang.Integer,java.util.Set<Pair<java.lang.Integer,java.lang.Integer>>> existingPartitionTuples, java.util.Map<java.lang.Integer,java.util.Set<Pair<java.lang.Integer,java.lang.Integer>>> newPartitionTuples) Given a mapping of existing node ids to their partition tuples and another new set of node ids to partition tuples, combines them together and puts it into the existing partition tuples
static void	RebalanceUtils.combinePartitionTuples(java.util.Map<java.lang.Integer,java.util.Set<Pair<java.lang.Integer,java.lang.Integer>>> existingPartitionTuples, java.util.Map<java.lang.Integer,java.util.Set<Pair<java.lang.Integer,java.lang.Integer>>> newPartitionTuples) Given a mapping of existing node ids to their partition tuples and another new set of node ids to partition tuples, combines them together and puts it into the existing partition tuples
static java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>>	RebalanceUtils.flattenPartitionTuples(java.util.Set<Pair<java.lang.Integer,java.lang.Integer>> partitionTuples) Given a list of tuples of [replica_type, partition], flattens it and generates a map of replica_type to partition mapping
static java.util.List<java.lang.Integer>	RebalanceUtils.getPartitionsFromTuples(java.util.Set<Pair<java.lang.Integer,java.lang.Integer>> tuples) Given a set of [ replica, partition ] tuples, flatten it to retrieve only the partitions
static java.lang.String	RebalanceUtils.printMap(java.util.Map<java.lang.Integer,java.util.Set<Pair<java.lang.Integer,java.lang.Integer>>> nodeIdToAllPartitions) Returns a string representation of the cluster