public class TestAsyncClientPushback extends ClientPushbackTestBase
| Modifier and Type | Field and Description |
|---|---|
static HBaseClassTestRule |
CLASS_RULE |
private org.apache.hadoop.hbase.client.AsyncConnectionImpl |
conn |
private org.apache.hadoop.hbase.client.AsyncBufferedMutator |
mutator |
tableName, UTIL| Constructor and Description |
|---|
TestAsyncClientPushback() |
| Modifier and Type | Method and Description |
|---|---|
protected org.apache.hadoop.hbase.client.backoff.ClientBackoffPolicy |
getBackoffPolicy() |
protected org.apache.hadoop.hbase.client.MetricsConnection |
getConnectionMetrics() |
protected org.apache.hadoop.hbase.client.ServerStatisticTracker |
getStatisticsTracker() |
protected void |
mutate(org.apache.hadoop.hbase.client.Put put) |
protected void |
mutate(org.apache.hadoop.hbase.client.Put put,
AtomicLong endTime,
CountDownLatch latch) |
protected void |
mutateRow(org.apache.hadoop.hbase.client.RowMutations mutations) |
void |
setUp() |
void |
tearDown() |
cleanupCluster, setupCluster, testClientTracksServerPushback, testMutateRowStatspublic static final HBaseClassTestRule CLASS_RULE
private org.apache.hadoop.hbase.client.AsyncConnectionImpl conn
private org.apache.hadoop.hbase.client.AsyncBufferedMutator mutator
public TestAsyncClientPushback()
public void tearDown() throws IOException
IOExceptionprotected org.apache.hadoop.hbase.client.backoff.ClientBackoffPolicy getBackoffPolicy() throws IOException
getBackoffPolicy in class ClientPushbackTestBaseIOExceptionprotected org.apache.hadoop.hbase.client.ServerStatisticTracker getStatisticsTracker() throws IOException
getStatisticsTracker in class ClientPushbackTestBaseIOExceptionprotected org.apache.hadoop.hbase.client.MetricsConnection getConnectionMetrics() throws IOException
getConnectionMetrics in class ClientPushbackTestBaseIOExceptionprotected void mutate(org.apache.hadoop.hbase.client.Put put) throws IOException
mutate in class ClientPushbackTestBaseIOExceptionprotected void mutate(org.apache.hadoop.hbase.client.Put put, AtomicLong endTime, CountDownLatch latch) throws IOException
mutate in class ClientPushbackTestBaseIOExceptionprotected void mutateRow(org.apache.hadoop.hbase.client.RowMutations mutations) throws IOException
mutateRow in class ClientPushbackTestBaseIOExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.