Method parseKeyValue

test/core/TestAppendDataPoints.java:81–194

()

  }

  @Test
  public void parseKeyValue() throws Exception {
    KeyValue kv = new KeyValue(ROW_KEY, CF, 
        AppendDataPoints.APPEND_COLUMN_QUALIFIER, 
        MockBase.concatByteArrays(DPQ_S, DPV));
    AppendDataPoints adp = new AppendDataPoints();
    Collection<Cell> cells = adp.parseKeyValue(tsdb, kv);
    assertEquals(1, cells.size());
    Cell cell = cells.iterator().next();
    assertArrayEquals(DPV, cell.value);
    assertEquals(1356998402000L, cell.timestamp(1356998400));
    assertArrayEquals(DPQ_S, adp.qualifier());
    assertArrayEquals(DPV, adp.value());
    verify(client, never()).put(any(PutRequest.class));
    
    kv = new KeyValue(ROW_KEY, CF, 
        AppendDataPoints.APPEND_COLUMN_QUALIFIER, 
        MockBase.concatByteArrays(DPQ_MS, DPV));
    adp = new AppendDataPoints();
    cells = adp.parseKeyValue(tsdb, kv);
    assertEquals(1, cells.size());
    cell = cells.iterator().next();
    assertArrayEquals(DPV, cell.value);
    assertEquals(1356998400128L, cell.timestamp(1356998400));
    assertArrayEquals(DPQ_MS, adp.qualifier());
    assertArrayEquals(DPV, adp.value());
    verify(client, never()).put(any(PutRequest.class));
    
    // some odd offset
    kv = new KeyValue(ROW_KEY, CF, 
        new byte[] { AppendDataPoints.APPEND_COLUMN_PREFIX, 42, 42 },
        MockBase.concatByteArrays(DPQ_MS, DPV));
    adp = new AppendDataPoints();
    cells = adp.parseKeyValue(tsdb, kv);
    assertEquals(1, cells.size());
    cell = cells.iterator().next();
    assertArrayEquals(DPV, cell.value);
    assertEquals(1356998400128L, cell.timestamp(1356998400));
    assertArrayEquals(DPQ_MS, adp.qualifier());
    assertArrayEquals(DPV, adp.value());
    verify(client, never()).put(any(PutRequest.class));
    
    kv = new KeyValue(ROW_KEY, CF, 
        AppendDataPoints.APPEND_COLUMN_QUALIFIER, 
        MockBase.concatByteArrays(DPQ_MS, DPV, DPQ_S, DPV2));
    adp = new AppendDataPoints();
    cells = adp.parseKeyValue(tsdb, kv);
    assertEquals(2, cells.size());
    Iterator<Cell> iterator = cells.iterator();
    cell = iterator.next();
    assertArrayEquals(DPV, cell.value);
    assertEquals(1356998400128L, cell.timestamp(1356998400));
    cell = iterator.next();
    assertArrayEquals(DPV2, cell.value);
    assertEquals(1356998402000L, cell.timestamp(1356998400));
    assertArrayEquals(MockBase.concatByteArrays(DPQ_MS, DPQ_S), adp.qualifier());
    assertArrayEquals(MockBase.concatByteArrays(DPV, DPV2), adp.value());
    verify(client, never()).put(any(PutRequest.class));