1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.monitoring.ThreadMonitoring

Java 类org.apache.hadoop.hbase.monitoring.ThreadMonitoring 实例源码

项目：ditb    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：LCIndex-HBase-0.94.16    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：pbase    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：HIndex    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：IRIndex    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：hbase    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：RStore    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：PyroDB    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：c5    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：HBase-Research    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：hbase-0.94.8-qod    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：hbase-0.94.8-qod    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：DominoHBase    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：hindex    文件：ExecutorService.java    
/**
 * Dump a textual representation of the executor's status
 * to the given writer.
 *
 * @param out the stream to write to
 * @param indent a string prefix for each line, used for indentation
 */
public void dumpTo(Writer out, String indent) throws IOException {
  out.write(indent + "Status for executor: " + executor + "\n");
  out.write(indent + "=======================================\n");
  out.write(indent + queuedEvents.size() + " events queued, " +
      running.size() + " running\n");
  if (!queuedEvents.isEmpty()) {
    out.write(indent + "Queued:\n");
    for (EventHandler e : queuedEvents) {
      out.write(indent + "  " + e + "\n");
    }
    out.write("\n");
  }
  if (!running.isEmpty()) {
    out.write(indent + "Running:\n");
    for (RunningEventStatus stat : running) {
      out.write(indent + "  Running on thread '" +
          stat.threadInfo.getThreadName() +
          "': " + stat.event + "\n");
      out.write(ThreadMonitoring.formatThreadInfo(
          stat.threadInfo, indent + "  "));
      out.write("\n");
    }
  }
  out.flush();
}
项目：ditb    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：LCIndex-HBase-0.94.16    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：pbase    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：HIndex    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：IRIndex    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：hbase    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：RStore    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：PyroDB    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：c5    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：HBase-Research    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：hbase-0.94.8-qod    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：hbase-0.94.8-qod    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：DominoHBase    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}
项目：hindex    文件：ExecutorService.java    
public RunningEventStatus(Thread t, EventHandler event) {
  this.threadInfo = ThreadMonitoring.getThreadInfo(t);
  this.event = event;
}