List of waitUntilDone() Examples

Examples of waitUntilDone()

org.apache.accumulo.server.zookeeper.DistributedWorkQueue.waitUntilDone()
org.apache.crunch.PipelineExecution.waitUntilDone()
Blocks until pipeline completes, i.e. {@code SUCCEEDED}, {@code FAILED} or {@code KILLED}.
org.apache.crunch.impl.mr.MRPipelineExecution.waitUntilDone()
org.apache.directory.studio.test.integration.ui.bots.utils.JobWatcher.waitUntilDone()
Waits until the watched job is done.
org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFuture.waitUntilDone()
org.jgroups.util.ReusableThread.waitUntilDone()
org.python.pydev.debug.model.remote.ThreadListCommand.waitUntilDone()

Examples of org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFuture.waitUntilDone()

    puts.add(createPut(1, true));
    // Wait for AP to be free. While ars might have the result, ap counters are decreased later.
    ap.waitUntilDone();
    ars = ap.submit(DUMMY_TABLE, puts, false, null, true);
    Assert.assertEquals(0, puts.size());
    ars.waitUntilDone();
    Assert.assertEquals(2, ap.callsCt.get());
    verifyResult(ars, true);
  }


  @Test

View Full Code Here

Examples of org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFuture.waitUntilDone()

    puts.add(createPut(1, false));
    puts.add(createPut(1, true));
    puts.add(createPut(1, true));


    AsyncRequestFuture ars = ap.submit(DUMMY_TABLE, puts, false, null, true);
    ars.waitUntilDone();
    verifyResult(ars, false, true, true);
    Assert.assertEquals(NB_RETRIES + 1, ap.callsCt.get());


    Assert.assertEquals(1, ars.getFailedOperations().size());
  }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFuture.waitUntilDone()

   */
  @Override
  public void batch(final List<? extends Row> actions, final Object[] results)
      throws InterruptedException, IOException {
    AsyncRequestFuture ars = multiAp.submitAll(pool, tableName, actions, null, results);
    ars.waitUntilDone();
    if (ars.hasError()) {
      throw ars.getErrors();
    }
  }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFuture.waitUntilDone()

              callbackErrorServers.add("null");
            }
          }
        }, results);


    future.waitUntilDone();


    if (future.hasError()) {
      throw future.getErrors();
    } else if (!callbackErrorExceptions.isEmpty()) {
      throw new RetriesExhaustedWithDetailsException(callbackErrorExceptions, callbackErrorActions,

View Full Code Here

Examples of org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFuture.waitUntilDone()

    List<Put> puts = new ArrayList<Put>();
    puts.add(createPut(1, true));


    final AsyncRequestFuture ars = ap.submit(DUMMY_TABLE, puts, false, cb, false);
    Assert.assertTrue(puts.isEmpty());
    ars.waitUntilDone();
    Assert.assertEquals(updateCalled.get(), 1);
  }


  @Test
  public void testSubmitBusyRegion() throws Exception {

View Full Code Here

Examples of org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFuture.waitUntilDone()

    Put p = createPut(1, false);
    puts.add(p);


    AsyncRequestFuture ars = ap.submit(DUMMY_TABLE, puts, false, null, true);
    Assert.assertEquals(0, puts.size());
    ars.waitUntilDone();
    verifyResult(ars, false);
    Assert.assertEquals(NB_RETRIES + 1, ap.callsCt.get());


    Assert.assertEquals(1, ars.getErrors().exceptions.size());
    Assert.assertTrue("was: " + ars.getErrors().exceptions.get(0),

View Full Code Here

Examples of org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFuture.waitUntilDone()

    puts.add(createPut(1, true));
    puts.add(createPut(1, true));


    AsyncRequestFuture ars = ap.submit(DUMMY_TABLE, puts, false, null, true);
    Assert.assertTrue(puts.isEmpty());
    ars.waitUntilDone();
    verifyResult(ars, false, true, true);
    Assert.assertEquals(NB_RETRIES + 1, ap.callsCt.get());
    ap.callsCt.set(0);
    Assert.assertEquals(1, ars.getErrors().actions.size());

View Full Code Here

Examples of org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFuture.waitUntilDone()

    puts.add(createPut(1, true));
    // Wait for AP to be free. While ars might have the result, ap counters are decreased later.
    ap.waitUntilDone();
    ars = ap.submit(DUMMY_TABLE, puts, false, null, true);
    Assert.assertEquals(0, puts.size());
    ars.waitUntilDone();
    Assert.assertEquals(2, ap.callsCt.get());
    verifyResult(ars, true);
  }


  @Test

View Full Code Here

Examples of org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFuture.waitUntilDone()

    puts.add(createPut(1, false));
    puts.add(createPut(1, true));
    puts.add(createPut(1, true));


    AsyncRequestFuture ars = ap.submit(DUMMY_TABLE, puts, false, null, true);
    ars.waitUntilDone();
    verifyResult(ars, false, true, true);
    Assert.assertEquals(NB_RETRIES + 1, ap.callsCt.get());


    Assert.assertEquals(1, ars.getFailedOperations().size());
  }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.AsyncProcess.AsyncRequestFuture.waitUntilDone()

   */
  @Override
  public void batch(final List<? extends Row> actions, final Object[] results)
      throws InterruptedException, IOException {
    AsyncRequestFuture ars = multiAp.submitAll(pool, tableName, actions, null, results);
    ars.waitUntilDone();
    if (ars.hasError()) {
      throw ars.getErrors();
    }
  }

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.