private static class TestBasicWALEntryStream.PartialWALEntryFailingWALEntryFilter extends Object implements org.apache.hadoop.hbase.replication.WALEntryFilter
Modifier and Type | Field and Description |
---|---|
private int |
filteredWALEntryCount |
private int |
maxThrowExceptionCount |
private int |
throwExceptionCount |
private int |
walEntryCount |
Constructor and Description |
---|
PartialWALEntryFailingWALEntryFilter(int throwExceptionLimit,
int walEntryCount) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.wal.WAL.Entry |
filter(org.apache.hadoop.hbase.wal.WAL.Entry entry) |
int |
getThrowExceptionCount() |
private int filteredWALEntryCount
private int walEntryCount
private int throwExceptionCount
private int maxThrowExceptionCount
public PartialWALEntryFailingWALEntryFilter(int throwExceptionLimit, int walEntryCount)
public org.apache.hadoop.hbase.wal.WAL.Entry filter(org.apache.hadoop.hbase.wal.WAL.Entry entry)
filter
in interface org.apache.hadoop.hbase.replication.WALEntryFilter
public int getThrowExceptionCount()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.