List of takeSnapshotAsync() Examples

Examples of takeSnapshotAsync()

org.apache.hadoop.hbase.client.Admin.takeSnapshotAsync()
Take a snapshot without waiting for the server to complete that snapshot (asynchronous) Only a single snapshot should be taken at a time, or results may be undefined. @param snapshot snapshot to take @return response from the server indicating the max time to wait for the snapshot @throws IOException if the snapshot did not succeed or we lose contact with the master. @throws SnapshotCreationException if snapshot creation failed @throws IllegalArgumentException if the snapshot request is formatted incorrectly
org.apache.hadoop.hbase.client.HBaseAdmin.takeSnapshotAsync()
Take a snapshot without waiting for the server to complete that snapshot (asynchronous)
Only a single snapshot should be taken at a time, or results may be undefined. @param snapshot snapshot to take @return the max time in millis to wait for the snapshot @throws IOException if the snapshot did not succeed or we lose contact with the master. @throws SnapshotCreationException if snapshot creation failed @throws IllegalArgumentException if the snapshot request is formatted incorrectly

Examples of org.apache.hadoop.hbase.client.Admin.takeSnapshotAsync()

      @Override
      public void run() {
        try {
          Admin admin = UTIL.getHBaseAdmin();
          LOG.info("Submitting snapshot request: " + ClientSnapshotDescriptionUtils.toString(ss));
          admin.takeSnapshotAsync(ss);
        } catch (Exception e) {
          LOG.info("Exception during snapshot request: " + ClientSnapshotDescriptionUtils.toString(
              ss)
              + ".  This is ok, we expect some", e);
        }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.Admin.takeSnapshotAsync()

      @Override
      public void run() {
        try {
          Admin admin = UTIL.getHBaseAdmin();
          LOG.info("Submitting snapshot request: " + ClientSnapshotDescriptionUtils.toString(ss));
          admin.takeSnapshotAsync(ss);
        } catch (Exception e) {
          LOG.info("Exception during snapshot request: " + ClientSnapshotDescriptionUtils.toString(
              ss)
              + ".  This is ok, we expect some", e);
        }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.Admin.takeSnapshotAsync()

        .setTable(TABLE_NAME.getNameAsString())
        .setType(SnapshotDescription.Type.FLUSH)
        .build();


    // take the snapshot async
    admin.takeSnapshotAsync(snapshot);


    // constantly loop, looking for the snapshot to complete
    HMaster master = UTIL.getMiniHBaseCluster().getMaster();
    SnapshotTestingUtils.waitForSnapshotToComplete(master, snapshot, 200);
    LOG.info(" === Async Snapshot Completed ===");

View Full Code Here

Examples of org.apache.hadoop.hbase.client.Admin.takeSnapshotAsync()

        .setTable(TABLE_NAME.getNameAsString())
        .setType(SnapshotDescription.Type.FLUSH)
        .build();


    // take the snapshot async
    admin.takeSnapshotAsync(snapshot);


    // constantly loop, looking for the snapshot to complete
    HMaster master = UTIL.getMiniHBaseCluster().getMaster();
    SnapshotTestingUtils.waitForSnapshotToComplete(master, snapshot, 200);
    LOG.info(" === Async Snapshot Completed ===");

View Full Code Here

Examples of org.apache.hadoop.hbase.client.Admin.takeSnapshotAsync()

      @Override
      public void run() {
        try {
          Admin admin = UTIL.getHBaseAdmin();
          LOG.info("Submitting snapshot request: " + ClientSnapshotDescriptionUtils.toString(ss));
          admin.takeSnapshotAsync(ss);
        } catch (Exception e) {
          LOG.info("Exception during snapshot request: " + ClientSnapshotDescriptionUtils.toString(
              ss)
              + ".  This is ok, we expect some", e);
        }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.Admin.takeSnapshotAsync()

      @Override
      public void run() {
        try {
          Admin admin = UTIL.getHBaseAdmin();
          LOG.info("Submitting snapshot request: " + ClientSnapshotDescriptionUtils.toString(ss));
          admin.takeSnapshotAsync(ss);
        } catch (Exception e) {
          LOG.info("Exception during snapshot request: " + ClientSnapshotDescriptionUtils.toString(
              ss)
              + ".  This is ok, we expect some", e);
        }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.HBaseAdmin.takeSnapshotAsync()

    HBaseAdmin admin = UTIL.getHBaseAdmin();
    SnapshotDescription snapshot = SnapshotDescription.newBuilder().setName("asyncSnapshot")
        .setTable(STRING_TABLE_NAME).setType(SnapshotDescription.Type.FLUSH).build();


    // take the snapshot async
    admin.takeSnapshotAsync(snapshot);


    // constantly loop, looking for the snapshot to complete
    HMaster master = UTIL.getMiniHBaseCluster().getMaster();
    SnapshotTestingUtils.waitForSnapshotToComplete(master, new HSnapshotDescription(snapshot), 200);
    LOG.info(" === Async Snapshot Completed ===");

View Full Code Here

Examples of org.apache.hadoop.hbase.client.HBaseAdmin.takeSnapshotAsync()

      @Override
      public void run() {
        try {
          HBaseAdmin admin = UTIL.getHBaseAdmin();
          LOG.info("Submitting snapshot request: " + SnapshotDescriptionUtils.toString(ss));
          admin.takeSnapshotAsync(ss);
        } catch (Exception e) {
          LOG.info("Exception during snapshot request: " + SnapshotDescriptionUtils.toString(ss)
              + ".  This is ok, we expect some", e);
        }
        LOG.info("Submitted snapshot request: " + SnapshotDescriptionUtils.toString(ss));

View Full Code Here

Examples of org.apache.hadoop.hbase.client.HBaseAdmin.takeSnapshotAsync()

      @Override
      public void run() {
        try {
          HBaseAdmin admin = UTIL.getHBaseAdmin();
          LOG.info("Submitting snapshot request: " + SnapshotDescriptionUtils.toString(ss));
          admin.takeSnapshotAsync(ss);
        } catch (Exception e) {
          LOG.info("Exception during snapshot request: " + SnapshotDescriptionUtils.toString(ss)
              + ".  This is ok, we expect some", e);
        }
        LOG.info("Submitted snapshot request: " + SnapshotDescriptionUtils.toString(ss));

View Full Code Here

Examples of org.apache.hadoop.hbase.client.HBaseAdmin.takeSnapshotAsync()

    HBaseAdmin admin = UTIL.getHBaseAdmin();
    SnapshotDescription snapshot = SnapshotDescription.newBuilder().setName("asyncSnapshot")
        .setTable(STRING_TABLE_NAME).setType(SnapshotDescription.Type.FLUSH).build();


    // take the snapshot async
    admin.takeSnapshotAsync(snapshot);


    // constantly loop, looking for the snapshot to complete
    HMaster master = UTIL.getMiniHBaseCluster().getMaster();
    SnapshotTestingUtils.waitForSnapshotToComplete(master, new HSnapshotDescription(snapshot), 200);
    LOG.info(" === Async Snapshot Completed ===");

View Full Code Here

0 1 2 3

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.