Java 类org.apache.hadoop.hbase.wal.WALSplitter.RegionEntryBuffer 实例源码

@Override
public void append(RegionEntryBuffer buffer) throws IOException {
  List<Entry> entries = buffer.getEntryBuffer();

  if (entries.isEmpty() || entries.get(0).getEdit().getCells().isEmpty()) {
    return;
  }

  // meta edits (e.g. flush) are always replicated.
  // data edits (e.g. put) are replicated if the table requires them.
  if (!requiresReplication(buffer.getTableName(), entries)) {
    return;
  }

  sinkWriter.append(buffer.getTableName(), buffer.getEncodedRegionName(),
    entries.get(0).getEdit().getCells().get(0).getRow(), entries);
}

@Override
public void append(RegionEntryBuffer buffer) throws IOException {
  List<Entry> entries = buffer.getEntryBuffer();

  if (entries.isEmpty() || entries.get(0).getEdit().getCells().isEmpty()) {
    return;
  }

  // meta edits (e.g. flush) are always replicated.
  // data edits (e.g. put) are replicated if the table requires them.
  if (!requiresReplication(buffer.getTableName(), entries)) {
    return;
  }

  sinkWriter.append(buffer.getTableName(), buffer.getEncodedRegionName(),
    CellUtil.cloneRow(entries.get(0).getEdit().getCells().get(0)), entries);
}

@Test
public void testRegionEntryBuffer() throws Exception {
  WALSplitter.RegionEntryBuffer reb = new WALSplitter.RegionEntryBuffer(
      TEST_TABLE, TEST_REGION);
  assertEquals(0, reb.heapSize());

  reb.appendEntry(createTestLogEntry(1));
  assertTrue(reb.heapSize() > 0);
}

@Test
public void testRegionEntryBuffer() throws Exception {
  WALSplitter.RegionEntryBuffer reb = new WALSplitter.RegionEntryBuffer(
      TEST_TABLE, TEST_REGION);
  assertEquals(0, reb.heapSize());

  reb.appendEntry(createTestLogEntry(1));
  assertTrue(reb.heapSize() > 0);
}

@Test
public void testRegionEntryBuffer() throws Exception {
  WALSplitter.RegionEntryBuffer reb = new WALSplitter.RegionEntryBuffer(
      TEST_TABLE, TEST_REGION);
  assertEquals(0, reb.heapSize());

  reb.appendEntry(createTestLogEntry(1));
  assertTrue(reb.heapSize() > 0);
}