• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java StorageProxyMBean类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.cassandra.service.StorageProxyMBean的典型用法代码示例。如果您正苦于以下问题:Java StorageProxyMBean类的具体用法?Java StorageProxyMBean怎么用?Java StorageProxyMBean使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



StorageProxyMBean类属于org.apache.cassandra.service包,在下文中一共展示了StorageProxyMBean类的5个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: execute

import org.apache.cassandra.service.StorageProxyMBean; //导入依赖的package包/类
@Override
public void execute(NodeProbe probe)
{
    StorageProxyMBean sp = probe.getSpProxy();
    String[] percentiles = new String[]{"50%", "75%", "95%", "98%", "99%", "Min", "Max"};
    double[] readLatency = probe.metricPercentilesAsArray(sp.getRecentReadLatencyHistogramMicros());
    double[] writeLatency = probe.metricPercentilesAsArray(sp.getRecentWriteLatencyHistogramMicros());
    double[] rangeLatency = probe.metricPercentilesAsArray(sp.getRecentRangeLatencyHistogramMicros());

    System.out.println("proxy histograms");
    System.out.println(format("%-10s%18s%18s%18s",
            "Percentile", "Read Latency", "Write Latency", "Range Latency"));
    System.out.println(format("%-10s%18s%18s%18s",
            "", "(micros)", "(micros)", "(micros)"));
    for (int i = 0; i < percentiles.length; i++)
    {
        System.out.println(format("%-10s%18.2f%18.2f%18.2f",
                percentiles[i],
                readLatency[i],
                writeLatency[i],
                rangeLatency[i]));
    }
    System.out.println();
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:25,代码来源:NodeTool.java


示例2: printProxyHistograms

import org.apache.cassandra.service.StorageProxyMBean; //导入依赖的package包/类
private void printProxyHistograms(PrintStream output)
{
    StorageProxyMBean sp = this.probe.getSpProxy();
    long[] offsets = new EstimatedHistogram().getBucketOffsets();
    long[] rrlh = sp.getRecentReadLatencyHistogramMicros();
    long[] rwlh = sp.getRecentWriteLatencyHistogramMicros();
    long[] rrnglh = sp.getRecentRangeLatencyHistogramMicros();

    output.println("proxy histograms");
    output.println(String.format("%-10s%18s%18s%18s",
                                "Offset", "Read Latency", "Write Latency", "Range Latency"));
    for (int i = 0; i < offsets.length; i++)
    {
        output.println(String.format("%-10d%18s%18s%18s",
                                    offsets[i],
                                    (i < rrlh.length ? rrlh[i] : "0"),
                                    (i < rwlh.length ? rwlh[i] : "0"),
                                    (i < rrnglh.length ? rrnglh[i] : "0")));
    }
}
 
开发者ID:pgaref,项目名称:ACaZoo,代码行数:21,代码来源:NodeCmd.java


示例3: connect

import org.apache.cassandra.service.StorageProxyMBean; //导入依赖的package包/类
/**
 * Create a connection to the JMX agent and setup the M[X]Bean proxies.
 *
 * @throws IOException on connection failures
 */
private void connect() throws IOException
{
    JMXServiceURL jmxUrl = new JMXServiceURL(String.format(fmtUrl, host, port));
    Map<String,Object> env = new HashMap<String,Object>();
    if (username != null)
    {
        String[] creds = { username, password };
        env.put(JMXConnector.CREDENTIALS, creds);
    }
    jmxc = JMXConnectorFactory.connect(jmxUrl, env);
    mbeanServerConn = jmxc.getMBeanServerConnection();

    try
    {
        ObjectName name = new ObjectName(ssObjName);
        ssProxy = JMX.newMBeanProxy(mbeanServerConn, name, StorageServiceMBean.class);
        name = new ObjectName(MessagingService.MBEAN_NAME);
        msProxy = JMX.newMBeanProxy(mbeanServerConn, name, MessagingServiceMBean.class);
        name = new ObjectName(StreamManagerMBean.OBJECT_NAME);
        streamProxy = JMX.newMBeanProxy(mbeanServerConn, name, StreamManagerMBean.class);
        name = new ObjectName(CompactionManager.MBEAN_OBJECT_NAME);
        compactionProxy = JMX.newMBeanProxy(mbeanServerConn, name, CompactionManagerMBean.class);
        name = new ObjectName(FailureDetector.MBEAN_NAME);
        fdProxy = JMX.newMBeanProxy(mbeanServerConn, name, FailureDetectorMBean.class);
        name = new ObjectName(CacheService.MBEAN_NAME);
        cacheService = JMX.newMBeanProxy(mbeanServerConn, name, CacheServiceMBean.class);
        name = new ObjectName(StorageProxy.MBEAN_NAME);
        spProxy = JMX.newMBeanProxy(mbeanServerConn, name, StorageProxyMBean.class);
        name = new ObjectName(HintedHandOffManager.MBEAN_NAME);
        hhProxy = JMX.newMBeanProxy(mbeanServerConn, name, HintedHandOffManagerMBean.class);
        name = new ObjectName(GCInspector.MBEAN_NAME);
        gcProxy = JMX.newMBeanProxy(mbeanServerConn, name, GCInspectorMXBean.class);
    }
    catch (MalformedObjectNameException e)
    {
        throw new RuntimeException(
                "Invalid ObjectName? Please report this as a bug.", e);
    }

    memProxy = ManagementFactory.newPlatformMXBeanProxy(mbeanServerConn,
            ManagementFactory.MEMORY_MXBEAN_NAME, MemoryMXBean.class);
    runtimeProxy = ManagementFactory.newPlatformMXBeanProxy(
            mbeanServerConn, ManagementFactory.RUNTIME_MXBEAN_NAME, RuntimeMXBean.class);
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:50,代码来源:NodeProbe.java


示例4: getSpProxy

import org.apache.cassandra.service.StorageProxyMBean; //导入依赖的package包/类
public StorageProxyMBean getSpProxy()
{
    return spProxy;
}
 
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:5,代码来源:NodeProbe.java


示例5: connect

import org.apache.cassandra.service.StorageProxyMBean; //导入依赖的package包/类
/**
 * Create a connection to the JMX agent and setup the M[X]Bean proxies.
 *
 * @throws IOException on connection failures
 */
private void connect() throws IOException
{
    JMXServiceURL jmxUrl = new JMXServiceURL(String.format(fmtUrl, host, port));
    Map<String,Object> env = new HashMap<String,Object>();
    if (username != null)
    {
        String[] creds = { username, password };
        env.put(JMXConnector.CREDENTIALS, creds);
    }

    env.put("com.sun.jndi.rmi.factory.socket", getRMIClientSocketFactory());

    jmxc = JMXConnectorFactory.connect(jmxUrl, env);
    mbeanServerConn = jmxc.getMBeanServerConnection();

    try
    {
        ObjectName name = new ObjectName(ssObjName);
        ssProxy = JMX.newMBeanProxy(mbeanServerConn, name, StorageServiceMBean.class);
        name = new ObjectName(MessagingService.MBEAN_NAME);
        msProxy = JMX.newMBeanProxy(mbeanServerConn, name, MessagingServiceMBean.class);
        name = new ObjectName(StreamManagerMBean.OBJECT_NAME);
        streamProxy = JMX.newMBeanProxy(mbeanServerConn, name, StreamManagerMBean.class);
        name = new ObjectName(CompactionManager.MBEAN_OBJECT_NAME);
        compactionProxy = JMX.newMBeanProxy(mbeanServerConn, name, CompactionManagerMBean.class);
        name = new ObjectName(FailureDetector.MBEAN_NAME);
        fdProxy = JMX.newMBeanProxy(mbeanServerConn, name, FailureDetectorMBean.class);
        name = new ObjectName(CacheService.MBEAN_NAME);
        cacheService = JMX.newMBeanProxy(mbeanServerConn, name, CacheServiceMBean.class);
        name = new ObjectName(StorageProxy.MBEAN_NAME);
        spProxy = JMX.newMBeanProxy(mbeanServerConn, name, StorageProxyMBean.class);
        name = new ObjectName(HintedHandOffManager.MBEAN_NAME);
        hhProxy = JMX.newMBeanProxy(mbeanServerConn, name, HintedHandOffManagerMBean.class);
        name = new ObjectName(GCInspector.MBEAN_NAME);
        gcProxy = JMX.newMBeanProxy(mbeanServerConn, name, GCInspectorMXBean.class);
        name = new ObjectName(Gossiper.MBEAN_NAME);
        gossProxy = JMX.newMBeanProxy(mbeanServerConn, name, GossiperMBean.class);
        name = new ObjectName(BatchlogManager.MBEAN_NAME);
        bmProxy = JMX.newMBeanProxy(mbeanServerConn, name, BatchlogManagerMBean.class);
    }
    catch (MalformedObjectNameException e)
    {
        throw new RuntimeException(
                "Invalid ObjectName? Please report this as a bug.", e);
    }

    memProxy = ManagementFactory.newPlatformMXBeanProxy(mbeanServerConn,
            ManagementFactory.MEMORY_MXBEAN_NAME, MemoryMXBean.class);
    runtimeProxy = ManagementFactory.newPlatformMXBeanProxy(
            mbeanServerConn, ManagementFactory.RUNTIME_MXBEAN_NAME, RuntimeMXBean.class);
}
 
开发者ID:scylladb,项目名称:scylla-tools-java,代码行数:57,代码来源:NodeProbe.java



注:本文中的org.apache.cassandra.service.StorageProxyMBean类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java Touches类代码示例发布时间:2022-05-23
下一篇:
Java SMOreg类代码示例发布时间:2022-05-23
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap