Examples of ProxyPutStats


Examples of voldemort.store.rebalancing.ProxyPutStats

            this.dynThrottleLimit = null;

        // create the proxy put thread pool
        this.proxyPutWorkerPool = Executors.newFixedThreadPool(config.getMaxProxyPutThreads(),
                                                               new DaemonThreadFactory("voldemort-proxy-put-thread"));
        this.aggregatedProxyPutStats = new ProxyPutStats(null);
        if(config.isJmxEnabled()) {
            JmxUtils.registerMbean(this.aggregatedProxyPutStats,
                                   JmxUtils.createObjectName("voldemort.store.rebalancing",
                                                             "aggregate-proxy-puts"));
        }
View Full Code Here

Examples of voldemort.store.rebalancing.ProxyPutStats

                    metadata.addMetadataStoreListener(store.getName(), retentionEnforcingStore);
                    store = retentionEnforcingStore;
                }

                if(voldemortConfig.isEnableRebalanceService()) {
                    ProxyPutStats proxyPutStats = new ProxyPutStats(aggregatedProxyPutStats);
                    if(voldemortConfig.isJmxEnabled()) {
                        JmxUtils.registerMbean(proxyPutStats,
                                               JmxUtils.createObjectName("voldemort.store.rebalancing",
                                                                         engine.getName()
                                                                                 + "-proxy-puts"));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.