Java 类org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.SnapshotDescription.Type 实例源码

项目：ditb 文件：SnapshotManager.java

private SnapshotDescription toSnapshotDescription(ProcedureDescription desc)
    throws IOException {
  SnapshotDescription.Builder builder = SnapshotDescription.newBuilder();
  if (!desc.hasInstance()) {
    throw new IOException("Snapshot name is not defined: " + desc.toString());
  }
  String snapshotName = desc.getInstance();
  List<NameStringPair> props = desc.getConfigurationList();
  String table = null;
  for (NameStringPair prop : props) {
    if ("table".equalsIgnoreCase(prop.getName())) {
      table = prop.getValue();
    }
  }
  if (table == null) {
    throw new IOException("Snapshot table is not defined: " + desc.toString());
  }
  TableName tableName = TableName.valueOf(table);
  builder.setTable(tableName.getNameAsString());
  builder.setName(snapshotName);
  builder.setType(SnapshotDescription.Type.FLUSH);
  return builder.build();
}

项目：pbase 文件：SnapshotManager.java

private SnapshotDescription toSnapshotDescription(ProcedureDescription desc)
    throws IOException {
  SnapshotDescription.Builder builder = SnapshotDescription.newBuilder();
  if (!desc.hasInstance()) {
    throw new IOException("Snapshot name is not defined: " + desc.toString());
  }
  String snapshotName = desc.getInstance();
  List<NameStringPair> props = desc.getConfigurationList();
  String table = null;
  for (NameStringPair prop : props) {
    if ("table".equalsIgnoreCase(prop.getName())) {
      table = prop.getValue();
    }
  }
  if (table == null) {
    throw new IOException("Snapshot table is not defined: " + desc.toString());
  }
  TableName tableName = TableName.valueOf(table);
  builder.setTable(tableName.getNameAsString());
  builder.setName(snapshotName);
  builder.setType(SnapshotDescription.Type.FLUSH);
  return builder.build();
}

项目：HIndex 文件：SnapshotManager.java

private SnapshotDescription toSnapshotDescription(ProcedureDescription desc)
    throws IOException {
  SnapshotDescription.Builder builder = SnapshotDescription.newBuilder();
  if (!desc.hasInstance()) {
    throw new IOException("Snapshot name is not defined: " + desc.toString());
  }
  String snapshotName = desc.getInstance();
  List<NameStringPair> props = desc.getConfigurationList();
  String table = null;
  for (NameStringPair prop : props) {
    if ("table".equalsIgnoreCase(prop.getName())) {
      table = prop.getValue();
    }
  }
  if (table == null) {
    throw new IOException("Snapshot table is not defined: " + desc.toString());
  }
  TableName tableName = TableName.valueOf(table);
  builder.setTable(tableName.getNameAsString());
  builder.setName(snapshotName);
  builder.setType(SnapshotDescription.Type.FLUSH);
  return builder.build();
}

项目：PyroDB 文件：SnapshotManager.java

private SnapshotDescription toSnapshotDescription(ProcedureDescription desc)
    throws IOException {
  SnapshotDescription.Builder builder = SnapshotDescription.newBuilder();
  if (!desc.hasInstance()) {
    throw new IOException("Snapshot name is not defined: " + desc.toString());
  }
  String snapshotName = desc.getInstance();
  List<NameStringPair> props = desc.getConfigurationList();
  String table = null;
  for (NameStringPair prop : props) {
    if ("table".equalsIgnoreCase(prop.getName())) {
      table = prop.getValue();
    }
  }
  if (table == null) {
    throw new IOException("Snapshot table is not defined: " + desc.toString());
  }
  TableName tableName = TableName.valueOf(table);
  builder.setTable(tableName.getNameAsString());
  builder.setName(snapshotName);
  builder.setType(SnapshotDescription.Type.FLUSH);
  return builder.build();
}

项目：ditb 文件：SnapshotManager.java

/**
 * Take a snapshot of a disabled table.
 * @param snapshot description of the snapshot to take. Modified to be {@link Type#DISABLED}.
 * @throws HBaseSnapshotException if the snapshot could not be started
 */
private synchronized void snapshotDisabledTable(SnapshotDescription snapshot)
    throws HBaseSnapshotException {
  // setup the snapshot
  prepareToTakeSnapshot(snapshot);

  // set the snapshot to be a disabled snapshot, since the client doesn't know about that
  snapshot = snapshot.toBuilder().setType(Type.DISABLED).build();

  // Take the snapshot of the disabled table
  DisabledTableSnapshotHandler handler =
      new DisabledTableSnapshotHandler(snapshot, master);
  snapshotTable(snapshot, handler);
}

