List of registerUpdater() Examples

Examples of registerUpdater()

org.apache.hadoop.metrics.MetricsContext.registerUpdater()
Registers a callback to be called at regular time intervals, as determined by the implementation-class specific configuration. @param updater object to be run periodically; it should updatedsome metrics records and then return

Examples of org.apache.hadoop.metrics.MetricsContext.registerUpdater()

    
    // Create record for DataNode metrics
    MetricsContext context = MetricsUtil.getContext("dfs");
    metricsRecord = MetricsUtil.createRecord(context, "datanode");
    metricsRecord.setTag("sessionId", sessionId);
    context.registerUpdater(this);
  }
  
  public void shutdown() {
    if (datanodeActivityMBean != null) 
      datanodeActivityMBean.shutdown();

View Full Code Here

Examples of org.apache.hadoop.metrics.MetricsContext.registerUpdater()

        this.shuffleMetrics.setTag("user", conf.getUser());
        this.shuffleMetrics.setTag("jobName", conf.getJobName());
        this.shuffleMetrics.setTag("jobId", ReduceTask.this.getJobID().toString());
        this.shuffleMetrics.setTag("taskId", getTaskID().toString());
        this.shuffleMetrics.setTag("sessionId", conf.getSessionId());
        metricsContext.registerUpdater(this);
      }
      public synchronized void inputBytes(long numBytes) {
        this.numBytes += numBytes;
      }
      public synchronized void failedFetch() {

View Full Code Here

Examples of org.apache.hadoop.metrics.MetricsContext.registerUpdater()

          "Rate of successful kerberos logins and time taken in milliseconds");
      loginFailure = new MetricsTimeVaryingRate("loginFailure", registry,
          "Rate of failed kerberos logins and time taken in milliseconds");
      final MetricsContext metricsContext = MetricsUtil.getContext("ugi");
      metricsRecord = MetricsUtil.createRecord(metricsContext, "ugi");
      metricsContext.registerUpdater(this);
    }


    /**
     * Push the metrics to the monitoring subsystem on doUpdate() call.
     */

View Full Code Here

Examples of org.apache.hadoop.metrics.MetricsContext.registerUpdater()

    metricsRecord.setTag("port", port);


    LOG.info("Initializing RPC Metrics with hostName=" 
        + hostName + ", port=" + port);


    context.registerUpdater(this);
    
    // Need to clean up the interface to RpcMgt - don't need both metrics and server params
    rpcMBean = new RpcDetailedActivityMBean(registry, hostName, port);
  }

View Full Code Here

Examples of org.apache.hadoop.metrics.MetricsContext.registerUpdater()

    metricsRecord.setTag("port", port);


    LOG.info("Initializing RPC Metrics with hostName=" 
        + hostName + ", port=" + port);


    context.registerUpdater(this);
    
    // Need to clean up the interface to RpcMgt - don't need both metrics and server params
    rpcMBean = new RpcActivityMBean(registry, hostName, port);
  }

View Full Code Here

Examples of org.apache.hadoop.metrics.MetricsContext.registerUpdater()

    metricsRecord.setTag("port", port);


    LOG.info("Initializing RPC Metrics with hostName="
        + hostName + ", port=" + port);


    context.registerUpdater(this);


    initMethods(HMasterInterface.class);
    initMethods(HMasterRegionInterface.class);
    initMethods(HRegionInterface.class);
    rpcStatistics = new HBaseRPCStatistics(this.registry, hostName, port);

View Full Code Here

Examples of org.apache.hadoop.metrics.MetricsContext.registerUpdater()

  public RegionServerMetrics() {
    MetricsContext context = MetricsUtil.getContext("hbase");
    metricsRecord = MetricsUtil.createRecord(context, "regionserver");
    String name = Thread.currentThread().getName();
    metricsRecord.setTag("RegionServer", name);
    context.registerUpdater(this);
    // Add jvmmetrics.
    JvmMetrics.init("RegionServer", name);
    // Add Hbase Info metrics
    HBaseInfo.init();

View Full Code Here

Examples of org.apache.hadoop.metrics.MetricsContext.registerUpdater()

    metricsRecord.setTag("port", port);


    LOG.info("Initializing RPC Metrics with hostName="
        + hostName + ", port=" + port);


    context.registerUpdater(this);


    initMethods(HMasterInterface.class);
    initMethods(HMasterRegionInterface.class);
    initMethods(HRegionInterface.class);
    rpcStatistics = new HBaseRPCStatistics(this.registry, hostName, port);

View Full Code Here

Examples of org.apache.hadoop.metrics.MetricsContext.registerUpdater()


  public MasterMetrics(final String name) {
    MetricsContext context = MetricsUtil.getContext("hbase");
    metricsRecord = MetricsUtil.createRecord(context, "master");
    metricsRecord.setTag("Master", name);
    context.registerUpdater(this);
    JvmMetrics.init("Master", name);
    HBaseInfo.init();


    // expose the MBean for metrics
    masterStatistics = new MasterStatistics(this.registry);

View Full Code Here

Examples of org.apache.hadoop.metrics.MetricsContext.registerUpdater()

  public ReplicationSourceMetrics(String id) {
    MetricsContext context = MetricsUtil.getContext("hbase");
    String name = Thread.currentThread().getName();
    metricsRecord = MetricsUtil.createRecord(context, "replication");
    metricsRecord.setTag("RegionServer", name);
    context.registerUpdater(this);
    try {
      id = URLEncoder.encode(id, "UTF8");
    } catch (UnsupportedEncodingException e) {
      id = "CAN'T ENCODE UTF8";
    }

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.