Uses of Class
voldemort.client.protocol.admin.AdminClient

Packages that use AdminClient
voldemort The root package. 
voldemort.client.protocol.admin Classes that abstract admin based Voldemort requests. 
voldemort.client.rebalance All classes associated with the rebalance controller tool. 
voldemort.client.rebalance.task Classes that encapsulate a specific rebalance task (between a stealer-node and donor-node). 
voldemort.server.gossip Classes associated with the Gossip feature. 
voldemort.server.rebalance.async   
voldemort.store.readonly.swapper Classes used for fetching and swapping read-only stores. 
voldemort.tools Tools used for administrating a cluster. 
voldemort.tools.admin   
voldemort.tools.admin.command   
voldemort.utils Basic helper functions. 
 

Uses of AdminClient in voldemort
 

Methods in voldemort with parameters of type AdminClient
static void VoldemortAdminTool.executeGetMetadata(java.lang.Integer nodeId, AdminClient adminClient, java.lang.String metadataKey, java.lang.String outputDir)
           
static void VoldemortAdminTool.executeSetMetadata(java.lang.Integer nodeId, AdminClient adminClient, java.lang.String key, java.lang.Object value)
           
static void VoldemortAdminTool.executeSetMetadataPair(java.lang.Integer nodeId, AdminClient adminClient, java.lang.String clusterKey, java.lang.Object clusterValue, java.lang.String storesKey, java.lang.Object storesValue)
           
 

Uses of AdminClient in voldemort.client.protocol.admin
 

Fields in voldemort.client.protocol.admin declared as AdminClient
protected  AdminClient BaseStreamingClient.adminClient
           
 

Methods in voldemort.client.protocol.admin that return AdminClient
static AdminClient AdminClient.createTempAdminClient(VoldemortConfig voldemortConfig, Cluster cluster, int numConnPerNode)
          Helper method to construct an AdminClient with "good" default settings based upon a VoldemortConfig.
 AdminClient BaseStreamingClient.getAdminClient()
           
 

Uses of AdminClient in voldemort.client.rebalance
 

Methods in voldemort.client.rebalance that return AdminClient
 AdminClient RebalanceController.getAdminClient()
           
 

Uses of AdminClient in voldemort.client.rebalance.task
 

Fields in voldemort.client.rebalance.task declared as AdminClient
protected  AdminClient RebalanceTask.adminClient
           
 

Constructors in voldemort.client.rebalance.task with parameters of type AdminClient
RebalanceTask(int batchId, int taskId, java.util.List<RebalanceTaskInfo> stealInfos, java.util.concurrent.Semaphore donorPermit, AdminClient adminClient, RebalanceBatchPlanProgressBar progressBar, org.apache.log4j.Logger logger)
           
StealerBasedRebalanceTask(int batchId, int taskId, RebalanceTaskInfo stealInfo, java.util.concurrent.Semaphore donorPermit, AdminClient adminClient, RebalanceBatchPlanProgressBar progressBar, RebalanceScheduler scheduler)
           
 

Uses of AdminClient in voldemort.server.gossip
 

Constructors in voldemort.server.gossip with parameters of type AdminClient
Gossiper(MetadataStore metadataStore, AdminClient adminClient, int gossipInterval)
          Create a Gossiper object, which implements Runnable allowing it to be run as a thread or be submitted to an Executor.
 

Uses of AdminClient in voldemort.server.rebalance.async
 

Fields in voldemort.server.rebalance.async declared as AdminClient
protected  AdminClient RebalanceAsyncOperation.adminClient
           
 

Uses of AdminClient in voldemort.store.readonly.swapper
 

Constructors in voldemort.store.readonly.swapper with parameters of type AdminClient
AdminStoreSwapper(Cluster cluster, java.util.concurrent.ExecutorService executor, AdminClient adminClient, long timeoutMs)
           
AdminStoreSwapper(Cluster cluster, java.util.concurrent.ExecutorService executor, AdminClient adminClient, long timeoutMs, boolean deleteFailedFetch, boolean rollbackFailedSwap)
           
 

Uses of AdminClient in voldemort.tools
 

Fields in voldemort.tools declared as AdminClient
protected  AdminClient ZoneShrinkageCLI.adminClient
           
 

Methods in voldemort.tools with parameters of type AdminClient
protected static boolean ZoneShrinkageCLI.verifyMetadataConsistency(AdminClient adminClient, java.util.Collection<Node> nodes, java.lang.String clusterXml, java.lang.String storesXml)
           