项目：LCIndex-HBase-0.94.16 文件：SnapshotManager.java

/**
 * Take a snapshot of a disabled table.
 * @param snapshot description of the snapshot to take. Modified to be {@link Type#DISABLED}.
 * @throws HBaseSnapshotException if the snapshot could not be started
 */
private synchronized void snapshotDisabledTable(SnapshotDescription snapshot)
    throws HBaseSnapshotException {
  // setup the snapshot
  prepareToTakeSnapshot(snapshot);

  // set the snapshot to be a disabled snapshot, since the client doesn't know about that
  snapshot = snapshot.toBuilder().setType(Type.DISABLED).build();

  // Take the snapshot of the disabled table
  DisabledTableSnapshotHandler handler =
      new DisabledTableSnapshotHandler(snapshot, master, metricsMaster);
  snapshotTable(snapshot, handler);
}

项目：pbase 文件：SnapshotManager.java

/**
 * Take a snapshot of a disabled table.
 * @param snapshot description of the snapshot to take. Modified to be {@link Type#DISABLED}.
 * @throws HBaseSnapshotException if the snapshot could not be started
 */
private synchronized void snapshotDisabledTable(SnapshotDescription snapshot)
    throws HBaseSnapshotException {
  // setup the snapshot
  prepareToTakeSnapshot(snapshot);

  // set the snapshot to be a disabled snapshot, since the client doesn't know about that
  snapshot = snapshot.toBuilder().setType(Type.DISABLED).build();

  // Take the snapshot of the disabled table
  DisabledTableSnapshotHandler handler =
      new DisabledTableSnapshotHandler(snapshot, master);
  snapshotTable(snapshot, handler);
}

项目：HIndex 文件：SnapshotManager.java

/**
 * Take a snapshot of a disabled table.
 * @param snapshot description of the snapshot to take. Modified to be {@link Type#DISABLED}.
 * @throws HBaseSnapshotException if the snapshot could not be started
 */
private synchronized void snapshotDisabledTable(SnapshotDescription snapshot)
    throws HBaseSnapshotException {
  // setup the snapshot
  prepareToTakeSnapshot(snapshot);

  // set the snapshot to be a disabled snapshot, since the client doesn't know about that
  snapshot = snapshot.toBuilder().setType(Type.DISABLED).build();

  // Take the snapshot of the disabled table
  DisabledTableSnapshotHandler handler =
      new DisabledTableSnapshotHandler(snapshot, master);
  snapshotTable(snapshot, handler);
}

项目：IRIndex 文件：SnapshotManager.java

/**
 * Take a snapshot of a disabled table.
 * @param snapshot description of the snapshot to take. Modified to be {@link Type#DISABLED}.
 * @throws HBaseSnapshotException if the snapshot could not be started
 */
private synchronized void snapshotDisabledTable(SnapshotDescription snapshot)
    throws HBaseSnapshotException {
  // setup the snapshot
  prepareToTakeSnapshot(snapshot);

  // set the snapshot to be a disabled snapshot, since the client doesn't know about that
  snapshot = snapshot.toBuilder().setType(Type.DISABLED).build();

  // Take the snapshot of the disabled table
  DisabledTableSnapshotHandler handler =
      new DisabledTableSnapshotHandler(snapshot, master, metricsMaster);
  snapshotTable(snapshot, handler);
}

项目：PyroDB 文件：SnapshotManager.java

/**
 * Take a snapshot of a disabled table.
 * @param snapshot description of the snapshot to take. Modified to be {@link Type#DISABLED}.
 * @throws HBaseSnapshotException if the snapshot could not be started
 */
private synchronized void snapshotDisabledTable(SnapshotDescription snapshot)
    throws HBaseSnapshotException {
  // setup the snapshot
  prepareToTakeSnapshot(snapshot);

  // set the snapshot to be a disabled snapshot, since the client doesn't know about that
  snapshot = snapshot.toBuilder().setType(Type.DISABLED).build();

  // Take the snapshot of the disabled table
  DisabledTableSnapshotHandler handler =
      new DisabledTableSnapshotHandler(snapshot, master);
  snapshotTable(snapshot, handler);
}

项目：c5 文件：SnapshotManager.java

/**
 * Take a snapshot of a disabled table.
 * @param snapshot description of the snapshot to take. Modified to be {@link Type#DISABLED}.
 * @throws HBaseSnapshotException if the snapshot could not be started
 */
