Examples of MasterMonitorInfo

com.taobao.top.analysis.node.monitor.MasterMonitorInfo
Master端的监控信息 @author sihai
org.apache.accumulo.core.master.thrift.MasterMonitorInfo

Examples of org.apache.accumulo.core.master.thrift.MasterMonitorInfo

   * e.g. if you want to see the metadata table you should create a table.
   * @since 1.6.1
   */
  public MasterMonitorInfo getMasterMonitorInfo() throws AccumuloException, AccumuloSecurityException {
    MasterClientService.Iface client = null;
    MasterMonitorInfo stats = null;
    try {
      Instance instance = new ZooKeeperInstance(getClientConfig());
      client = MasterClient.getConnectionWithRetry(instance);
      stats = client.getMasterStats(Tracer.traceInfo(), SystemCredentials.get(instance).toThrift(instance));
    } catch (ThriftSecurityException exception) {

View Full Code Here

Examples of org.apache.accumulo.core.master.thrift.MasterMonitorInfo

import org.apache.accumulo.trace.instrument.Tracer;


public class GetMasterStats {
  public static void main(String[] args) throws Exception {
    MasterClientService.Iface client = null;
    MasterMonitorInfo stats = null;
    try {
      Instance instance = HdfsZooInstance.getInstance();
      client = MasterClient.getConnectionWithRetry(instance);
      stats = client.getMasterStats(Tracer.traceInfo(), SystemCredentials.get().toThrift(instance));
    } finally {

View Full Code Here

Examples of org.apache.accumulo.core.master.thrift.MasterMonitorInfo

    }
  }


  @Test(timeout = 60000)
  public void saneMonitorInfo() throws Exception {
    MasterMonitorInfo stats;
    while (true) {
      stats = accumulo.getMasterMonitorInfo();
      if (null != stats.tServerInfo && stats.tServerInfo.size() == NUM_TSERVERS) {
        break;
      }

View Full Code Here

Examples of org.apache.accumulo.core.master.thrift.MasterMonitorInfo

      
    }
    
    @Override
    public MasterMonitorInfo getMasterStats(TInfo info, AuthInfo credentials) throws ThriftSecurityException, TException {
      final MasterMonitorInfo result = new MasterMonitorInfo();
      result.loggers = new ArrayList<LoggerStatus>();
      for (String logger : loggers.getLoggersFromZooKeeper().values()) {
        result.loggers.add(new LoggerStatus(logger));
      }
      result.recovery = recovery.status();

View Full Code Here

Examples of org.apache.accumulo.core.master.thrift.MasterMonitorInfo

  
  private void doAccumuloTable(StringBuilder sb) throws IOException {
    // Accumulo
    Configuration conf = CachedConfiguration.getInstance();
    DistributedFileSystem fs = (DistributedFileSystem) FileSystem.get(conf);
    MasterMonitorInfo info = Monitor.getMmi();
    sb.append("<table>\n");
    sb.append("<tr><th colspan='2'><a href='/master'>Accumulo Master</a></th></tr>\n");
    if (info == null) {
      sb.append("<tr><td colspan='2'><span class='error'>Master is Down</span></td></tr>\n");
    } else {

View Full Code Here

Examples of org.apache.accumulo.core.master.thrift.MasterMonitorInfo

      }
    }
    
    @Override
    public MasterMonitorInfo getMasterStats(TInfo info, AuthInfo credentials) throws ThriftSecurityException, TException {
      final MasterMonitorInfo result = new MasterMonitorInfo();
      result.loggers = new ArrayList<LoggerStatus>();
      for (String logger : loggers.getLoggersFromZooKeeper().keySet()) {
        result.loggers.add(new LoggerStatus(logger));
      }
      result.recovery = recovery.status();

View Full Code Here

Examples of org.apache.accumulo.core.master.thrift.MasterMonitorInfo

      
    }
    
    @Override
    public MasterMonitorInfo getMasterStats(TInfo info, AuthInfo credentials) throws ThriftSecurityException, TException {
      final MasterMonitorInfo result = new MasterMonitorInfo();
      result.loggers = new ArrayList<LoggerStatus>();
      for (String logger : loggers.getLoggersFromZooKeeper().values()) {
        result.loggers.add(new LoggerStatus(logger));
      }
      result.recovery = recovery.status();

View Full Code Here

Examples of org.apache.accumulo.core.master.thrift.MasterMonitorInfo

  
  private void doAccumuloTable(StringBuilder sb) throws IOException {
    // Accumulo
    Configuration conf = CachedConfiguration.getInstance();
    FileSystem fs = TraceFileSystem.wrap(FileUtil.getFileSystem(conf, ServerConfiguration.getSiteConfiguration()));
    MasterMonitorInfo info = Monitor.getMmi();
    sb.append("<table>\n");
    sb.append("<tr><th colspan='2'><a href='/master'>Accumulo Master</a></th></tr>\n");
    if (info == null) {
      sb.append("<tr><td colspan='2'><span class='error'>Master is Down</span></td></tr>\n");
    } else {

View Full Code Here

Examples of org.apache.accumulo.core.master.thrift.MasterMonitorInfo

    private String getACUStats() throws Exception {
      
      MasterClientService.Iface client = null;
      try {
        client = MasterClient.getConnectionWithRetry(HdfsZooInstance.getInstance());
        MasterMonitorInfo stats = client.getMasterStats(null, SecurityConstants.getSystemCredentials());
        
        TableInfo all = new TableInfo();
        Map<String,TableInfo> tableSummaries = new HashMap<String,TableInfo>();
        
        for (TabletServerStatus server : stats.tServerInfo) {

View Full Code Here

Examples of org.apache.accumulo.core.master.thrift.MasterMonitorInfo

   * @throws IOException
   * @throws TTransportException
   */
  public static void main(String[] args) throws Exception {
    MasterClientService.Iface client = null;
    MasterMonitorInfo stats = null;
    try {
      client = MasterClient.getConnectionWithRetry(HdfsZooInstance.getInstance());
      stats = client.getMasterStats(null, SecurityConstants.getSystemCredentials());
    } finally {
      if (client != null)

View Full Code Here

0 1 2 3 4 5

TOP

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.