HBASE-23238: Remove 'static'ness of cell counter in LimitKVsReturnFilter (addendum)
Having it as static means the test cannot be parameterized (ran into this issue in HBASE-23305). That happens because the field is not reset between parameterized runs. Signed-off-by: Viraj Jasani <vjasani@apache.org>
This commit is contained in:
parent
85b43a7059
commit
27fc96e076
@ -779,24 +779,24 @@ public class TestScannersFromClientSide {
|
||||
|
||||
public static class LimitKVsReturnFilter extends FilterBase {
|
||||
|
||||
private static int total = 0;
|
||||
private int cellCount = 0;
|
||||
|
||||
@Override
|
||||
public ReturnCode filterKeyValue(Cell v) throws IOException {
|
||||
if(total>=6) {
|
||||
total++;
|
||||
if (cellCount >= 6) {
|
||||
cellCount++;
|
||||
return ReturnCode.SKIP;
|
||||
}
|
||||
total++;
|
||||
cellCount++;
|
||||
return ReturnCode.INCLUDE;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean filterAllRemaining() throws IOException {
|
||||
if(total<7) {
|
||||
if (cellCount < 7) {
|
||||
return false;
|
||||
}
|
||||
total++;
|
||||
cellCount++;
|
||||
return true;
|
||||
}
|
||||
|
||||
@ -810,5 +810,4 @@ public class TestScannersFromClientSide {
|
||||
return new LimitKVsReturnFilter();
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user