Uses of Class
voldemort.store.StoreDefinition

Packages that use StoreDefinition

voldemort.client.protocol.admin	Classes that abstract admin based Voldemort requests.
voldemort.client.rebalance	All classes associated with the rebalance controller tool.
voldemort.routing	Routing strategies for mapping requests into the Voldemort cluster.
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.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.retention
voldemort.store.routed	A store implmentation that handles routing to nodes, and repairing obsolete values detected on those nodes.
voldemort.store.slop.strategy	Bunch of different ways in which we would store failed requests for the Hinted handoff feature.
voldemort.store.system
voldemort.store.views	Classes related to Views and server side transforms
voldemort.utils	Basic helper functions.
voldemort.xml	Classes related to parsing our metadata ( cluster + store definition )

Uses of StoreDefinition in voldemort.client.protocol.admin

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

Versioned<java.util.List<StoreDefinition>>

AdminClient.MetadataManagementOperations.getRemoteStoreDefList(int nodeId) Retrieve the store definitions from a remote node.

Methods in voldemort.client.protocol.admin with parameters of type StoreDefinition

void	AdminClient.StoreManagementOperations.addStore(StoreDefinition def) Add a new store definition to all active nodes in the cluster.
void	AdminClient.StoreManagementOperations.addStore(StoreDefinition def, int nodeId) Add a new store definition to a particular node
java.util.Map<java.lang.Integer,java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>>>	AdminClient.HelperOperations.getReplicationMapping(int restoringNode, Cluster cluster, StoreDefinition storeDef) For a particular node, finds out all the [replica, partition] tuples it needs to steal in order to be brought back to normal state
java.util.Map<java.lang.Integer,java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>>>	AdminClient.HelperOperations.getReplicationMapping(int restoringNode, Cluster cluster, StoreDefinition storeDef, int zoneId) For a particular node, finds out all the [replica, partition] tuples it needs to steal in order to be brought back to normal state

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

void	AdminClient.MetadataManagementOperations.updateRemoteStoreDefList(int nodeId, java.util.List<StoreDefinition> storesList) Update the store definitions on a remote node.

Uses of StoreDefinition in voldemort.client.rebalance

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

java.util.List<StoreDefinition>

OrderedClusterTransition.getStoreDefs()

Method parameters in voldemort.client.rebalance with type arguments of type StoreDefinition

void	RebalanceController.rebalance(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs) Does basic verification of the metadata + server state.

Constructor parameters in voldemort.client.rebalance with type arguments of type StoreDefinition

OrderedClusterTransition(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs, RebalanceClusterPlan rebalanceClusterPlan)

RebalanceClusterPlan(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs, boolean enabledDeletePartition)
Compares the currentCluster configuration with the desired targetConfiguration and builds a map of Target node-id to map of source node-ids and partitions desired to be stolen/fetched.

RebalanceClusterPlan(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs, boolean enabledDeletePartition, boolean isStealerBased)
Compares the currentCluster configuration with the desired targetConfiguration and builds a map of Target node-id to map of source node-ids and partitions desired to be stolen/fetched.

Uses of StoreDefinition in voldemort.routing

Methods in voldemort.routing with parameters of type StoreDefinition

RoutingStrategy

RoutingStrategyFactory.updateRoutingStrategy(StoreDefinition storeDef, Cluster cluster)

Uses of StoreDefinition in voldemort.server.protocol.admin

Fields in voldemort.server.protocol.admin declared as StoreDefinition

protected StoreDefinition

FetchStreamRequestHandler.storeDef

Uses of StoreDefinition in voldemort.server.storage

Methods in voldemort.server.storage with parameters of type StoreDefinition

void	StorageService.openStore(StoreDefinition storeDef)
void	StorageService.openSystemStore(StoreDefinition storeDef)
void	StorageService.registerEngine(StorageEngine<ByteArray,byte[],byte[]> engine, boolean isReadOnly, java.lang.String storeType, StoreDefinition storeDef) Register the given engine with the storage repository
void	StorageService.registerNodeStores(StoreDefinition def, Cluster cluster, int localNode) For server side routing create NodeStore (socketstore) and pass it on to a RebootstrappingStore.
void	StorageService.updateStore(StoreDefinition storeDef)

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

protected void

StorageService.initializeMetadataVersions(java.util.List<StoreDefinition> storeDefs)

Uses of StoreDefinition in voldemort.store

Methods in voldemort.store that return StoreDefinition

StoreDefinition	StoreDefinitionBuilder.build()
static StoreDefinition	StoreUtils.getStoreDef(java.util.List<StoreDefinition> list, java.lang.String name) Get a store definition from the given list of store definitions

Methods in voldemort.store with parameters of type StoreDefinition

StorageEngine<ByteArray,byte[],byte[]>	StorageConfiguration.getStore(StoreDefinition storeDef, RoutingStrategy strategy) Get an initialized storage implementation
void	StorageConfiguration.update(StoreDefinition storeDef) Update the storage configuration at runtime

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

static StoreDefinition	StoreUtils.getStoreDef(java.util.List<StoreDefinition> list, java.lang.String name) Get a store definition from the given list of store definitions
static java.util.List<java.lang.String>	StoreUtils.getStoreNames(java.util.List<StoreDefinition> list, boolean ignoreViews) Get the list of store names from a list of store definitions

Uses of StoreDefinition in voldemort.store.bdb

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

com.sleepycat.je.Environment	BdbStorageConfiguration.getEnvironment(StoreDefinition storeDef)
StorageEngine<ByteArray,byte[],byte[]>	BdbStorageConfiguration.getStore(StoreDefinition storeDef, RoutingStrategy strategy)
void	BdbStorageConfiguration.update(StoreDefinition storeDef) Detect what has changed in the store definition and rewire BDB environments accordingly.

Uses of StoreDefinition in voldemort.store.configuration

Methods in voldemort.store.configuration with parameters of type StoreDefinition

StorageEngine<ByteArray,byte[],byte[]>	FileBackedCachingStorageConfiguration.getStore(StoreDefinition storeDef, RoutingStrategy strategy)
void	FileBackedCachingStorageConfiguration.update(StoreDefinition storeDef)

Uses of StoreDefinition in voldemort.store.memory

Methods in voldemort.store.memory with parameters of type StoreDefinition

StorageEngine<ByteArray,byte[],byte[]>	InMemoryStorageConfiguration.getStore(StoreDefinition storeDef, RoutingStrategy strategy)
StorageEngine<ByteArray,byte[],byte[]>	CacheStorageConfiguration.getStore(StoreDefinition storeDef, RoutingStrategy strategy)
void	InMemoryStorageConfiguration.update(StoreDefinition storeDef)
void	CacheStorageConfiguration.update(StoreDefinition storeDef)

Uses of StoreDefinition in voldemort.store.metadata

Methods in voldemort.store.metadata that return StoreDefinition

StoreDefinition

MetadataStore.getStoreDef(java.lang.String storeName)

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

java.util.List<StoreDefinition>	MetadataStore.getStoreDefList()
java.util.List<StoreDefinition>	MetadataStore.getSystemStoreDefList()

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

void	MetadataStoreListener.updateStoreDefinition(StoreDefinition storeDef)

Uses of StoreDefinition in voldemort.store.mysql

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

StorageEngine<ByteArray,byte[],byte[]>	MysqlStorageConfiguration.getStore(StoreDefinition storeDef, RoutingStrategy strategy)
void	MysqlStorageConfiguration.update(StoreDefinition storeDef)

Uses of StoreDefinition in voldemort.store.readonly

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

StorageEngine<ByteArray,byte[],byte[]>	ReadOnlyStorageConfiguration.getStore(StoreDefinition storeDef, RoutingStrategy strategy)
void	ReadOnlyStorageConfiguration.update(StoreDefinition storeDef)

Constructors in voldemort.store.readonly with parameters of type StoreDefinition

JsonStoreBuilder(JsonReader reader, Cluster cluster, StoreDefinition storeDefinition, RoutingStrategy routingStrategy, java.io.File outputDir, java.io.File tempDir, int internalSortSize, int numThreads, int numChunks, int ioBufferSize, boolean gzipIntermediate)

