public class TestScannerRetriableFailure extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TestScannerRetriableFailure.FaultyScannerObserver |
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static byte[] |
FAMILY_NAME |
private static String |
FAMILY_NAME_STR |
private static org.slf4j.Logger |
LOG |
TableNameTestRule |
testTable |
private static HBaseTestingUtility |
UTIL |
Constructor and Description |
---|
TestScannerRetriableFailure() |
Modifier and Type | Method and Description |
---|---|
private void |
checkTableRows(org.apache.hadoop.hbase.client.Table table,
int numRows) |
private org.apache.hadoop.fs.FileSystem |
getFileSystem() |
private org.apache.hadoop.fs.Path |
getRootDir() |
void |
loadTable(org.apache.hadoop.hbase.client.Table table,
int numRows) |
static void |
setup() |
private static void |
setupConf(org.apache.hadoop.conf.Configuration conf) |
static void |
tearDown() |
void |
testFaultyScanner() |
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static final HBaseTestingUtility UTIL
private static final String FAMILY_NAME_STR
private static final byte[] FAMILY_NAME
public TableNameTestRule testTable
public TestScannerRetriableFailure()
private static void setupConf(org.apache.hadoop.conf.Configuration conf)
public void testFaultyScanner() throws Exception
Exception
private org.apache.hadoop.fs.FileSystem getFileSystem()
private org.apache.hadoop.fs.Path getRootDir()
public void loadTable(org.apache.hadoop.hbase.client.Table table, int numRows) throws IOException
IOException
private void checkTableRows(org.apache.hadoop.hbase.client.Table table, int numRows) throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.