protected static boolean ZoneShrinkageCLI.verifyRebalanceState(AdminClient adminClient, java.util.Collection<Node> nodes)
           
 

Uses of AdminClient in voldemort.tools.admin
 

Methods in voldemort.tools.admin that return AdminClient
static AdminClient AdminToolUtils.getAdminClient(java.lang.String url)
          Utility function that constructs AdminClient.
 

Methods in voldemort.tools.admin with parameters of type AdminClient
static void AdminToolUtils.assertServerInNormalState(AdminClient adminClient)
          Utility function that checks the execution state of the server by checking the state of MetadataStore.VoldemortState
This function checks if all nodes of the cluster are in normal state ( MetadataStore.VoldemortState.NORMAL_SERVER).
static void AdminToolUtils.assertServerInNormalState(AdminClient adminClient, java.util.Collection<java.lang.Integer> nodeIds)
          Utility function that checks the execution state of the server by checking the state of MetadataStore.VoldemortState
This function checks if the nodes are in normal state ( MetadataStore.VoldemortState.NORMAL_SERVER).
static void AdminToolUtils.assertServerInNormalState(AdminClient adminClient, java.lang.Integer nodeId)
          Utility function that checks the execution state of the server by checking the state of MetadataStore.VoldemortState
This function checks if a node is in normal state ( MetadataStore.VoldemortState.NORMAL_SERVER).
static java.util.List<java.lang.Integer> AdminToolUtils.getAllNodeIds(AdminClient adminClient)
          Utility function that fetches node ids.
static java.util.List<java.lang.Integer> AdminToolUtils.getAllPartitions(AdminClient adminClient)
          Utility function that fetches partitions.
static java.util.List<java.lang.String> AdminToolUtils.getAllUserStoreNamesOnNode(AdminClient adminClient, java.lang.Integer nodeId)
          Utility function that fetches all stores on a node.
static java.util.Map<java.lang.String,StoreDefinition> AdminToolUtils.getUserStoreDefMapOnNode(AdminClient adminClient, java.lang.Integer nodeId)
          Utility function that fetches user defined store definitions
static void AdminToolUtils.validateUserStoreNamesOnNode(AdminClient adminClient, java.lang.Integer nodeId, java.util.List<java.lang.String> storeNames)
          Utility function that checks if store names are valid on a node.
 

Uses of AdminClient in voldemort.tools.admin.command
 

Methods in voldemort.tools.admin.command with parameters of type AdminClient
static void AdminCommandAsyncJob.SubCommandAsyncJobList.doAsyncJobList(AdminClient adminClient, java.util.List<java.lang.Integer> nodeIds)
          Gets list of async jobs across multiple nodes.
static void AdminCommandAsyncJob.SubCommandAsyncJobStop.doAsyncJobStop(AdminClient adminClient, java.lang.Integer nodeId, java.util.List<java.lang.Integer> jobIds)
          Stop async jobs on a single nodes.
static void AdminCommandCleanup.SubCommandCleanupOrphanedData.doCleanupOrphanedData(AdminClient adminClient, java.util.List<java.lang.Integer> nodeIds)
          Removes orphaned data on a single node after rebalancing is done.
static void AdminCommandCleanup.SubCommandCleanupVectorClocks.doCleanupVectorClocks(AdminClient adminClient, java.util.List<java.lang.Integer> nodeIds, java.util.List<java.lang.String> storeNames)
          Prunes data resulting from versioned puts during rebalancing
static void AdminCommandDebug.SubCommandDebugQueryKeys.doDebugQueryKeys(AdminClient adminClient, java.util.List<java.lang.Integer> nodeIds, java.util.List<java.lang.String> storeNames, java.util.List<java.lang.String> keyStrings, java.lang.String keyType)
          Queries stores for a set of keys
static void AdminCommandDebug.SubCommandDebugRoute.doDebugRoute(AdminClient adminClient, java.lang.String storeName, java.util.List<java.lang.String> keyStrings, java.lang.String keyType)
          Shows detailed routing information for a given set of keys on a store.
static void AdminCommandMeta.SubCommandMetaCheck.doMetaCheck(AdminClient adminClient, java.util.List<java.lang.String> metaKeys)
          Checks if metadata is consistent across all nodes.
static void AdminCommandMeta.SubCommandMetaCheckVersion.doMetaCheckVersion(AdminClient adminClient)
          Verifies metadata versions for all the cluster nodes