Uses of StoreDefinition in voldemort.store.retention

Methods in voldemort.store.retention with parameters of type StoreDefinition

void	RetentionEnforcingStore.updateStoreDefinition(StoreDefinition storeDef) Updates the store definition object and the retention time based on the updated store definition

Constructors in voldemort.store.retention with parameters of type StoreDefinition

RetentionEnforcingStore(Store<ByteArray,byte[],byte[]> innerStore, StoreDefinition storeDef, boolean deleteExpiredEntries, Time time)

Uses of StoreDefinition in voldemort.store.routed

Fields in voldemort.store.routed declared as StoreDefinition

protected StoreDefinition

RoutedStore.storeDef

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

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, boolean jmxEnabled, int jmxId)

Constructors in voldemort.store.routed with parameters of type StoreDefinition

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, TimeoutConfig timeoutConfig, FailureDetector failureDetector, boolean jmxEnabled, int jmxId)
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, TimeoutConfig timeoutConfig, 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, TimeoutConfig timeoutConfig, 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, TimeoutConfig timeoutConfig, FailureDetector failureDetector)
Create a RoutedStoreClient

Uses of StoreDefinition in voldemort.store.slop.strategy

Methods in voldemort.store.slop.strategy with parameters of type StoreDefinition

HintedHandoffStrategy

HintedHandoffStrategyFactory.updateHintedHandoffStrategy(StoreDefinition storeDef, Cluster cluster)

Uses of StoreDefinition in voldemort.store.system

Methods in voldemort.store.system that return StoreDefinition

static StoreDefinition

SystemStoreConstants.getSystemStoreDef(java.lang.String name)

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

static java.util.List<StoreDefinition>

SystemStoreConstants.getAllSystemStoreDefs()

Uses of StoreDefinition in voldemort.store.views

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

StorageEngine<ByteArray,byte[],byte[]>	ViewStorageConfiguration.getStore(StoreDefinition storeDef, RoutingStrategy strategy)
void	ViewStorageConfiguration.update(StoreDefinition storeDef)

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

ViewStorageConfiguration(VoldemortConfig config, java.util.List<StoreDefinition> stores, StoreRepository repo)

Uses of StoreDefinition in voldemort.utils

Methods in voldemort.utils that return StoreDefinition

static StoreDefinition

RebalanceUtils.getStoreDefinitionWithName(java.util.List<StoreDefinition> storeDefs, java.lang.String storeName) Given a store name and a list of store definitions, returns the appropriate store definition ( if it exists )

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

static java.util.List<StoreDefinition>	RebalanceUtils.filterStores(java.util.List<StoreDefinition> storeDefs, boolean isReadOnly) Given a list of store definitions, filters the list depending on the boolean
static java.util.List<StoreDefinition>	RebalanceUtils.getStoreDefinition(Cluster cluster, AdminClient adminClient) Given the cluster metadata and admin client, retrieves the list of store definitions.
static java.util.HashMap<StoreDefinition,java.lang.Integer>	KeyDistributionGenerator.getUniqueStoreDefinitionsWithCounts(java.util.List<StoreDefinition> storeDefs) Given a list of store definitions, find out and return a map of similar store definitions + count of them
static java.util.List<StoreDefinition>	RebalanceUtils.validateRebalanceStore(java.util.List<StoreDefinition> storeDefList) Given a list of store definitions, makes sure that rebalance supports all of them.

Methods in voldemort.utils with parameters of type StoreDefinition

