HBASE-19008 Add missing equals or hashCode method(s) to stock Filter implementations
Signed-off-by: Reid Chan <reidchan@apache.org> Signed-off-by: Ted Yu <yuzhihong@gmail.com>
This commit is contained in:
parent
0eb891cbd9
commit
694983dc96
|
@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.yetus.audience.InterfaceAudience;
|
import org.apache.yetus.audience.InterfaceAudience;
|
||||||
|
@ -132,4 +133,18 @@ public class ColumnCountGetFilter extends FilterBase {
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return this.getClass().getSimpleName() + " " + this.limit;
|
return this.getClass().getSimpleName() + " " + this.limit;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof ColumnCountGetFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
ColumnCountGetFilter f = (ColumnCountGetFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.limit);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -20,6 +20,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CellUtil;
|
import org.apache.hadoop.hbase.CellUtil;
|
||||||
|
@ -230,4 +231,18 @@ public class ColumnPaginationFilter extends FilterBase {
|
||||||
return String.format("%s (%d, %d)", this.getClass().getSimpleName(),
|
return String.format("%s (%d, %d)", this.getClass().getSimpleName(),
|
||||||
this.limit, this.offset);
|
this.limit, this.offset);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof ColumnPaginationFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
ColumnPaginationFilter f = (ColumnPaginationFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.limit, this.offset);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.ByteBufferExtendedCell;
|
import org.apache.hadoop.hbase.ByteBufferExtendedCell;
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
|
@ -161,4 +162,18 @@ public class ColumnPrefixFilter extends FilterBase {
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return this.getClass().getSimpleName() + " " + Bytes.toStringBinary(this.prefix);
|
return this.getClass().getSimpleName() + " " + Bytes.toStringBinary(this.prefix);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof ColumnPrefixFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
ColumnPrefixFilter f = (ColumnPrefixFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(Bytes.hashCode(this.getPrefix()));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -23,6 +23,7 @@ import static org.apache.hadoop.hbase.util.Bytes.len;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CellUtil;
|
import org.apache.hadoop.hbase.CellUtil;
|
||||||
|
@ -239,4 +240,19 @@ public class ColumnRangeFilter extends FilterBase {
|
||||||
+ ", " + Bytes.toStringBinary(this.maxColumn)
|
+ ", " + Bytes.toStringBinary(this.maxColumn)
|
||||||
+ (this.maxColumnInclusive ? "]" : ")");
|
+ (this.maxColumnInclusive ? "]" : ")");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof ColumnRangeFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
ColumnRangeFilter f = (ColumnRangeFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(Bytes.toStringBinary(this.getMinColumn()), this.getMinColumnInclusive(),
|
||||||
|
Bytes.toStringBinary(this.getMaxColumn()), this.getMaxColumnInclusive());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CellUtil;
|
import org.apache.hadoop.hbase.CellUtil;
|
||||||
|
@ -238,4 +239,19 @@ public class ColumnValueFilter extends FilterBase {
|
||||||
Bytes.toStringBinary(this.qualifier), this.op.name(),
|
Bytes.toStringBinary(this.qualifier), this.op.name(),
|
||||||
Bytes.toStringBinary(this.comparator.getValue()));
|
Bytes.toStringBinary(this.comparator.getValue()));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof ColumnValueFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
ColumnValueFilter f = (ColumnValueFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(Bytes.hashCode(this.getFamily()), Bytes.hashCode(this.getQualifier()),
|
||||||
|
this.getCompareOperator(), this.getComparator());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CompareOperator;
|
import org.apache.hadoop.hbase.CompareOperator;
|
||||||
|
@ -321,4 +322,18 @@ public abstract class CompareFilter extends FilterBase {
|
||||||
this.op.name(),
|
this.op.name(),
|
||||||
Bytes.toStringBinary(this.comparator.getValue()));
|
Bytes.toStringBinary(this.comparator.getValue()));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof CompareFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
CompareFilter f = (CompareFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.getComparator(), this.getCompareOperator());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -22,6 +22,7 @@ import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.HashSet;
|
import java.util.HashSet;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
|
@ -311,4 +312,19 @@ public class DependentColumnFilter extends CompareFilter {
|
||||||
this.op.name(),
|
this.op.name(),
|
||||||
this.comparator != null ? Bytes.toStringBinary(this.comparator.getValue()) : "null");
|
this.comparator != null ? Bytes.toStringBinary(this.comparator.getValue()) : "null");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof DependentColumnFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
DependentColumnFilter f = (DependentColumnFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(Bytes.hashCode(this.getFamily()), Bytes.hashCode(this.getQualifier()),
|
||||||
|
this.dropDependentColumn());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CompareOperator;
|
import org.apache.hadoop.hbase.CompareOperator;
|
||||||
|
@ -146,4 +147,18 @@ public class FamilyFilter extends CompareFilter {
|
||||||
FamilyFilter other = (FamilyFilter)o;
|
FamilyFilter other = (FamilyFilter)o;
|
||||||
return super.areSerializedFieldsEqual(other);
|
return super.areSerializedFieldsEqual(other);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof FamilyFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
FamilyFilter f = (FamilyFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.getComparator(), this.getCompareOperator());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -23,6 +23,7 @@ import java.util.ArrayList;
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.yetus.audience.InterfaceAudience;
|
import org.apache.yetus.audience.InterfaceAudience;
|
||||||
|
@ -276,4 +277,17 @@ final public class FilterList extends FilterBase {
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return this.filterListBase.toString();
|
return this.filterListBase.toString();
|
||||||
}
|
}
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof FilterList))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
FilterList f = (FilterList) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.getOperator(), Arrays.hashCode(this.getFilters().toArray()));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -24,8 +24,10 @@ import org.apache.yetus.audience.InterfaceAudience;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Arrays;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* FilterListWithAND represents an ordered list of filters which will be evaluated with an AND
|
* FilterListWithAND represents an ordered list of filters which will be evaluated with an AND
|
||||||
|
@ -279,4 +281,21 @@ public class FilterListWithAND extends FilterListBase {
|
||||||
}
|
}
|
||||||
return maxHint;
|
return maxHint;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof FilterListWithAND))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if (this == obj) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
FilterListWithAND f = (FilterListWithAND) obj;
|
||||||
|
return this.filters.equals(f.getFilters()) && this.seekHintFilters.equals(f.seekHintFilters);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.seekHintFilters, Arrays.hashCode(this.filters.toArray()));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -25,8 +25,10 @@ import org.apache.yetus.audience.InterfaceAudience;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Arrays;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* FilterListWithOR represents an ordered list of filters which will be evaluated with an OR
|
* FilterListWithOR represents an ordered list of filters which will be evaluated with an OR
|
||||||
|
@ -393,4 +395,25 @@ public class FilterListWithOR extends FilterListBase {
|
||||||
}
|
}
|
||||||
return minKeyHint;
|
return minKeyHint;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof FilterListWithOR))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if (this == obj) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
FilterListWithOR f = (FilterListWithOR) obj;
|
||||||
|
return this.filters.equals(f.getFilters()) &&
|
||||||
|
this.prevFilterRCList.equals(f.prevFilterRCList) &&
|
||||||
|
this.prevCellList.equals(f.prevCellList);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(Arrays.hashCode(this.prevFilterRCList.toArray()),
|
||||||
|
Arrays.hashCode(this.prevCellList.toArray()), Arrays.hashCode(this.filters.toArray()));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -18,6 +18,7 @@
|
||||||
|
|
||||||
package org.apache.hadoop.hbase.filter;
|
package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
|
import java.util.Objects;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
import java.util.TreeSet;
|
import java.util.TreeSet;
|
||||||
|
|
||||||
|
@ -133,4 +134,18 @@ public class FirstKeyValueMatchingQualifiersFilter extends FirstKeyOnlyFilter {
|
||||||
FirstKeyValueMatchingQualifiersFilter other = (FirstKeyValueMatchingQualifiersFilter)o;
|
FirstKeyValueMatchingQualifiersFilter other = (FirstKeyValueMatchingQualifiersFilter)o;
|
||||||
return this.qualifiers.equals(other.qualifiers);
|
return this.qualifiers.equals(other.qualifiers);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof FirstKeyValueMatchingQualifiersFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
FirstKeyValueMatchingQualifiersFilter f = (FirstKeyValueMatchingQualifiersFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.qualifiers);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -21,6 +21,7 @@ import java.util.ArrayList;
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.Comparator;
|
import java.util.Comparator;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
import java.util.PriorityQueue;
|
import java.util.PriorityQueue;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
|
@ -645,4 +646,18 @@ public class FuzzyRowFilter extends FilterBase {
|
||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof FuzzyRowFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
FuzzyRowFilter f = (FuzzyRowFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.fuzzyKeysData.toArray());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -20,6 +20,7 @@
|
||||||
package org.apache.hadoop.hbase.filter;
|
package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CellComparator;
|
import org.apache.hadoop.hbase.CellComparator;
|
||||||
|
@ -131,4 +132,18 @@ public class InclusiveStopFilter extends FilterBase {
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return this.getClass().getSimpleName() + " " + Bytes.toStringBinary(this.stopRowKey);
|
return this.getClass().getSimpleName() + " " + Bytes.toStringBinary(this.stopRowKey);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof InclusiveStopFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
InclusiveStopFilter f = (InclusiveStopFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(Bytes.hashCode(this.stopRowKey));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -23,7 +23,9 @@ import java.nio.ByteBuffer;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.Iterator;
|
import java.util.Iterator;
|
||||||
|
import java.util.Objects;
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.ByteBufferExtendedCell;
|
import org.apache.hadoop.hbase.ByteBufferExtendedCell;
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.HConstants;
|
import org.apache.hadoop.hbase.HConstants;
|
||||||
|
@ -133,6 +135,20 @@ public class KeyOnlyFilter extends FilterBase {
|
||||||
return this.lenAsVal == other.lenAsVal;
|
return this.lenAsVal == other.lenAsVal;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof KeyOnlyFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
KeyOnlyFilter f = (KeyOnlyFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.lenAsVal);
|
||||||
|
}
|
||||||
|
|
||||||
static class KeyOnlyCell implements Cell {
|
static class KeyOnlyCell implements Cell {
|
||||||
private Cell cell;
|
private Cell cell;
|
||||||
private boolean lenAsVal;
|
private boolean lenAsVal;
|
||||||
|
|
|
@ -20,6 +20,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CellUtil;
|
import org.apache.hadoop.hbase.CellUtil;
|
||||||
|
@ -512,5 +513,42 @@ public class MultiRowRangeFilter extends FilterBase {
|
||||||
|| Bytes.compareTo(startRow, stopRow) < 0
|
|| Bytes.compareTo(startRow, stopRow) < 0
|
||||||
|| (Bytes.compareTo(startRow, stopRow) == 0 && stopRowInclusive == true);
|
|| (Bytes.compareTo(startRow, stopRow) == 0 && stopRowInclusive == true);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj){
|
||||||
|
if (obj == null || (!(obj instanceof RowRange))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if (this == obj) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
RowRange rr = (RowRange) obj;
|
||||||
|
return Bytes.equals(this.stopRow, rr.getStopRow()) &&
|
||||||
|
Bytes.equals(this.startRow, this.getStartRow()) &&
|
||||||
|
this.startRowInclusive == rr.isStartRowInclusive() &&
|
||||||
|
this.stopRowInclusive == rr.isStopRowInclusive();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(Bytes.hashCode(this.stopRow),
|
||||||
|
Bytes.hashCode(this.startRow),
|
||||||
|
this.startRowInclusive,
|
||||||
|
this.stopRowInclusive);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof MultiRowRangeFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
MultiRowRangeFilter f = (MultiRowRangeFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.rangeList.toArray());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -19,7 +19,9 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Arrays;
|
||||||
import java.util.Comparator;
|
import java.util.Comparator;
|
||||||
|
import java.util.Objects;
|
||||||
import java.util.TreeSet;
|
import java.util.TreeSet;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
|
@ -207,4 +209,18 @@ public class MultipleColumnPrefixFilter extends FilterBase {
|
||||||
return String.format("%s (%d/%d): [%s]", this.getClass().getSimpleName(),
|
return String.format("%s (%d/%d): [%s]", this.getClass().getSimpleName(),
|
||||||
count, this.sortedPrefixes.size(), prefixes.toString());
|
count, this.sortedPrefixes.size(), prefixes.toString());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof MultipleColumnPrefixFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
MultipleColumnPrefixFilter f = (MultipleColumnPrefixFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(Arrays.hashCode(this.sortedPrefixes.toArray()));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -20,6 +20,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.exceptions.DeserializationException;
|
import org.apache.hadoop.hbase.exceptions.DeserializationException;
|
||||||
|
@ -150,4 +151,18 @@ public class PageFilter extends FilterBase {
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return this.getClass().getSimpleName() + " " + this.pageSize;
|
return this.getClass().getSimpleName() + " " + this.pageSize;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof PageFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
PageFilter f = (PageFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.pageSize);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -20,6 +20,7 @@
|
||||||
package org.apache.hadoop.hbase.filter;
|
package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.ByteBufferExtendedCell;
|
import org.apache.hadoop.hbase.ByteBufferExtendedCell;
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
|
@ -156,4 +157,18 @@ public class PrefixFilter extends FilterBase {
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return this.getClass().getSimpleName() + " " + Bytes.toStringBinary(this.prefix);
|
return this.getClass().getSimpleName() + " " + Bytes.toStringBinary(this.prefix);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof PrefixFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
PrefixFilter f = (PrefixFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(Bytes.hashCode(this.getPrefix()));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CompareOperator;
|
import org.apache.hadoop.hbase.CompareOperator;
|
||||||
|
@ -140,4 +141,18 @@ public class QualifierFilter extends CompareFilter {
|
||||||
|
|
||||||
return super.areSerializedFieldsEqual(o);
|
return super.areSerializedFieldsEqual(o);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof QualifierFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
QualifierFilter f = (QualifierFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.getComparator(), this.getCompareOperator());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -19,6 +19,7 @@
|
||||||
|
|
||||||
package org.apache.hadoop.hbase.filter;
|
package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
|
import java.util.Objects;
|
||||||
import java.util.Random;
|
import java.util.Random;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
|
@ -154,4 +155,18 @@ public class RandomRowFilter extends FilterBase {
|
||||||
RandomRowFilter other = (RandomRowFilter)o;
|
RandomRowFilter other = (RandomRowFilter)o;
|
||||||
return this.getChance() == other.getChance();
|
return this.getChance() == other.getChance();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof RandomRowFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
RandomRowFilter f = (RandomRowFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.getChance());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CompareOperator;
|
import org.apache.hadoop.hbase.CompareOperator;
|
||||||
|
@ -160,4 +161,18 @@ public class RowFilter extends CompareFilter {
|
||||||
|
|
||||||
return super.areSerializedFieldsEqual(o);
|
return super.areSerializedFieldsEqual(o);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof RowFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
RowFilter f = (RowFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.getComparator(), this.getCompareOperator());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CellUtil;
|
import org.apache.hadoop.hbase.CellUtil;
|
||||||
|
@ -460,4 +461,19 @@ public class SingleColumnValueFilter extends FilterBase {
|
||||||
Bytes.toStringBinary(this.columnQualifier), this.op.name(),
|
Bytes.toStringBinary(this.columnQualifier), this.op.name(),
|
||||||
Bytes.toStringBinary(this.comparator.getValue()));
|
Bytes.toStringBinary(this.comparator.getValue()));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(SingleColumnValueFilter.class.isInstance(obj)))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
SingleColumnValueFilter f = (SingleColumnValueFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(Bytes.hashCode(this.getFamily()), Bytes.hashCode(this.getQualifier()),
|
||||||
|
this.op, this.getComparator(), this.getFilterIfMissing(), this.getLatestVersionOnly());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -20,6 +20,7 @@
|
||||||
package org.apache.hadoop.hbase.filter;
|
package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.yetus.audience.InterfaceAudience;
|
import org.apache.yetus.audience.InterfaceAudience;
|
||||||
|
@ -161,4 +162,18 @@ public class SkipFilter extends FilterBase {
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return this.getClass().getSimpleName() + " " + this.filter.toString();
|
return this.getClass().getSimpleName() + " " + this.filter.toString();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj.getClass() == this.getClass()))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
SkipFilter f = (SkipFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.filter);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -20,6 +20,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
import java.util.TreeSet;
|
import java.util.TreeSet;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
|
@ -238,4 +239,18 @@ public class TimestampsFilter extends FilterBase {
|
||||||
return String.format("%s (%d/%d): [%s] canHint: [%b]", this.getClass().getSimpleName(),
|
return String.format("%s (%d/%d): [%s] canHint: [%b]", this.getClass().getSimpleName(),
|
||||||
count, this.timestamps.size(), tsList.toString(), canHint);
|
count, this.timestamps.size(), tsList.toString(), canHint);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof TimestampsFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
TimestampsFilter f = (TimestampsFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.getTimestamps().toArray());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CompareOperator;
|
import org.apache.hadoop.hbase.CompareOperator;
|
||||||
|
@ -139,4 +140,18 @@ public class ValueFilter extends CompareFilter {
|
||||||
|
|
||||||
return super.areSerializedFieldsEqual(o);
|
return super.areSerializedFieldsEqual(o);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj instanceof ValueFilter))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
ValueFilter f = (ValueFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.getComparator(), this.getCompareOperator());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -20,6 +20,7 @@
|
||||||
package org.apache.hadoop.hbase.filter;
|
package org.apache.hadoop.hbase.filter;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.yetus.audience.InterfaceAudience;
|
import org.apache.yetus.audience.InterfaceAudience;
|
||||||
|
@ -163,4 +164,18 @@ public class WhileMatchFilter extends FilterBase {
|
||||||
public String toString() {
|
public String toString() {
|
||||||
return this.getClass().getSimpleName() + " " + this.filter.toString();
|
return this.getClass().getSimpleName() + " " + this.filter.toString();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj.getClass() == this.getClass()))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
WhileMatchFilter f = (WhileMatchFilter) obj;
|
||||||
|
return this.areSerializedFieldsEqual(f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.filter);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -20,6 +20,7 @@ package org.apache.hadoop.hbase.security.access;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.yetus.audience.InterfaceAudience;
|
import org.apache.yetus.audience.InterfaceAudience;
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
|
@ -173,4 +174,26 @@ class AccessControlFilter extends FilterBase {
|
||||||
throw new UnsupportedOperationException(
|
throw new UnsupportedOperationException(
|
||||||
"Serialization not supported. Intended for server-side use only.");
|
"Serialization not supported. Intended for server-side use only.");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj.getClass() == this.getClass()))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if(this == obj){
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
AccessControlFilter f=(AccessControlFilter)obj;
|
||||||
|
return this.authManager.equals(f.authManager) &&
|
||||||
|
this.table.equals(f.table) &&
|
||||||
|
this.user.equals(f.user) &&
|
||||||
|
this.strategy.equals(f.strategy) &&
|
||||||
|
this.cfVsMaxVersions.equals(f.cfVsMaxVersions);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.authManager, this.table, this.strategy, this.user,
|
||||||
|
this.cfVsMaxVersions);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -1038,6 +1038,23 @@ public class VisibilityController implements MasterCoprocessor, RegionCoprocesso
|
||||||
deleteCellVisTagsFormat);
|
deleteCellVisTagsFormat);
|
||||||
return matchFound ? ReturnCode.INCLUDE : ReturnCode.SKIP;
|
return matchFound ? ReturnCode.INCLUDE : ReturnCode.SKIP;
|
||||||
}
|
}
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj.getClass() == this.getClass()))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if(this == obj){
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
DeleteVersionVisibilityExpressionFilter f = (DeleteVersionVisibilityExpressionFilter)obj;
|
||||||
|
return this.deleteCellVisTags.equals(f.deleteCellVisTags) &&
|
||||||
|
this.deleteCellVisTagsFormat.equals(f.deleteCellVisTagsFormat);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.deleteCellVisTags, this.deleteCellVisTagsFormat);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -19,6 +19,7 @@ package org.apache.hadoop.hbase.security.visibility;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.yetus.audience.InterfaceAudience;
|
import org.apache.yetus.audience.InterfaceAudience;
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
|
@ -90,4 +91,21 @@ class VisibilityLabelFilter extends FilterBase {
|
||||||
this.curFamilyMaxVersions = 0;
|
this.curFamilyMaxVersions = 0;
|
||||||
this.curQualMetVersions = 0;
|
this.curQualMetVersions = 0;
|
||||||
}
|
}
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj.getClass() == this.getClass()))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if(this == obj){
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
VisibilityLabelFilter f = (VisibilityLabelFilter)obj;
|
||||||
|
return this.expEvaluator.equals(f.expEvaluator) &&
|
||||||
|
this.cfVsMaxVersions.equals(f.cfVsMaxVersions);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.expEvaluator, this.cfVsMaxVersions);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -18,6 +18,7 @@
|
||||||
package org.apache.hadoop.hbase.client;
|
package org.apache.hadoop.hbase.client;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.yetus.audience.InterfaceAudience;
|
import org.apache.yetus.audience.InterfaceAudience;
|
||||||
|
@ -55,4 +56,21 @@ public final class ColumnCountOnRowFilter extends FilterBase {
|
||||||
public static ColumnCountOnRowFilter parseFrom(byte[] bytes) throws DeserializationException {
|
public static ColumnCountOnRowFilter parseFrom(byte[] bytes) throws DeserializationException {
|
||||||
return new ColumnCountOnRowFilter(Bytes.toInt(bytes));
|
return new ColumnCountOnRowFilter(Bytes.toInt(bytes));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if (obj == null || (!(obj.getClass() == this.getClass()))) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if (this == obj) {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
ColumnCountOnRowFilter f = (ColumnCountOnRowFilter) obj;
|
||||||
|
return this.limit == f.limit;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.limit);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -25,6 +25,7 @@ import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CellComparator;
|
import org.apache.hadoop.hbase.CellComparator;
|
||||||
import org.apache.hadoop.hbase.CellUtil;
|
import org.apache.hadoop.hbase.CellUtil;
|
||||||
|
|
|
@ -27,6 +27,8 @@ import java.io.IOException;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import org.apache.hadoop.hbase.Cell;
|
import org.apache.hadoop.hbase.Cell;
|
||||||
import org.apache.hadoop.hbase.CellComparator;
|
import org.apache.hadoop.hbase.CellComparator;
|
||||||
import org.apache.hadoop.hbase.CompareOperator;
|
import org.apache.hadoop.hbase.CompareOperator;
|
||||||
|
@ -648,6 +650,23 @@ public class TestFilterList {
|
||||||
this.didCellPassToTheFilter = true;
|
this.didCellPassToTheFilter = true;
|
||||||
return targetRetCode;
|
return targetRetCode;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if(obj == null || !(obj instanceof MockFilter)){
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if(obj == this){
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
MockFilter f = (MockFilter)obj;
|
||||||
|
return this.targetRetCode.equals(f.targetRetCode);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.targetRetCode);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
|
@ -820,6 +839,23 @@ public class TestFilterList {
|
||||||
public Cell getNextCellHint(Cell currentCell) throws IOException {
|
public Cell getNextCellHint(Cell currentCell) throws IOException {
|
||||||
return this.returnCell;
|
return this.returnCell;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if(obj == null || !(obj instanceof MockSeekHintFilter)){
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if(obj == this){
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
MockSeekHintFilter f = (MockSeekHintFilter)obj;
|
||||||
|
return this.returnCell.equals(f.returnCell);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.returnCell);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
|
@ -989,6 +1025,23 @@ public class TestFilterList {
|
||||||
public boolean getTransformed() {
|
public boolean getTransformed() {
|
||||||
return this.transformed;
|
return this.transformed;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean equals(Object obj) {
|
||||||
|
if(obj == null || !(obj instanceof TransformFilter)){
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
if(obj == this){
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
TransformFilter f = (TransformFilter)obj;
|
||||||
|
return this.targetRetCode.equals(f.targetRetCode);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int hashCode() {
|
||||||
|
return Objects.hash(this.targetRetCode);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
|
|
Loading…
Reference in New Issue