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; }
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 SingleColumnValuePartitionFilter(final byte[] family, final byte[] qualifier, final CompareOp compareOp, final WritableByteArrayComparable comparator, ValuePartition vp) { super(family, qualifier, compareOp, comparator); this.valuePartition = vp; }