Java 类org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Condition 实例源码

项目：ditb 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned delete
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param delete
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Delete delete) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutation(ProtobufUtil.toMutation(MutationType.DELETE, delete,
    MutationProto.newBuilder()));
  builder.setCondition(condition);
  return builder.build();
}

项目：pbase 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned delete
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param delete
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Delete delete) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutation(ProtobufUtil.toMutation(MutationType.DELETE, delete,
    MutationProto.newBuilder()));
  builder.setCondition(condition);
  return builder.build();
}

项目：HIndex 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned delete
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param delete
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Delete delete) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutation(ProtobufUtil.toMutation(MutationType.DELETE, delete,
    MutationProto.newBuilder()));
  builder.setCondition(condition);
  return builder.build();
}

项目：PyroDB 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned delete
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param delete
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Delete delete) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutation(ProtobufUtil.toMutation(MutationType.DELETE, delete,
    MutationProto.newBuilder()));
  builder.setCondition(condition);
  return builder.build();
}

项目：c5 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned delete
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param delete
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Delete delete) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutation(ProtobufUtil.toMutation(MutationType.DELETE, delete,
    MutationProto.newBuilder()));
  builder.setCondition(condition);
  return builder.build();
}

项目：ditb 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned put
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param put
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Put put) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutation(ProtobufUtil.toMutation(MutationType.PUT, put, MutationProto.newBuilder()));
  builder.setCondition(condition);
  return builder.build();
}

项目：ditb 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for conditioned row mutations
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param rowMutations
 * @return a mutate request
 * @throws IOException
 */
public static ClientProtos.MultiRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final RowMutations rowMutations) throws IOException {
  RegionAction.Builder builder =
      getRegionActionBuilderWithRegion(RegionAction.newBuilder(), regionName);
  builder.setAtomic(true);
  ClientProtos.Action.Builder actionBuilder = ClientProtos.Action.newBuilder();
  MutationProto.Builder mutationBuilder = MutationProto.newBuilder();
  Condition condition = buildCondition(
      row, family, qualifier, comparator, compareType);
  for (Mutation mutation: rowMutations.getMutations()) {
    MutationType mutateType = null;
    if (mutation instanceof Put) {
      mutateType = MutationType.PUT;
    } else if (mutation instanceof Delete) {
      mutateType = MutationType.DELETE;
    } else {
      throw new DoNotRetryIOException("RowMutations supports only put and delete, not " +
          mutation.getClass().getName());
    }
    mutationBuilder.clear();
    MutationProto mp = ProtobufUtil.toMutation(mutateType, mutation, mutationBuilder);
    actionBuilder.clear();
    actionBuilder.setMutation(mp);
    builder.addAction(actionBuilder.build());
  }
  ClientProtos.MultiRequest request =
      ClientProtos.MultiRequest.newBuilder().addRegionAction(builder.build())
          .setCondition(condition).build();
  return request;
}

项目：ditb 文件：RequestConverter.java

/**
 * Create a protocol buffer Condition
 *
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @return a Condition
 * @throws IOException
 */
private static Condition buildCondition(final byte[] row,
    final byte[] family, final byte [] qualifier,
    final ByteArrayComparable comparator,
    final CompareType compareType) throws IOException {
  Condition.Builder builder = Condition.newBuilder();
  builder.setRow(ByteStringer.wrap(row));
  builder.setFamily(ByteStringer.wrap(family));
  builder.setQualifier(ByteStringer.wrap(qualifier));
  builder.setComparator(ProtobufUtil.toComparator(comparator));
  builder.setCompareType(compareType);
  return builder.build();
}

项目：pbase 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned put
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param put
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Put put) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutation(ProtobufUtil.toMutation(MutationType.PUT, put, MutationProto.newBuilder()));
  builder.setCondition(condition);
  return builder.build();
}

项目：pbase 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for conditioned row mutations
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param rowMutations
 * @return a mutate request
 * @throws IOException
 */
public static ClientProtos.MultiRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final RowMutations rowMutations) throws IOException {
  RegionAction.Builder builder =
      getRegionActionBuilderWithRegion(RegionAction.newBuilder(), regionName);
  builder.setAtomic(true);
  ClientProtos.Action.Builder actionBuilder = ClientProtos.Action.newBuilder();
  MutationProto.Builder mutationBuilder = MutationProto.newBuilder();
  Condition condition = buildCondition(
      row, family, qualifier, comparator, compareType);
  for (Mutation mutation: rowMutations.getMutations()) {
    MutationType mutateType = null;
    if (mutation instanceof Put) {
      mutateType = MutationType.PUT;
    } else if (mutation instanceof Delete) {
      mutateType = MutationType.DELETE;
    } else {
      throw new DoNotRetryIOException("RowMutations supports only put and delete, not " +
          mutation.getClass().getName());
    }
    mutationBuilder.clear();
    MutationProto mp = ProtobufUtil.toMutation(mutateType, mutation, mutationBuilder);
    actionBuilder.clear();
    actionBuilder.setMutation(mp);
    builder.addAction(actionBuilder.build());
  }
  ClientProtos.MultiRequest request =
      ClientProtos.MultiRequest.newBuilder().addRegionAction(builder.build())
          .setCondition(condition).build();
  return request;
}

项目：pbase 文件：RequestConverter.java

/**
 * Create a protocol buffer Condition
 *
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @return a Condition
 * @throws IOException
 */
