Test a get that queries by family byte and qualifier byte @throws Exception
()
| 95 | * @throws Exception |
| 96 | */ |
| 97 | @Test |
| 98 | public void getWithQualifier() throws Exception { |
| 99 | final GetRequest get = new GetRequest(TABLE, KEY, FAMILY, QUALIFIER); |
| 100 | final ArrayList<KeyValue> row = new ArrayList<KeyValue>(1); |
| 101 | row.add(KV); |
| 102 | when(regionclient.isAlive()).thenReturn(true); |
| 103 | doAnswer(new Answer<Object>() { |
| 104 | public Object answer(final InvocationOnMock invocation) { |
| 105 | get.getDeferred().callback(row); |
| 106 | return null; |
| 107 | } |
| 108 | }).when(regionclient).sendRpc(get); |
| 109 | assertSame(row, client.get(get).joinUninterruptibly()); |
| 110 | } |
| 111 | |
| 112 | /** |
| 113 | * Test a get that queries by family string |