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.metadata	Our in-memory metadata store on the server which is backed by the configuration files.
voldemort.store.readonly	A storage engine that provides very efficient read-only access to large sorted files of data.
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.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.getRemoteStoreDefList(int nodeId) Retrieve the store definitions from a remote node.

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

void	AdminClient.addStore(StoreDefinition def) Add a new store definition to all active nodes in the cluster.
void	AdminClient.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.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

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

void	AdminClient.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.

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.registerNodeStores(StoreDefinition def, Cluster cluster, int localNode) For server side routing create NodeStore (socketstore) and pass it on to a RebootstrappingStore.

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

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

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()

Uses of StoreDefinition in voldemort.store.readonly

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.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)

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, 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 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.views

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.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 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.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
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.

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)