Examples of org.apache.commons.lang.time.StopWatch.start()

Class org.apache.commons.lang.time.StopWatch

Examples of org.apache.commons.lang.time.StopWatch.start()

org.apache.commons.lang.time.StopWatch.start()

Start the stopwatch.

This method starts a new timing session, clearing any previous values.
@throws IllegalStateException if the StopWatch is already running.

          table = new HTable(this.admin.getConfiguration(), tableName);
          startKey = region.getStartKey();
          // Can't do a get on empty start row so do a Scan of first element if any instead.
          if(startKey.length > 0) {
            get = new Get(startKey);
            stopWatch.start();
            table.get(get);
            stopWatch.stop();
          } else {
            scan = new Scan();
            scan.setCaching(1);

View Full Code Here

            stopWatch.stop();
          } else {
            scan = new Scan();
            scan.setCaching(1);
            scan.setMaxResultSize(1L);
            stopWatch.start();
            table.getScanner(scan);
            stopWatch.stop();
          }
          this.getSink().publishReadTiming(tableName, serverName, stopWatch.getTime());
        } catch (TableNotFoundException tnfe) {

View Full Code Here


        // Holds any exception that was thrown during startup
        final ObjectHolder errorHolder = new ObjectHolder();


        StopWatch watch = new StopWatch();
        watch.start();


        // Start the server int a seperate thread
        Thread t = new Thread("Geronimo Server Runner") {
            public void run() {
                try {

View Full Code Here


    // Wait until both of the two jobs are submitted.
    List<MRJob> jobs = exec.getJobs();
    assertEquals(2, jobs.size());
    StopWatch watch = new StopWatch();
    watch.start();
    int numOfJobsSubmitted = 0;
    while (numOfJobsSubmitted < 2 && watch.getTime() < 10000) {
      numOfJobsSubmitted = 0;
      for (MRJob job : jobs) {
        if (job.getJobState() == MRJob.State.RUNNING) {

View Full Code Here

    Job job0 = jobs.get(0).getJob();
    job0.killJob();


    // Expect the pipeline exits and the other job is killed.
    StopWatch watch2 = new StopWatch();
    watch2.start();
    Job job1 = jobs.get(1).getJob();
    while (!job1.isComplete() && watch2.getTime() < 10000) {
      Thread.sleep(100);
    }
    assertTrue(job1.isComplete());

View Full Code Here


        // Holds any exception that was thrown during startup
        final ObjectHolder errorHolder = new ObjectHolder();


        StopWatch watch = new StopWatch();
        watch.start();


        // Start the server int a seperate thread
        Thread t = new Thread("Geronimo Server Runner") {
            public void run() {
                try {

View Full Code Here


        runningGroups.add( groupId );


        StopWatch stopWatch = new StopWatch();
        stopWatch.reset();
        stopWatch.start();


        File mergedIndexDirectory = indexMergerRequest.getMergedIndexDirectory();


        String tempRepoId = mergedIndexDirectory.getName();

View Full Code Here

            }
            this.runningRemoteDownloadIds.add( this.remoteRepository.getId() );
        }
        File tempIndexDirectory = null;
        StopWatch stopWatch = new StopWatch();
        stopWatch.start();
        try
        {
            log.info( "start download remote index for remote repository " + this.remoteRepository.getId() );
            IndexingContext indexingContext = remoteRepositoryAdmin.createIndexContext( this.remoteRepository );

View Full Code Here


        // Holds any exception that was thrown during startup
        final ObjectHolder errorHolder = new ObjectHolder();


        StopWatch watch = new StopWatch();
        watch.start();


        // Start the server int a seperate thread
        Thread t = new Thread("Geronimo Server Runner") {
            public void run() {
                try {

View Full Code Here


                final EventExecutorGroup executorService = ctx.executor();
                final Future<?> iteration = executorService.submit((Callable<Void>) () -> {
                    logger.debug("Preparing to iterate results from - {} - in thread [{}]", requestMessage, Thread.currentThread().getName());


                    stopWatch.start();


                    List<Object> aggregate = new ArrayList<>(resultIterationBatchSize);
                    while (itty.hasNext()) {
                        aggregate.add(itty.next());

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.