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()

        this.shuffleMetrics.setTag("user", conf.getUser());
        this.shuffleMetrics.setTag("jobName", conf.getJobName());
        this.shuffleMetrics.setTag("jobId", ReduceTask.this.getJobId());
        this.shuffleMetrics.setTag("taskId", getTaskId());
        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()

      // Create a record for map-reduce metrics
      MetricsContext context = MetricsUtil.getContext("mapred");
      metricsRecord = MetricsUtil.createRecord(context, "jobtracker");
      metricsRecord.setTag("sessionId", sessionId);
      this.tracker = tracker;
      context.registerUpdater(this);
    }
      
    /**
     * Since this object is a registered updater, this method will be called
     * periodically, e.g. every 5 seconds.

View Full Code Here

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

    ShuffleServerMetrics(JobConf conf) {
      MetricsContext context = MetricsUtil.getContext("mapred");
      shuffleMetricsRecord = 
                           MetricsUtil.createRecord(context, "shuffleOutput");
      this.shuffleMetricsRecord.setTag("sessionId", conf.getSessionId());
      context.registerUpdater(this);
    }
    synchronized void serverHandlerBusy() {
      ++serverHandlerBusy;
    }
    synchronized void serverHandlerFree() {

View Full Code Here

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

      JvmMetrics.init("TaskTracker", sessionId);
      // Create a record for Task Tracker metrics
      MetricsContext context = MetricsUtil.getContext("mapred");
      metricsRecord = MetricsUtil.createRecord(context, "tasktracker");
      metricsRecord.setTag("sessionId", sessionId);
      context.registerUpdater(this);
    }
      
    synchronized void completeTask() {
      ++numCompletedTasks;
    }

View Full Code Here

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()


  public DFSClientMetrics() {
    // Create a record for FSNamesystem metrics
    MetricsContext metricsContext = MetricsUtil.getContext("hdfsclient");
    metricsRecord = MetricsUtil.createRecord(metricsContext, "DFSClient");
    metricsContext.registerUpdater(this);
  
  }




  public Object clone() throws CloneNotSupportedException{

View Full Code Here

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

  public LookasideMetrics() {
    // Create a record for LookasideCache metrics
    MetricsContext metricsContext = MetricsUtil.getContext("lookasideCache");
    metricsRecord = MetricsUtil.createRecord(metricsContext,
                                             "LookasideFileSystem");
    metricsContext.registerUpdater(this);


  }


  /**
   * Since this object is a registered updater, this method will be called

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());
        this.shuffleMetrics.setTag("taskId", getTaskId());
        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()

      // Create a record for map-reduce metrics
      MetricsContext context = MetricsUtil.getContext("mapred");
      metricsRecord = MetricsUtil.createRecord(context, "jobtracker");
      metricsRecord.setTag("sessionId", sessionId);
      this.tracker = tracker;
      context.registerUpdater(this);
    }
      
    /**
     * Since this object is a registered updater, this method will be called
     * periodically, e.g. every 5 seconds.

View Full Code Here

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

      JvmMetrics.init("NameNode", sessionId);
      // Create a record for NameNode metrics
      MetricsContext metricsContext = MetricsUtil.getContext("dfs");
      metricsRecord = MetricsUtil.createRecord(metricsContext, "namenode");
      metricsRecord.setTag("sessionId", sessionId);
      metricsContext.registerUpdater(this);
    }
      
    /**
     * Since this object is a registered updater, this method will be called
     * periodically, e.g. every 5 seconds.

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.