|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Pair | |
---|---|
voldemort.client.protocol.admin | Classes that abstract admin based Voldemort requests. |
voldemort.routing | Routing strategies for mapping requests into the Voldemort cluster. |
voldemort.server | The Voldemort server. |
voldemort.server.protocol.admin | Server side implementation of admin based requests |
voldemort.server.scheduler.slop | The background jobs associated with the slop store. |
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.tools | Tools used for administrating a cluster. |
voldemort.utils | Basic helper functions. |
Uses of Pair in voldemort.client.protocol.admin |
---|
Fields in voldemort.client.protocol.admin with type parameters of type Pair | |
---|---|
protected java.util.HashMap<Pair<java.lang.String,java.lang.Integer>,java.lang.Boolean> |
BaseStreamingClient.nodeIdStoreInitialized
|
protected java.util.HashMap<Pair<java.lang.String,java.lang.Integer>,java.io.DataOutputStream> |
BaseStreamingClient.nodeIdStoreToOutputStreamRequest
|
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.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> partitionIds,
VoldemortFilter filter,
boolean fetchMasterEntries,
Cluster initialCluster,
long recordsPerPartition)
Fetch key/value tuples belonging to this list of partition ids |
java.util.Iterator<Pair<ByteArray,Versioned<byte[]>>> |
AdminClient.BulkStreamingFetchOperations.fetchEntries(int nodeId,
java.lang.String storeName,
java.util.List<java.lang.Integer> partitionIds,
VoldemortFilter filter,
boolean fetchMasterEntries,
long recordsPerPartition)
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 |
Method parameters in voldemort.client.protocol.admin with type arguments of type Pair | |
---|---|
void |
AdminClient.StreamingOperations.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. |
void |
AdminClient.StreamingOperations.updateEntriesTimeBased(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 in the same way as AdminClient.StreamingOperations.updateEntries(int, String, Iterator, VoldemortFilter)
The only difference being the resolving on the server will happen
based on timestamp and not the vector clock. |
Uses of Pair in voldemort.routing |
---|
Method parameters in voldemort.routing with type arguments of type Pair | |
---|---|
static java.util.List<java.lang.Integer> |
StoreRoutingPlan.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. |
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[]>>> |
PartitionScanFetchEntriesRequestHandler.entriesPartitionIterator
|
Uses of Pair in voldemort.server.scheduler.slop |
---|
Methods in voldemort.server.scheduler.slop with parameters of type Pair | |
---|---|
protected void |
SlopPusherJob.handleDeadSlop(SlopStorageEngine slopStorageEngine,
Pair<ByteArray,Versioned<Slop>> keyAndVal)
Handle slop for nodes that are no longer part of the cluster. |
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>>> |
AbstractStorageEngine.entries()
|
ClosableIterator<Pair<K,Versioned<V>>> |
StorageEngine.entries(int partition)
Get an iterator over pairs of entries in a store's partition. |
ClosableIterator<Pair<K,Versioned<V>>> |
AbstractStorageEngine.entries(int partitionId)
|
Method parameters in voldemort.store with type arguments of type Pair | ||
---|---|---|
static
|
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<java.lang.String,Versioned<java.lang.String>>> |
ConfigurationStorageEngine.entries()
|
ClosableIterator<Pair<ByteArray,Versioned<byte[]>>> |
FileBackedCachingStorageEngine.entries()
|
ClosableIterator<Pair<java.lang.String,Versioned<java.lang.String>>> |
ConfigurationStorageEngine.entries(int partition)
|
ClosableIterator<Pair<ByteArray,Versioned<byte[]>>> |
FileBackedCachingStorageEngine.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 |
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.tools |
---|
Methods in voldemort.tools that return Pair | |
---|---|
static Pair<java.util.HashMap<Node,java.lang.Integer>,java.util.HashMap<Node,java.lang.Integer>> |
Repartitioner.getDonorsAndStealersForBalance(Cluster nextCandidateCluster,
java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> numPartitionsPerNodePerZone)
Assign target number of partitions per node to specific node IDs. |
static Pair<ByteArray,Versioned<byte[]>> |
ImportTextDumpToBDB.lineToEntry(java.lang.String line)
|
Methods in voldemort.tools with parameters of type Pair | |
---|---|
static java.lang.String |
ExportBDBToTextDump.makeLine(Pair<ByteArray,Versioned<byte[]>> pair)
|
Uses of Pair in voldemort.utils |
---|
Methods in voldemort.utils that return Pair | ||
---|---|---|
static
|
Pair.create(F first,
S second)
Static factory method that, unlike the constructor, performs generic inference saving some typing. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |