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, testMutateRowStats
public 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
IOException
protected org.apache.hadoop.hbase.client.backoff.ClientBackoffPolicy getBackoffPolicy() throws IOException
getBackoffPolicy
in class ClientPushbackTestBase
IOException
protected org.apache.hadoop.hbase.client.ServerStatisticTracker getStatisticsTracker() throws IOException
getStatisticsTracker
in class ClientPushbackTestBase
IOException
protected org.apache.hadoop.hbase.client.MetricsConnection getConnectionMetrics() throws IOException
getConnectionMetrics
in class ClientPushbackTestBase
IOException
protected void mutate(org.apache.hadoop.hbase.client.Put put) throws IOException
mutate
in class ClientPushbackTestBase
IOException
protected void mutate(org.apache.hadoop.hbase.client.Put put, AtomicLong endTime, CountDownLatch latch) throws IOException
mutate
in class ClientPushbackTestBase
IOException
protected void mutateRow(org.apache.hadoop.hbase.client.RowMutations mutations) throws IOException
mutateRow
in class ClientPushbackTestBase
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.