|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use VoldemortFilter | |
---|---|
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.server.protocol.admin | Server side implementation of admin based requests |
Uses of VoldemortFilter in voldemort.client.protocol.admin |
---|
Methods in voldemort.client.protocol.admin with parameters of type VoldemortFilter | |
---|---|
long |
AdminClient.StoreMaintenanceOperations.deletePartitions(int nodeId,
java.lang.String storeName,
java.util.List<java.lang.Integer> partitionIds,
Cluster initialCluster,
VoldemortFilter filter)
Delete all entries belonging to all the partitions passed as a map of replica_type to partition list. |
long |
AdminClient.StoreMaintenanceOperations.deletePartitions(int nodeId,
java.lang.String storeName,
java.util.List<java.lang.Integer> partitionList,
VoldemortFilter filter)
Delete all entries belonging to a list of partitions |
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<ByteArray> |
AdminClient.BulkStreamingFetchOperations.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.BulkStreamingFetchOperations.fetchKeys(int nodeId,
java.lang.String storeName,
java.util.List<java.lang.Integer> partitionIds,
VoldemortFilter filter,
boolean fetchMasterEntries,
Cluster initialCluster,
long recordsPerPartition)
Fetch all keys belonging to the list of partition ids. |
java.util.Iterator<ByteArray> |
AdminClient.BulkStreamingFetchOperations.fetchKeys(int nodeId,
java.lang.String storeName,
java.util.List<java.lang.Integer> partitionIds,
VoldemortFilter filter,
boolean fetchMasterEntries,
long recordsPerPartition)
Legacy interface for fetching entries. |
int |
AdminClient.StoreMaintenanceOperations.migratePartitions(int donorNodeId,
int stealerNodeId,
java.lang.String storeName,
java.util.List<java.lang.Integer> stealPartitionList,
VoldemortFilter filter)
Migrate keys/values belonging to stealPartitionList ( can be primary or replica ) from donor node to stealer node. |
int |
AdminClient.StoreMaintenanceOperations.migratePartitions(int donorNodeId,
int stealerNodeId,
java.lang.String storeName,
java.util.List<java.lang.Integer> partitionIds,
VoldemortFilter filter,
Cluster initialCluster)
Migrate keys/values belonging to a list of partition ids from donor node to stealer node. |
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 VoldemortFilter in voldemort.client.protocol.admin.filter |
---|
Classes in voldemort.client.protocol.admin.filter that implement VoldemortFilter | |
---|---|
class |
DefaultVoldemortFilter
|
Uses of VoldemortFilter in voldemort.server.protocol.admin |
---|
Fields in voldemort.server.protocol.admin declared as VoldemortFilter | |
---|---|
protected VoldemortFilter |
FetchStreamRequestHandler.filter
|
protected VoldemortFilter |
UpdatePartitionEntriesStreamRequestHandler.filter
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |