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
IOException
public void tearDown() throws IOException
IOException
private 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
IOException
private void testCheckAndMutateWithFilterBuilder(org.apache.hadoop.hbase.client.Row op)
public void testCheckAndMutateWithFilterBuilderThenPut()
public void testCheckAndMutateWithFilterBuilderThenDelete()
public void testCheckAndMutateWithFilterBuilderThenMutations() throws IOException
IOException
public void testMutateRow() throws IOException
IOException
public 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.