private static Condition buildCondition(final byte[] row,
    final byte[] family, final byte [] qualifier,
    final ByteArrayComparable comparator,
    final CompareType compareType) throws IOException {
  Condition.Builder builder = Condition.newBuilder();
  builder.setRow(ByteStringer.wrap(row));
  builder.setFamily(ByteStringer.wrap(family));
  builder.setQualifier(ByteStringer.wrap(qualifier));
  builder.setComparator(ProtobufUtil.toComparator(comparator));
  builder.setCompareType(compareType);
  return builder.build();
}

项目：HIndex 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned put
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param put
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Put put) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutation(ProtobufUtil.toMutation(MutationType.PUT, put, MutationProto.newBuilder()));
  builder.setCondition(condition);
  return builder.build();
}

项目：HIndex 文件：RequestConverter.java

/**
 * Create a protocol buffer Condition
 *
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @return a Condition
 * @throws IOException
 */
private static Condition buildCondition(final byte[] row,
    final byte[] family, final byte [] qualifier,
    final ByteArrayComparable comparator,
    final CompareType compareType) throws IOException {
  Condition.Builder builder = Condition.newBuilder();
  builder.setRow(HBaseZeroCopyByteString.wrap(row));
  builder.setFamily(HBaseZeroCopyByteString.wrap(family));
  builder.setQualifier(HBaseZeroCopyByteString.wrap(qualifier));
  builder.setComparator(ProtobufUtil.toComparator(comparator));
  builder.setCompareType(compareType);
  return builder.build();
}

项目：PyroDB 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned put
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param put
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Put put) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutation(ProtobufUtil.toMutation(MutationType.PUT, put, MutationProto.newBuilder()));
  builder.setCondition(condition);
  return builder.build();
}

项目：PyroDB 文件：RequestConverter.java

/**
 * Create a protocol buffer Condition
 *
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @return a Condition
 * @throws IOException
 */
private static Condition buildCondition(final byte[] row,
    final byte[] family, final byte [] qualifier,
    final ByteArrayComparable comparator,
    final CompareType compareType) throws IOException {
  Condition.Builder builder = Condition.newBuilder();
  builder.setRow(HBaseZeroCopyByteString.wrap(row));
  builder.setFamily(HBaseZeroCopyByteString.wrap(family));
  builder.setQualifier(HBaseZeroCopyByteString.wrap(qualifier));
  builder.setComparator(ProtobufUtil.toComparator(comparator));
  builder.setCompareType(compareType);
  return builder.build();
}

项目：c5 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned put
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param put
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Put put) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutation(ProtobufUtil.toMutation(MutationType.PUT, put, MutationProto.newBuilder()));
  builder.setCondition(condition);
  return builder.build();
}

项目：c5 文件：RequestConverter.java

/**
 * Create a protocol buffer Condition
 *
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @return a Condition
 * @throws IOException
 */
private static Condition buildCondition(final byte[] row,
    final byte[] family, final byte [] qualifier,
    final ByteArrayComparable comparator,
    final CompareType compareType) throws IOException {
  Condition.Builder builder = Condition.newBuilder();
  builder.setRow(ZeroCopyLiteralByteString.wrap(row));
  builder.setFamily(ZeroCopyLiteralByteString.wrap(family));
  builder.setQualifier(ZeroCopyLiteralByteString.wrap(qualifier));
  builder.setComparator(ProtobufUtil.toComparator(comparator));
  builder.setCompareType(compareType);
  return builder.build();
}

项目：DominoHBase 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned put
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param put
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Put put) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutate(ProtobufUtil.toMutate(MutateType.PUT, put));
  builder.setCondition(condition);
  return builder.build();
}

项目：DominoHBase 文件：RequestConverter.java

/**
 * Create a protocol buffer MutateRequest for a conditioned delete
 *
 * @param regionName
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @param delete
 * @return a mutate request
 * @throws IOException
 */
public static MutateRequest buildMutateRequest(
    final byte[] regionName, final byte[] row, final byte[] family,
    final byte [] qualifier, final ByteArrayComparable comparator,
    final CompareType compareType, final Delete delete) throws IOException {
  MutateRequest.Builder builder = MutateRequest.newBuilder();
  RegionSpecifier region = buildRegionSpecifier(
    RegionSpecifierType.REGION_NAME, regionName);
  builder.setRegion(region);
  Condition condition = buildCondition(
    row, family, qualifier, comparator, compareType);
  builder.setMutate(ProtobufUtil.toMutate(MutateType.DELETE, delete));
  builder.setCondition(condition);
  return builder.build();
}

项目：DominoHBase 文件：RequestConverter.java

/**
 * Create a protocol buffer Condition
 *
 * @param row
 * @param family
 * @param qualifier
 * @param comparator
 * @param compareType
 * @return a Condition
 * @throws IOException
 */
private static Condition buildCondition(final byte[] row,
    final byte[] family, final byte [] qualifier,
    final ByteArrayComparable comparator,
    final CompareType compareType) throws IOException {
  Condition.Builder builder = Condition.newBuilder();
  builder.setRow(ByteString.copyFrom(row));
  builder.setFamily(ByteString.copyFrom(family));
  builder.setQualifier(ByteString.copyFrom(qualifier));
  builder.setComparator(ProtobufUtil.toComparator(comparator));
  builder.setCompareType(compareType);
  return builder.build();
}