Java 类org.apache.hadoop.hbase.index.ValuePartition 实例源码

Filter doFiltersRestruct(Filter filter) {
  if (filter instanceof SingleColumnValueFilter) {
    ValuePartition vp = null;
    if (filter instanceof SingleColumnValuePartitionFilter) {
      vp = ((SingleColumnValuePartitionFilter) filter).getValuePartition();
    }
    SingleColumnValueFilter scvf = (SingleColumnValueFilter) filter;
    if (scvf.getOperator().equals(CompareOp.LESS)
        || scvf.getOperator().equals(CompareOp.LESS_OR_EQUAL)
        || scvf.getOperator().equals(CompareOp.GREATER)
        || scvf.getOperator().equals(CompareOp.GREATER_OR_EQUAL)) {
      return new SingleColumnRangeFilter(scvf.getFamily(), scvf.getQualifier(), vp, scvf
          .getComparator().getValue(), scvf.getOperator(), null, null);
    }
  }
  FilterGroupingWorker groupWorker = new FilterGroupingWorker();
  return groupWorker.group(filter);
}

Filter doFiltersRestruct(Filter filter) {
  if (filter instanceof SingleColumnValueFilter) {
    ValuePartition vp = null;
    if (filter instanceof SingleColumnValuePartitionFilter) {
      vp = ((SingleColumnValuePartitionFilter) filter).getValuePartition();
    }
    SingleColumnValueFilter scvf = (SingleColumnValueFilter) filter;
    if (scvf.getOperator().equals(CompareOp.LESS)
        || scvf.getOperator().equals(CompareOp.LESS_OR_EQUAL)
        || scvf.getOperator().equals(CompareOp.GREATER)
        || scvf.getOperator().equals(CompareOp.GREATER_OR_EQUAL)) {
      return new SingleColumnRangeFilter(scvf.getFamily(), scvf.getQualifier(), vp, scvf
          .getComparator().getValue(), scvf.getOperator(), null, null);
    }
  }
  FilterGroupingWorker groupWorker = new FilterGroupingWorker();
  return groupWorker.group(filter);
}

public FilterColumnValueDetail(byte[] cf, byte[] qualifier, byte[] value,
    ValuePartition valuePartition, CompareOp compareOp) {
  this.cf = cf;
  this.qualifier = qualifier;
  this.value = value;
  this.compareOp = compareOp;
  this.column = new Column(this.cf, this.qualifier, valuePartition);
}

public FilterColumnValueRange(byte[] cf, byte[] qualifier, ValuePartition vp,
    byte[] lowerBoundValue, CompareOp lowerBoundCompareOp, byte[] upperBoundValue,
    CompareOp upperBoundCompareOp) {
  super(cf, qualifier, lowerBoundValue, vp, lowerBoundCompareOp);
  this.upperBoundCompareOp = upperBoundCompareOp;
  this.upperBoundValue = upperBoundValue;
}

private static byte[] getValueFromKV(Cell kv, ColumnQualifier indexCQ) {
  ValuePartition vp = indexCQ.getValuePartition();
  byte value[] = null;
  if (vp != null) {
    value = vp.getPartOfValue(kv.getValue());
    if (value != null) {
      value = IndexUtils.changeValueAccToDataType(value, indexCQ.getType());
    }
  } else {
    LOG.trace("No offset or separator is mentioned. So just returning the value fetched from kv");
    value = kv.getValue();
    value = IndexUtils.changeValueAccToDataType(value, indexCQ.getType());
  }
  return value;
}

public FilterColumnValueDetail(byte[] cf, byte[] qualifier, byte[] value,
    ValuePartition valuePartition, CompareOp compareOp) {
  this.cf = cf;
  this.qualifier = qualifier;
  this.value = value;
  this.compareOp = compareOp;
  this.column = new Column(this.cf, this.qualifier, valuePartition);
}

public FilterColumnValueRange(byte[] cf, byte[] qualifier, ValuePartition vp,
    byte[] lowerBoundValue, CompareOp lowerBoundCompareOp, byte[] upperBoundValue,
    CompareOp upperBoundCompareOp) {
  super(cf, qualifier, lowerBoundValue, vp, lowerBoundCompareOp);
  this.upperBoundCompareOp = upperBoundCompareOp;
  this.upperBoundValue = upperBoundValue;
}

private static byte[] getValueFromKV(KeyValue kv, ColumnQualifier indexCQ) {
  ValuePartition vp = indexCQ.getValuePartition();
  byte value[] = null;
  if (vp != null) {
    value = vp.getPartOfValue(kv.getValue());
    if (value != null) {
      value = IndexUtils.changeValueAccToDataType(value, indexCQ.getType());
    }
  } else {
    LOG.trace("No offset or separator is mentioned. So just returning the value fetched from kv");
    value = kv.getValue();
    value = IndexUtils.changeValueAccToDataType(value, indexCQ.getType());
  }
  return value;
}

public SingleColumnRangeFilter(byte[] cf, byte[] qualifier, ValuePartition vp,
    byte[] boundValue1, CompareOp boundOp1, byte[] boundValue2, CompareOp boundOp2) {
  this(cf, qualifier, boundValue1, boundOp1, boundValue2, boundOp2);
  this.valuePartition = vp;
}

public ValuePartition getValuePartition() {
  return valuePartition;
}

public void setValuePartition(ValuePartition valuePartition) {
  this.valuePartition = valuePartition;
}

public SingleColumnValuePartitionFilter(final byte[] family, final byte[] qualifier,
    final CompareOp compareOp, final byte[] value, ValuePartition vp) {
  this(family, qualifier, compareOp, new BinaryComparator(value), vp);
}

public SingleColumnValuePartitionFilter(final byte[] family, final byte[] qualifier,
    final CompareOp compareOp, final ByteArrayComparable comparator, ValuePartition vp) {
  super(family, qualifier, compareOp, comparator);
  this.valuePartition = vp;
}

public ValuePartition getValuePartition() {
  return valuePartition;
}

public SingleColumnRangeFilter(byte[] cf, byte[] qualifier, ValuePartition vp,
    byte[] boundValue1, CompareOp boundOp1, byte[] boundValue2, CompareOp boundOp2) {
  this(cf, qualifier, boundValue1, boundOp1, boundValue2, boundOp2);
  this.valuePartition = vp;
}

public ValuePartition getValuePartition() {
  return valuePartition;
}

public void setValuePartition(ValuePartition valuePartition) {
  this.valuePartition = valuePartition;
}

public SingleColumnValuePartitionFilter(final byte[] family, final byte[] qualifier,
    final CompareOp compareOp, final byte[] value, ValuePartition vp) {
  this(family, qualifier, compareOp, new BinaryComparator(value), vp);
}

public SingleColumnValuePartitionFilter(final byte[] family, final byte[] qualifier,
    final CompareOp compareOp, final WritableByteArrayComparable comparator, ValuePartition vp) {
  super(family, qualifier, compareOp, comparator);
  this.valuePartition = vp;
}

public ValuePartition getValuePartition() {
  return valuePartition;
}