private synchronized void snapshotDisabledTable(SnapshotDescription snapshot)
    throws HBaseSnapshotException {
  // setup the snapshot
  prepareToTakeSnapshot(snapshot);

  // set the snapshot to be a disabled snapshot, since the client doesn't know about that
  snapshot = snapshot.toBuilder().setType(Type.DISABLED).build();

  // Take the snapshot of the disabled table
  DisabledTableSnapshotHandler handler =
      new DisabledTableSnapshotHandler(snapshot, master);
  snapshotTable(snapshot, handler);
}

项目：HBase-Research 文件：SnapshotManager.java

/**
 * Take a snapshot of a disabled table.
 * @param snapshot description of the snapshot to take. Modified to be {@link Type#DISABLED}.
 * @throws HBaseSnapshotException if the snapshot could not be started
 */
private synchronized void snapshotDisabledTable(SnapshotDescription snapshot)
    throws HBaseSnapshotException {
  // setup the snapshot
  prepareToTakeSnapshot(snapshot);

  // set the snapshot to be a disabled snapshot, since the client doesn't know about that
  snapshot = snapshot.toBuilder().setType(Type.DISABLED).build();

  // Take the snapshot of the disabled table
  DisabledTableSnapshotHandler handler =
      new DisabledTableSnapshotHandler(snapshot, master, metricsMaster);
  snapshotTable(snapshot, handler);
}

项目：hbase-0.94.8-qod 文件：SnapshotManager.java

/**
 * Take a snapshot of a disabled table.
 * @param snapshot description of the snapshot to take. Modified to be {@link Type#DISABLED}.
 * @throws HBaseSnapshotException if the snapshot could not be started
 */
private synchronized void snapshotDisabledTable(SnapshotDescription snapshot)
    throws HBaseSnapshotException {
  // setup the snapshot
  prepareToTakeSnapshot(snapshot);

  // set the snapshot to be a disabled snapshot, since the client doesn't know about that
  snapshot = snapshot.toBuilder().setType(Type.DISABLED).build();

  // Take the snapshot of the disabled table
  DisabledTableSnapshotHandler handler =
      new DisabledTableSnapshotHandler(snapshot, master, metricsMaster);
  snapshotTable(snapshot, handler);
}

项目：hbase-0.94.8-qod 文件：SnapshotManager.java

/**
 * Take a snapshot of a disabled table.
 * @param snapshot description of the snapshot to take. Modified to be {@link Type#DISABLED}.
 * @throws HBaseSnapshotException if the snapshot could not be started
 */
private synchronized void snapshotDisabledTable(SnapshotDescription snapshot)
    throws HBaseSnapshotException {
  // setup the snapshot
  prepareToTakeSnapshot(snapshot);

  // set the snapshot to be a disabled snapshot, since the client doesn't know about that
  snapshot = snapshot.toBuilder().setType(Type.DISABLED).build();

  // Take the snapshot of the disabled table
  DisabledTableSnapshotHandler handler =
      new DisabledTableSnapshotHandler(snapshot, master, metricsMaster);
  snapshotTable(snapshot, handler);
}

项目：hindex 文件：SnapshotManager.java

/**
 * Take a snapshot of a disabled table.
 * @param snapshot description of the snapshot to take. Modified to be {@link Type#DISABLED}.
 * @throws HBaseSnapshotException if the snapshot could not be started
 */
private synchronized void snapshotDisabledTable(SnapshotDescription snapshot)
    throws HBaseSnapshotException {
  // setup the snapshot
  prepareToTakeSnapshot(snapshot);

  // set the snapshot to be a disabled snapshot, since the client doesn't know about that
  snapshot = snapshot.toBuilder().setType(Type.DISABLED).build();

  // Take the snapshot of the disabled table
  DisabledTableSnapshotHandler handler =
      new DisabledTableSnapshotHandler(snapshot, master, metricsMaster);
  snapshotTable(snapshot, handler);
}

项目：ColumnManagerForHBase 文件：MAdmin.java

@Override
public void snapshot(String string, TableName tn, Type type) throws IOException, SnapshotCreationException, IllegalArgumentException {
  wrappedHbaseAdmin.snapshot(string, tn, type);
}

项目：openyu-commons 文件：HzSessionImpl.java

public void snapshot(String snapshotName, String tableName, Type type)
        throws IOException, SnapshotCreationException,
        IllegalArgumentException {
    delegate.snapshot(snapshotName, tableName, type);
}

项目：openyu-commons 文件：HzSession.java

void snapshot(String snapshotName, String tableName, Type type)
throws IOException, SnapshotCreationException, IllegalArgumentException;

项目：CSBT 文件：CrossSiteHBaseAdmin.java

/**
 * Unsupported.
 */
public void snapshot(String snapshotName, String tableName, Type type) throws IOException,
    SnapshotCreationException, IllegalArgumentException {
  throw new UnsupportedOperationException();
}