static boolean	RebalanceUtils.checkKeyBelongsToNode(byte[] key, int nodeId, Cluster cluster, StoreDefinition storeDef)
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 boolean	RebalanceUtils.checkKeyBelongsToPartition(int nodeId, byte[] key, java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> replicaToPartitionList, Cluster cluster, StoreDefinition storeDef) Check that the key belongs to one of the partitions in the map of replica type to partitions
static boolean	RebalanceUtils.checkPartitionBelongsToNode(int partition, int nodeId, Cluster cluster, StoreDefinition storeDef) Checks if a given partition is stored in the node.
static boolean	RebalanceUtils.checkPartitionBelongsToNode(int partition, int replicaType, int nodeId, Cluster cluster, StoreDefinition storeDef)
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.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.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>>	RebalanceUtils.getOptimizedReplicaToPartitionList(int stealerNodeId, Cluster cluster, StoreDefinition storeDef, java.util.HashMap<java.lang.Integer,java.util.List<java.lang.Integer>> currentReplicaToPartitionList) Given the current replica to partition list, try to check if the donor node would already contain that partition and if yes, ignore it
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 StoreDefinition

static java.util.List<RebalancePartitionsInfo>	RebalanceUtils.filterPartitionPlanWithStores(java.util.List<RebalancePartitionsInfo> existingPlanList, java.util.List<StoreDefinition> storeDefs) Given a list of partition plans and a set of stores, copies the store names to every individual plan and creates a new list
static java.util.List<StoreDefinition>	RebalanceUtils.filterStores(java.util.List<StoreDefinition> storeDefs, boolean isReadOnly) Given a list of store definitions, filters the list depending on the boolean
void	Entropy.generateEntropy(Cluster cluster, java.util.List<StoreDefinition> storeDefs, java.io.File storeDir, boolean opType) Run the actual entropy calculation tool
void	Entropy.generateEntropy(Cluster cluster, java.util.List<StoreDefinition> storeDefs, java.io.File storeDir, boolean opType, boolean negativeTest) Run the actual entropy calculation tool
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
static void	RebalanceUtils.generateMinCluster(Cluster currentCluster, Cluster targetCluster, java.util.List<StoreDefinition> storeDefs, java.lang.String outputDir, int tries) Outputs an optimized cluster based on the existing cluster and the new nodes that are being added.
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 StoreDefinition	RebalanceUtils.getStoreDefinitionWithName(java.util.List<StoreDefinition> storeDefs, java.lang.String storeName) Given a store name and a list of store definitions, returns the appropriate store definition ( if it exists )
static java.util.List<java.lang.String>	RebalanceUtils.getStoreNames(java.util.List<StoreDefinition> storeDefList) Given a list of store definitions return a list of store names
static java.util.HashMap<StoreDefinition,java.lang.Integer>	KeyDistributionGenerator.getUniqueStoreDefinitionsWithCounts(java.util.List<StoreDefinition> storeDefs) Given a list of store definitions, find out and return a map of similar store definitions + count of them
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
static void	RebalanceUtils.validateReadOnlyStores(Cluster cluster, java.util.List<StoreDefinition> storeDefs, AdminClient adminClient) Given a list of store definitions, cluster and admin client returns a boolean indicating if all RO stores are in the correct format.
static java.util.List<StoreDefinition>	RebalanceUtils.validateRebalanceStore(java.util.List<StoreDefinition> storeDefList) Given a list of store definitions, makes sure that rebalance supports all of them.

Constructors in voldemort.utils with parameters of type StoreDefinition

KeyLocationValidation(Cluster cluster, int nodeId, StoreDefinition storeDef, ByteArray keyList)

Uses of StoreDefinition in voldemort.xml

Methods in voldemort.xml that return StoreDefinition

StoreDefinition

StoreDefinitionsMapper.readStore(java.io.Reader input)

Methods in voldemort.xml that return types with arguments of type StoreDefinition

java.util.List<StoreDefinition>	StoreDefinitionsMapper.readStoreList(java.io.File f)
java.util.List<StoreDefinition>	StoreDefinitionsMapper.readStoreList(java.io.Reader input)
java.util.List<StoreDefinition>	StoreDefinitionsMapper.readStoreList(java.io.Reader input, boolean verifySchema)

Methods in voldemort.xml with parameters of type StoreDefinition

java.lang.String

StoreDefinitionsMapper.writeStore(StoreDefinition store)

Method parameters in voldemort.xml with type arguments of type StoreDefinition

java.lang.String

StoreDefinitionsMapper.writeStoreList(java.util.List<StoreDefinition> stores)