[02/10] hbase git commit: HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue
HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue Signed-off-by: zhangduoProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/15eae6ac Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/15eae6ac Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/15eae6ac Branch: refs/heads/branch-2 Commit: 15eae6ac3592979804a798a035af3d1efa3b76c0 Parents: 47d8549 Author: huzheng Authored: Thu Jun 8 15:58:42 2017 +0800 Committer: zhangduo Committed: Wed Oct 25 20:41:24 2017 +0800 -- .../apache/hadoop/hbase/filter/FilterList.java | 541 --- .../hadoop/hbase/filter/TestFilterList.java | 148 - 2 files changed, 471 insertions(+), 218 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/15eae6ac/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java index 3ff978d..3147ab0 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java @@ -90,62 +90,53 @@ final public class FilterList extends FilterBase { private Cell transformedCell = null; /** - * Constructor that takes a set of {@link Filter}s. The default operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a set of {@link Filter}s and an operator. + * @param operator Operator to process filter set with. + * @param rowFilters Set of row filters. + */ + public FilterList(final Operator operator, final List rowFilters) { +reversed = checkAndGetReversed(rowFilters, reversed); +this.filters = new ArrayList<>(rowFilters); +this.operator = operator; +initPrevListForMustPassOne(rowFilters.size()); + } + + /** + * Constructor that takes a set of {@link Filter}s. The default operator MUST_PASS_ALL is assumed. * All filters are cloned to internal list. * @param rowFilters list of filters */ public FilterList(final List rowFilters) { -reversed = getReversed(rowFilters, reversed); -this.filters = new ArrayList<>(rowFilters); -initPrevListForMustPassOne(rowFilters.size()); +this(Operator.MUST_PASS_ALL, rowFilters); } /** - * Constructor that takes a var arg number of {@link Filter}s. The fefault operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a var arg number of {@link Filter}s. The default operator MUST_PASS_ALL + * is assumed. * @param rowFilters */ public FilterList(final Filter... rowFilters) { -this(Arrays.asList(rowFilters)); +this(Operator.MUST_PASS_ALL, Arrays.asList(rowFilters)); } /** * Constructor that takes an operator. - * * @param operator Operator to process filter set with. */ public FilterList(final Operator operator) { -this.operator = operator; -this.filters = new ArrayList<>(); -initPrevListForMustPassOne(filters.size()); - } - - /** - * Constructor that takes a set of {@link Filter}s and an operator. - * - * @param operator Operator to process filter set with. - * @param rowFilters Set of row filters. - */ - public FilterList(final Operator operator, final List rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.size()); +this(operator, new ArrayList<>()); } /** * Constructor that takes a var arg number of {@link Filter}s and an operator. - * * @param operator Operator to process filter set with. * @param rowFilters Filters to use */ public FilterList(final Operator operator, final Filter... rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.length); +this(operator, Arrays.asList(rowFilters)); } - public void initPrevListForMustPassOne(int size) { + private void initPrevListForMustPassOne(int size) { if (operator == Operator.MUST_PASS_ONE) { if (this.prevFilterRCList == null) { prevFilterRCList = new ArrayList<>(Collections.nCopies(size, null)); @@ -156,10 +147,8 @@ final public class FilterList extends FilterBase { } } - /** * Get the operator. - * * @return operator */ public Operator getOperator() { @@ -168,7 +157,6 @@ final public class FilterList extends FilterBase { /** * Get the filters. - * * @return filters */ public List getFilters() { @@ -183,33 +171,22 @@ final public class FilterList extends FilterBase { return filters.isEmpty(); } - private
[06/10] hbase git commit: HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue
HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue Signed-off-by: zhangduoProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/a811fb41 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/a811fb41 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/a811fb41 Branch: refs/heads/master Commit: a811fb410df2685253d49bcca9b4200beb279712 Parents: 1061225 Author: huzheng Authored: Thu Jun 8 15:58:42 2017 +0800 Committer: zhangduo Committed: Wed Oct 25 20:36:19 2017 +0800 -- .../apache/hadoop/hbase/filter/FilterList.java | 541 --- .../hadoop/hbase/filter/TestFilterList.java | 148 - 2 files changed, 471 insertions(+), 218 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/a811fb41/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java index 3ff978d..3147ab0 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java @@ -90,62 +90,53 @@ final public class FilterList extends FilterBase { private Cell transformedCell = null; /** - * Constructor that takes a set of {@link Filter}s. The default operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a set of {@link Filter}s and an operator. + * @param operator Operator to process filter set with. + * @param rowFilters Set of row filters. + */ + public FilterList(final Operator operator, final List rowFilters) { +reversed = checkAndGetReversed(rowFilters, reversed); +this.filters = new ArrayList<>(rowFilters); +this.operator = operator; +initPrevListForMustPassOne(rowFilters.size()); + } + + /** + * Constructor that takes a set of {@link Filter}s. The default operator MUST_PASS_ALL is assumed. * All filters are cloned to internal list. * @param rowFilters list of filters */ public FilterList(final List rowFilters) { -reversed = getReversed(rowFilters, reversed); -this.filters = new ArrayList<>(rowFilters); -initPrevListForMustPassOne(rowFilters.size()); +this(Operator.MUST_PASS_ALL, rowFilters); } /** - * Constructor that takes a var arg number of {@link Filter}s. The fefault operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a var arg number of {@link Filter}s. The default operator MUST_PASS_ALL + * is assumed. * @param rowFilters */ public FilterList(final Filter... rowFilters) { -this(Arrays.asList(rowFilters)); +this(Operator.MUST_PASS_ALL, Arrays.asList(rowFilters)); } /** * Constructor that takes an operator. - * * @param operator Operator to process filter set with. */ public FilterList(final Operator operator) { -this.operator = operator; -this.filters = new ArrayList<>(); -initPrevListForMustPassOne(filters.size()); - } - - /** - * Constructor that takes a set of {@link Filter}s and an operator. - * - * @param operator Operator to process filter set with. - * @param rowFilters Set of row filters. - */ - public FilterList(final Operator operator, final List rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.size()); +this(operator, new ArrayList<>()); } /** * Constructor that takes a var arg number of {@link Filter}s and an operator. - * * @param operator Operator to process filter set with. * @param rowFilters Filters to use */ public FilterList(final Operator operator, final Filter... rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.length); +this(operator, Arrays.asList(rowFilters)); } - public void initPrevListForMustPassOne(int size) { + private void initPrevListForMustPassOne(int size) { if (operator == Operator.MUST_PASS_ONE) { if (this.prevFilterRCList == null) { prevFilterRCList = new ArrayList<>(Collections.nCopies(size, null)); @@ -156,10 +147,8 @@ final public class FilterList extends FilterBase { } } - /** * Get the operator. - * * @return operator */ public Operator getOperator() { @@ -168,7 +157,6 @@ final public class FilterList extends FilterBase { /** * Get the filters. - * * @return filters */ public List getFilters() { @@ -183,33 +171,22 @@ final public class FilterList extends FilterBase { return filters.isEmpty(); } - private
[19/23] hbase git commit: HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue
HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue Signed-off-by: zhangduoProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/a811fb41 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/a811fb41 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/a811fb41 Branch: refs/heads/HBASE-18410 Commit: a811fb410df2685253d49bcca9b4200beb279712 Parents: 1061225 Author: huzheng Authored: Thu Jun 8 15:58:42 2017 +0800 Committer: zhangduo Committed: Wed Oct 25 20:36:19 2017 +0800 -- .../apache/hadoop/hbase/filter/FilterList.java | 541 --- .../hadoop/hbase/filter/TestFilterList.java | 148 - 2 files changed, 471 insertions(+), 218 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/a811fb41/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java index 3ff978d..3147ab0 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java @@ -90,62 +90,53 @@ final public class FilterList extends FilterBase { private Cell transformedCell = null; /** - * Constructor that takes a set of {@link Filter}s. The default operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a set of {@link Filter}s and an operator. + * @param operator Operator to process filter set with. + * @param rowFilters Set of row filters. + */ + public FilterList(final Operator operator, final List rowFilters) { +reversed = checkAndGetReversed(rowFilters, reversed); +this.filters = new ArrayList<>(rowFilters); +this.operator = operator; +initPrevListForMustPassOne(rowFilters.size()); + } + + /** + * Constructor that takes a set of {@link Filter}s. The default operator MUST_PASS_ALL is assumed. * All filters are cloned to internal list. * @param rowFilters list of filters */ public FilterList(final List rowFilters) { -reversed = getReversed(rowFilters, reversed); -this.filters = new ArrayList<>(rowFilters); -initPrevListForMustPassOne(rowFilters.size()); +this(Operator.MUST_PASS_ALL, rowFilters); } /** - * Constructor that takes a var arg number of {@link Filter}s. The fefault operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a var arg number of {@link Filter}s. The default operator MUST_PASS_ALL + * is assumed. * @param rowFilters */ public FilterList(final Filter... rowFilters) { -this(Arrays.asList(rowFilters)); +this(Operator.MUST_PASS_ALL, Arrays.asList(rowFilters)); } /** * Constructor that takes an operator. - * * @param operator Operator to process filter set with. */ public FilterList(final Operator operator) { -this.operator = operator; -this.filters = new ArrayList<>(); -initPrevListForMustPassOne(filters.size()); - } - - /** - * Constructor that takes a set of {@link Filter}s and an operator. - * - * @param operator Operator to process filter set with. - * @param rowFilters Set of row filters. - */ - public FilterList(final Operator operator, final List rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.size()); +this(operator, new ArrayList<>()); } /** * Constructor that takes a var arg number of {@link Filter}s and an operator. - * * @param operator Operator to process filter set with. * @param rowFilters Filters to use */ public FilterList(final Operator operator, final Filter... rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.length); +this(operator, Arrays.asList(rowFilters)); } - public void initPrevListForMustPassOne(int size) { + private void initPrevListForMustPassOne(int size) { if (operator == Operator.MUST_PASS_ONE) { if (this.prevFilterRCList == null) { prevFilterRCList = new ArrayList<>(Collections.nCopies(size, null)); @@ -156,10 +147,8 @@ final public class FilterList extends FilterBase { } } - /** * Get the operator. - * * @return operator */ public Operator getOperator() { @@ -168,7 +157,6 @@ final public class FilterList extends FilterBase { /** * Get the filters. - * * @return filters */ public List getFilters() { @@ -183,33 +171,22 @@ final public class FilterList extends FilterBase { return filters.isEmpty(); } - private
[17/21] hbase git commit: HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue
HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue Signed-off-by: zhangduoProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/9be96049 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/9be96049 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/9be96049 Branch: refs/heads/HBASE-18410 Commit: 9be960493e40ef1bd310fc7ff936e08cffc2cf80 Parents: 57c1a84 Author: huzheng Authored: Thu Jun 8 15:58:42 2017 +0800 Committer: zhangduo Committed: Wed Oct 25 20:27:16 2017 +0800 -- .../apache/hadoop/hbase/filter/FilterList.java | 541 --- .../hadoop/hbase/filter/TestFilterList.java | 148 - 2 files changed, 471 insertions(+), 218 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/9be96049/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java index 3ff978d..3147ab0 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java @@ -90,62 +90,53 @@ final public class FilterList extends FilterBase { private Cell transformedCell = null; /** - * Constructor that takes a set of {@link Filter}s. The default operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a set of {@link Filter}s and an operator. + * @param operator Operator to process filter set with. + * @param rowFilters Set of row filters. + */ + public FilterList(final Operator operator, final List rowFilters) { +reversed = checkAndGetReversed(rowFilters, reversed); +this.filters = new ArrayList<>(rowFilters); +this.operator = operator; +initPrevListForMustPassOne(rowFilters.size()); + } + + /** + * Constructor that takes a set of {@link Filter}s. The default operator MUST_PASS_ALL is assumed. * All filters are cloned to internal list. * @param rowFilters list of filters */ public FilterList(final List rowFilters) { -reversed = getReversed(rowFilters, reversed); -this.filters = new ArrayList<>(rowFilters); -initPrevListForMustPassOne(rowFilters.size()); +this(Operator.MUST_PASS_ALL, rowFilters); } /** - * Constructor that takes a var arg number of {@link Filter}s. The fefault operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a var arg number of {@link Filter}s. The default operator MUST_PASS_ALL + * is assumed. * @param rowFilters */ public FilterList(final Filter... rowFilters) { -this(Arrays.asList(rowFilters)); +this(Operator.MUST_PASS_ALL, Arrays.asList(rowFilters)); } /** * Constructor that takes an operator. - * * @param operator Operator to process filter set with. */ public FilterList(final Operator operator) { -this.operator = operator; -this.filters = new ArrayList<>(); -initPrevListForMustPassOne(filters.size()); - } - - /** - * Constructor that takes a set of {@link Filter}s and an operator. - * - * @param operator Operator to process filter set with. - * @param rowFilters Set of row filters. - */ - public FilterList(final Operator operator, final List rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.size()); +this(operator, new ArrayList<>()); } /** * Constructor that takes a var arg number of {@link Filter}s and an operator. - * * @param operator Operator to process filter set with. * @param rowFilters Filters to use */ public FilterList(final Operator operator, final Filter... rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.length); +this(operator, Arrays.asList(rowFilters)); } - public void initPrevListForMustPassOne(int size) { + private void initPrevListForMustPassOne(int size) { if (operator == Operator.MUST_PASS_ONE) { if (this.prevFilterRCList == null) { prevFilterRCList = new ArrayList<>(Collections.nCopies(size, null)); @@ -156,10 +147,8 @@ final public class FilterList extends FilterBase { } } - /** * Get the operator. - * * @return operator */ public Operator getOperator() { @@ -168,7 +157,6 @@ final public class FilterList extends FilterBase { /** * Get the filters. - * * @return filters */ public List getFilters() { @@ -183,33 +171,22 @@ final public class FilterList extends FilterBase { return filters.isEmpty(); } - private
[47/50] [abbrv] hbase git commit: HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue
HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue Signed-off-by: zhangduoProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/24a7ce84 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/24a7ce84 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/24a7ce84 Branch: refs/heads/HBASE-18410 Commit: 24a7ce849f0e951ba0a84337681033c541d46276 Parents: 5c9523b Author: huzheng Authored: Thu Jun 8 15:58:42 2017 +0800 Committer: zhangduo Committed: Tue Oct 24 11:37:45 2017 +0800 -- .../apache/hadoop/hbase/filter/FilterList.java | 541 --- .../hadoop/hbase/filter/TestFilterList.java | 148 - 2 files changed, 471 insertions(+), 218 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/24a7ce84/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java index 3ff978d..3147ab0 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java @@ -90,62 +90,53 @@ final public class FilterList extends FilterBase { private Cell transformedCell = null; /** - * Constructor that takes a set of {@link Filter}s. The default operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a set of {@link Filter}s and an operator. + * @param operator Operator to process filter set with. + * @param rowFilters Set of row filters. + */ + public FilterList(final Operator operator, final List rowFilters) { +reversed = checkAndGetReversed(rowFilters, reversed); +this.filters = new ArrayList<>(rowFilters); +this.operator = operator; +initPrevListForMustPassOne(rowFilters.size()); + } + + /** + * Constructor that takes a set of {@link Filter}s. The default operator MUST_PASS_ALL is assumed. * All filters are cloned to internal list. * @param rowFilters list of filters */ public FilterList(final List rowFilters) { -reversed = getReversed(rowFilters, reversed); -this.filters = new ArrayList<>(rowFilters); -initPrevListForMustPassOne(rowFilters.size()); +this(Operator.MUST_PASS_ALL, rowFilters); } /** - * Constructor that takes a var arg number of {@link Filter}s. The fefault operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a var arg number of {@link Filter}s. The default operator MUST_PASS_ALL + * is assumed. * @param rowFilters */ public FilterList(final Filter... rowFilters) { -this(Arrays.asList(rowFilters)); +this(Operator.MUST_PASS_ALL, Arrays.asList(rowFilters)); } /** * Constructor that takes an operator. - * * @param operator Operator to process filter set with. */ public FilterList(final Operator operator) { -this.operator = operator; -this.filters = new ArrayList<>(); -initPrevListForMustPassOne(filters.size()); - } - - /** - * Constructor that takes a set of {@link Filter}s and an operator. - * - * @param operator Operator to process filter set with. - * @param rowFilters Set of row filters. - */ - public FilterList(final Operator operator, final List rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.size()); +this(operator, new ArrayList<>()); } /** * Constructor that takes a var arg number of {@link Filter}s and an operator. - * * @param operator Operator to process filter set with. * @param rowFilters Filters to use */ public FilterList(final Operator operator, final Filter... rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.length); +this(operator, Arrays.asList(rowFilters)); } - public void initPrevListForMustPassOne(int size) { + private void initPrevListForMustPassOne(int size) { if (operator == Operator.MUST_PASS_ONE) { if (this.prevFilterRCList == null) { prevFilterRCList = new ArrayList<>(Collections.nCopies(size, null)); @@ -156,10 +147,8 @@ final public class FilterList extends FilterBase { } } - /** * Get the operator. - * * @return operator */ public Operator getOperator() { @@ -168,7 +157,6 @@ final public class FilterList extends FilterBase { /** * Get the filters. - * * @return filters */ public List getFilters() { @@ -183,33 +171,22 @@ final public class FilterList extends FilterBase { return filters.isEmpty(); } - private
[5/6] hbase git commit: HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue
HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue Signed-off-by: zhangduoProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/fd0e0e91 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/fd0e0e91 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/fd0e0e91 Branch: refs/heads/HBASE-18410 Commit: fd0e0e91b7d875fe2c22ebc3ba704cc7f84aa6c7 Parents: 5119d60 Author: huzheng Authored: Thu Jun 8 15:58:42 2017 +0800 Committer: Sean Busbey Committed: Mon Oct 9 23:03:22 2017 -0500 -- .../apache/hadoop/hbase/filter/FilterList.java | 542 --- .../hadoop/hbase/filter/TestFilterList.java | 146 +++-- 2 files changed, 469 insertions(+), 219 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/fd0e0e91/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java index cd51648..961c991 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java @@ -90,62 +90,53 @@ final public class FilterList extends FilterBase { private Cell transformedCell = null; /** - * Constructor that takes a set of {@link Filter}s. The default operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a set of {@link Filter}s and an operator. + * @param operator Operator to process filter set with. + * @param rowFilters Set of row filters. + */ + public FilterList(final Operator operator, final List rowFilters) { +reversed = checkAndGetReversed(rowFilters, reversed); +this.filters = new ArrayList<>(rowFilters); +this.operator = operator; +initPrevListForMustPassOne(rowFilters.size()); + } + + /** + * Constructor that takes a set of {@link Filter}s. The default operator MUST_PASS_ALL is assumed. * All filters are cloned to internal list. * @param rowFilters list of filters */ public FilterList(final List rowFilters) { -reversed = getReversed(rowFilters, reversed); -this.filters = new ArrayList<>(rowFilters); -initPrevListForMustPassOne(rowFilters.size()); +this(Operator.MUST_PASS_ALL, rowFilters); } /** - * Constructor that takes a var arg number of {@link Filter}s. The fefault operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a var arg number of {@link Filter}s. The default operator MUST_PASS_ALL + * is assumed. * @param rowFilters */ public FilterList(final Filter... rowFilters) { -this(Arrays.asList(rowFilters)); +this(Operator.MUST_PASS_ALL, Arrays.asList(rowFilters)); } /** * Constructor that takes an operator. - * * @param operator Operator to process filter set with. */ public FilterList(final Operator operator) { -this.operator = operator; -this.filters = new ArrayList<>(); -initPrevListForMustPassOne(filters.size()); - } - - /** - * Constructor that takes a set of {@link Filter}s and an operator. - * - * @param operator Operator to process filter set with. - * @param rowFilters Set of row filters. - */ - public FilterList(final Operator operator, final List rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.size()); +this(operator, new ArrayList<>()); } /** * Constructor that takes a var arg number of {@link Filter}s and an operator. - * * @param operator Operator to process filter set with. * @param rowFilters Filters to use */ public FilterList(final Operator operator, final Filter... rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.length); +this(operator, Arrays.asList(rowFilters)); } - public void initPrevListForMustPassOne(int size) { + private void initPrevListForMustPassOne(int size) { if (operator == Operator.MUST_PASS_ONE) { if (this.prevFilterRCList == null) { prevFilterRCList = new ArrayList<>(Collections.nCopies(size, null)); @@ -156,10 +147,8 @@ final public class FilterList extends FilterBase { } } - /** * Get the operator. - * * @return operator */ public Operator getOperator() { @@ -168,7 +157,6 @@ final public class FilterList extends FilterBase { /** * Get the filters. - * * @return filters */ public List getFilters() { @@ -183,33 +171,22 @@ final public class FilterList extends FilterBase { return filters.isEmpty(); } - private
hbase git commit: HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue
Repository: hbase Updated Branches: refs/heads/branch-2 3e1ceadc8 -> 7c2622baf HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue Signed-off-by: zhangduoProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/7c2622ba Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/7c2622ba Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/7c2622ba Branch: refs/heads/branch-2 Commit: 7c2622baf75ac414547488799216cdf2b37be7bd Parents: 3e1cead Author: huzheng Authored: Thu Jun 8 15:58:42 2017 +0800 Committer: zhangduo Committed: Tue Sep 26 11:23:38 2017 +0800 -- .../apache/hadoop/hbase/filter/FilterList.java | 542 --- .../hadoop/hbase/filter/TestFilterList.java | 146 +++-- 2 files changed, 469 insertions(+), 219 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/7c2622ba/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java index 1e80a7e..7f2405d 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java @@ -90,62 +90,53 @@ final public class FilterList extends FilterBase { private Cell transformedCell = null; /** - * Constructor that takes a set of {@link Filter}s. The default operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a set of {@link Filter}s and an operator. + * @param operator Operator to process filter set with. + * @param rowFilters Set of row filters. + */ + public FilterList(final Operator operator, final List rowFilters) { +reversed = checkAndGetReversed(rowFilters, reversed); +this.filters = new ArrayList<>(rowFilters); +this.operator = operator; +initPrevListForMustPassOne(rowFilters.size()); + } + + /** + * Constructor that takes a set of {@link Filter}s. The default operator MUST_PASS_ALL is assumed. * All filters are cloned to internal list. * @param rowFilters list of filters */ public FilterList(final List rowFilters) { -reversed = getReversed(rowFilters, reversed); -this.filters = new ArrayList<>(rowFilters); -initPrevListForMustPassOne(rowFilters.size()); +this(Operator.MUST_PASS_ALL, rowFilters); } /** - * Constructor that takes a var arg number of {@link Filter}s. The fefault operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a var arg number of {@link Filter}s. The default operator MUST_PASS_ALL + * is assumed. * @param rowFilters */ public FilterList(final Filter... rowFilters) { -this(Arrays.asList(rowFilters)); +this(Operator.MUST_PASS_ALL, Arrays.asList(rowFilters)); } /** * Constructor that takes an operator. - * * @param operator Operator to process filter set with. */ public FilterList(final Operator operator) { -this.operator = operator; -this.filters = new ArrayList<>(); -initPrevListForMustPassOne(filters.size()); - } - - /** - * Constructor that takes a set of {@link Filter}s and an operator. - * - * @param operator Operator to process filter set with. - * @param rowFilters Set of row filters. - */ - public FilterList(final Operator operator, final List rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.size()); +this(operator, new ArrayList<>()); } /** * Constructor that takes a var arg number of {@link Filter}s and an operator. - * * @param operator Operator to process filter set with. * @param rowFilters Filters to use */ public FilterList(final Operator operator, final Filter... rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.length); +this(operator, Arrays.asList(rowFilters)); } - public void initPrevListForMustPassOne(int size) { + private void initPrevListForMustPassOne(int size) { if (operator == Operator.MUST_PASS_ONE) { if (this.prevFilterRCList == null) { prevFilterRCList = new ArrayList<>(Collections.nCopies(size, null)); @@ -156,10 +147,8 @@ final public class FilterList extends FilterBase { } } - /** * Get the operator. - * * @return operator */ public Operator getOperator() { @@ -168,7 +157,6 @@ final public class FilterList extends FilterBase { /** * Get the filters. - * * @return filters */ public List getFilters() { @@ -183,33 +171,22 @@ final public class
hbase git commit: HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue
Repository: hbase Updated Branches: refs/heads/master 3c7ab8107 -> f54cc1ca5 HBASE-18160 Fix incorrect logic in FilterList.filterKeyValue Signed-off-by: zhangduoProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/f54cc1ca Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/f54cc1ca Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/f54cc1ca Branch: refs/heads/master Commit: f54cc1ca51440ee0f445a008f2f31697730fd7fe Parents: 3c7ab81 Author: huzheng Authored: Thu Jun 8 15:58:42 2017 +0800 Committer: zhangduo Committed: Tue Sep 26 11:46:01 2017 +0800 -- .../apache/hadoop/hbase/filter/FilterList.java | 542 --- .../hadoop/hbase/filter/TestFilterList.java | 146 +++-- 2 files changed, 469 insertions(+), 219 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/f54cc1ca/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java index 1e80a7e..7f2405d 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/filter/FilterList.java @@ -90,62 +90,53 @@ final public class FilterList extends FilterBase { private Cell transformedCell = null; /** - * Constructor that takes a set of {@link Filter}s. The default operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a set of {@link Filter}s and an operator. + * @param operator Operator to process filter set with. + * @param rowFilters Set of row filters. + */ + public FilterList(final Operator operator, final List rowFilters) { +reversed = checkAndGetReversed(rowFilters, reversed); +this.filters = new ArrayList<>(rowFilters); +this.operator = operator; +initPrevListForMustPassOne(rowFilters.size()); + } + + /** + * Constructor that takes a set of {@link Filter}s. The default operator MUST_PASS_ALL is assumed. * All filters are cloned to internal list. * @param rowFilters list of filters */ public FilterList(final List rowFilters) { -reversed = getReversed(rowFilters, reversed); -this.filters = new ArrayList<>(rowFilters); -initPrevListForMustPassOne(rowFilters.size()); +this(Operator.MUST_PASS_ALL, rowFilters); } /** - * Constructor that takes a var arg number of {@link Filter}s. The fefault operator - * MUST_PASS_ALL is assumed. + * Constructor that takes a var arg number of {@link Filter}s. The default operator MUST_PASS_ALL + * is assumed. * @param rowFilters */ public FilterList(final Filter... rowFilters) { -this(Arrays.asList(rowFilters)); +this(Operator.MUST_PASS_ALL, Arrays.asList(rowFilters)); } /** * Constructor that takes an operator. - * * @param operator Operator to process filter set with. */ public FilterList(final Operator operator) { -this.operator = operator; -this.filters = new ArrayList<>(); -initPrevListForMustPassOne(filters.size()); - } - - /** - * Constructor that takes a set of {@link Filter}s and an operator. - * - * @param operator Operator to process filter set with. - * @param rowFilters Set of row filters. - */ - public FilterList(final Operator operator, final List rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.size()); +this(operator, new ArrayList<>()); } /** * Constructor that takes a var arg number of {@link Filter}s and an operator. - * * @param operator Operator to process filter set with. * @param rowFilters Filters to use */ public FilterList(final Operator operator, final Filter... rowFilters) { -this(rowFilters); -this.operator = operator; -initPrevListForMustPassOne(rowFilters.length); +this(operator, Arrays.asList(rowFilters)); } - public void initPrevListForMustPassOne(int size) { + private void initPrevListForMustPassOne(int size) { if (operator == Operator.MUST_PASS_ONE) { if (this.prevFilterRCList == null) { prevFilterRCList = new ArrayList<>(Collections.nCopies(size, null)); @@ -156,10 +147,8 @@ final public class FilterList extends FilterBase { } } - /** * Get the operator. - * * @return operator */ public Operator getOperator() { @@ -168,7 +157,6 @@ final public class FilterList extends FilterBase { /** * Get the filters. - * * @return filters */ public List getFilters() { @@ -183,33 +171,22 @@ final public class