org.apache.hadoop.hbase.CompareOperator#GREATER_OR_EQUAL源码实例Demo

protected CompareOperator getCompare(Where where) {
    if (where == Where.Equals)
        return CompareOperator.EQUAL;

    if (where == Where.NotEquals)
        return CompareOperator.NOT_EQUAL;

    if (where == Where.Less)
        return CompareOperator.LESS;

    if (where == Where.LessEquals)
        return CompareOperator.LESS_OR_EQUAL;

    if (where == Where.Greater)
        return CompareOperator.GREATER;

    if (where == Where.GreaterEquals)
        return CompareOperator.GREATER_OR_EQUAL;

    return CompareOperator.EQUAL;
}
 

@Test
public void testSingleColumnValueExcludeFilter() throws Exception {
  // null family/column SingleColumnValueExcludeFilter
  SingleColumnValueExcludeFilter singleColumnValueExcludeFilter =
    new SingleColumnValueExcludeFilter(null, null,
    CompareOperator.GREATER_OR_EQUAL, Bytes.toBytes("value"));
  assertTrue(singleColumnValueExcludeFilter.areSerializedFieldsEqual(
    ProtobufUtil.toFilter(ProtobufUtil.toFilter(singleColumnValueExcludeFilter))));

  // non-null family/column SingleColumnValueFilter
  singleColumnValueExcludeFilter =
    new SingleColumnValueExcludeFilter(Bytes.toBytes("fam"), Bytes.toBytes("qual"),
    CompareOperator.LESS_OR_EQUAL, new NullComparator(), false, false);
  assertTrue(singleColumnValueExcludeFilter.areSerializedFieldsEqual(
    ProtobufUtil.toFilter(ProtobufUtil.toFilter(singleColumnValueExcludeFilter))));
}
 

/**
 * Takes a compareOperator symbol as a byte array and returns the corresponding CompareOperator
 * @param compareOpAsByteArray the comparatorOperator symbol as a byte array
 * @return the Compare Operator
 */
public static CompareOperator createCompareOperator (byte [] compareOpAsByteArray) {
  ByteBuffer compareOp = ByteBuffer.wrap(compareOpAsByteArray);
  if (compareOp.equals(ParseConstants.LESS_THAN_BUFFER))
    return CompareOperator.LESS;
  else if (compareOp.equals(ParseConstants.LESS_THAN_OR_EQUAL_TO_BUFFER))
    return CompareOperator.LESS_OR_EQUAL;
  else if (compareOp.equals(ParseConstants.GREATER_THAN_BUFFER))
    return CompareOperator.GREATER;
  else if (compareOp.equals(ParseConstants.GREATER_THAN_OR_EQUAL_TO_BUFFER))
    return CompareOperator.GREATER_OR_EQUAL;
  else if (compareOp.equals(ParseConstants.NOT_EQUAL_TO_BUFFER))
    return CompareOperator.NOT_EQUAL;
  else if (compareOp.equals(ParseConstants.EQUAL_TO_BUFFER))
    return CompareOperator.EQUAL;
  else
    throw new IllegalArgumentException("Invalid compare operator");
}
 

public static CompareOperator compareOpFromThrift(TCompareOperator tCompareOp) {
  switch (tCompareOp.getValue()) {
    case 0: return CompareOperator.LESS;
    case 1: return CompareOperator.LESS_OR_EQUAL;
    case 2: return CompareOperator.EQUAL;
    case 3: return CompareOperator.NOT_EQUAL;
    case 4: return CompareOperator.GREATER_OR_EQUAL;
    case 5: return CompareOperator.GREATER;
    case 6: return CompareOperator.NO_OP;
    default: return null;
  }
}
 

@Test
public void testDependentColumnFilter() throws Exception {
  // null column qualifier/family
  DependentColumnFilter dependentColumnFilter = new DependentColumnFilter(null, null);
  assertTrue(dependentColumnFilter.areSerializedFieldsEqual(
    ProtobufUtil.toFilter(ProtobufUtil.toFilter(dependentColumnFilter))));

  // non-null column qualifier/family
  dependentColumnFilter = new DependentColumnFilter(Bytes.toBytes("family"),
    Bytes.toBytes("qual"), true, CompareOperator.GREATER_OR_EQUAL,
    new BitComparator(Bytes.toBytes("bitComparator"), BitComparator.BitwiseOp.OR));
  assertTrue(dependentColumnFilter.areSerializedFieldsEqual(
    ProtobufUtil.toFilter(ProtobufUtil.toFilter(dependentColumnFilter))));
}
 

private Filter basicFilterNew() {
  return new SingleColumnValueFilter(COLUMN_FAMILY, COLUMN_QUALIFIER,
  CompareOperator.GREATER_OR_EQUAL, VAL_2);
}