public class TestAsyncTableTracing extends Object
| Modifier and Type | Field and Description |
|---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.apache.hadoop.conf.Configuration |
CONF |
private org.apache.hadoop.hbase.client.AsyncConnectionImpl |
conn |
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface |
stub |
private org.apache.hadoop.hbase.client.AsyncTable<org.apache.hadoop.hbase.client.ScanResultConsumer> |
table |
io.opentelemetry.sdk.testing.junit4.OpenTelemetryRule |
traceRule |
| Constructor and Description |
|---|
TestAsyncTableTracing() |
public static final HBaseClassTestRule CLASS_RULE
private static org.apache.hadoop.conf.Configuration CONF
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub
private org.apache.hadoop.hbase.client.AsyncConnectionImpl conn
private org.apache.hadoop.hbase.client.AsyncTable<org.apache.hadoop.hbase.client.ScanResultConsumer> table
public io.opentelemetry.sdk.testing.junit4.OpenTelemetryRule traceRule
public TestAsyncTableTracing()
public void setUp() throws IOException
IOExceptionpublic void tearDown() throws IOException
IOExceptionprivate void assertTrace(String tableOperation)
private void assertTrace(String tableOperation, org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData> matcher)
public void testExists()
public void testGet()
public void testPut()
public void testDelete()
public void testAppend()
public void testIncrement()
public void testIncrementColumnValue1()
public void testIncrementColumnValue2()
public void testCheckAndMutate()
public void testCheckAndMutateList()
public void testCheckAndMutateAll()
private void testCheckAndMutateBuilder(org.apache.hadoop.hbase.client.Row op)
public void testCheckAndMutateBuilderThenPut()
public void testCheckAndMutateBuilderThenDelete()
public void testCheckAndMutateBuilderThenMutations() throws IOException
IOExceptionprivate void testCheckAndMutateWithFilterBuilder(org.apache.hadoop.hbase.client.Row op)
public void testCheckAndMutateWithFilterBuilderThenPut()
public void testCheckAndMutateWithFilterBuilderThenDelete()
public void testCheckAndMutateWithFilterBuilderThenMutations() throws IOException
IOExceptionpublic void testMutateRow() throws IOException
IOExceptionpublic void testScanAll()
public void testGetScanner()
public void testExistsList()
public void testExistsAll()
public void testGetList()
public void testGetAll()
public void testPutList()
public void testPutAll()
public void testDeleteList()
public void testDeleteAll()
public void testBatch()
public void testBatchAll()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.