static void AdminCommandMeta.SubCommandMetaClearRebalance.doMetaClearRebalance(AdminClient adminClient, java.util.List<java.lang.Integer> nodeIds)
          Removes metadata related to rebalancing.
static void AdminCommandMeta.SubCommandMetaGet.doMetaGet(AdminClient adminClient, java.util.Collection<java.lang.Integer> nodeIds, java.util.List<java.lang.String> metaKeys, java.io.File directory, java.lang.Boolean verbose)
          Gets metadata.
static void AdminCommandMeta.doMetaSet(AdminClient adminClient, java.util.List<java.lang.Integer> nodeIds, java.lang.String metaKey, java.lang.Object metaValue)
          Sets metadata.
static void AdminCommandMeta.SubCommandMetaSet.doMetaSetPair(AdminClient adminClient, java.util.List<java.lang.Integer> nodeIds, java.lang.Object clusterValue, java.lang.Object storesValue)
          Sets metadata pair atomically.
static void AdminCommandMeta.SubCommandMetaSyncVersion.doMetaSyncVersion(AdminClient adminClient, java.lang.Integer nodeId)
          Synchronizes metadata versions across all nodes.
static void AdminCommandMeta.SubCommandMetaSet.doMetaUpdateVersionsOnStores(AdminClient adminClient, java.util.List<StoreDefinition> oldStoreDefs, java.util.List<StoreDefinition> newStoreDefs)
          Updates metadata versions on stores.
static void AdminCommandQuota.SubCommandQuotaGet.doQuotaGet(AdminClient adminClient, java.util.List<java.lang.String> storeNames, java.util.List<java.lang.String> quotaTypes)
          Gets quota for given quota types on given stores.
static void AdminCommandQuota.SubCommandQuotaSet.doQuotaSet(AdminClient adminClient, java.util.List<java.lang.String> storeNames, java.util.Map<java.lang.String,java.lang.String> quotaMap)
          Sets quota for given quota types on given stores.
static void AdminCommandQuota.SubCommandQuotaUnset.doQuotaUnset(AdminClient adminClient, java.util.List<java.lang.String> storeNames, java.util.List<java.lang.String> quotaTypes)
          Unsets quota for given quota types on given stores.
static void AdminCommandStore.SubCommandStoreAdd.doStoreAdd(AdminClient adminClient, java.util.List<java.lang.Integer> nodeIds, java.lang.String storesFile)
          Adds store on given nodes from a given stores.xml file.
static void AdminCommandStore.SubCommandStoreDelete.doStoreDelete(AdminClient adminClient, java.util.List<java.lang.Integer> nodeIds, java.util.List<java.lang.String> storeNames)
          Deletes given list of stores on given nodes.
static void AdminCommandStore.SubCommandStoreTruncatePartition.doStoreTruncatePartition(AdminClient adminClient, java.lang.Integer nodeId, java.util.List<java.lang.String> storeNames, java.util.List<java.lang.Integer> partIds)
          Removes contents of partitions on a single node.
static void AdminCommandStore.SubCommandStoreTruncateStore.doStoreTruncateStore(AdminClient adminClient, java.util.List<java.lang.Integer> nodeIds, java.util.List<java.lang.String> storeNames)
          Removes contents of stores.
static void AdminCommandStream.SubCommandStreamFetchEntries.doStreamFetchEntries(AdminClient adminClient, java.lang.Integer nodeId, java.util.List<java.lang.String> storeNames, java.util.List<java.lang.Integer> partIds, java.lang.Boolean orphaned, java.io.File directory, java.lang.String format)
          Fetches entries from a given node.
static void AdminCommandStream.SubCommandStreamFetchKeys.doStreamFetchKeys(AdminClient adminClient, java.lang.Integer nodeId, java.util.List<java.lang.String> storeNames, java.util.List<java.lang.Integer> partIds, java.lang.Boolean orphaned, java.io.File directory, java.lang.String format)
          Fetches keys from a given node.
static void AdminCommandStream.SubCommandStreamUpdateEntries.doStreamUpdateEntries(AdminClient adminClient, java.lang.Integer nodeId, java.util.List<java.lang.String> storeNames, java.io.File inDir)
          Updates entries on a given node.
 

Uses of AdminClient in voldemort.utils
 

Methods in voldemort.utils that return AdminClient
 AdminClient ConsistencyFix.getAdminClient()
           
 



Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu