org.apache.hadoop.hbase.wal.WALKeyImpl.getTableName()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(120)

本文整理了Java中org.apache.hadoop.hbase.wal.WALKeyImpl.getTableName()方法的一些代码示例，展示了WALKeyImpl.getTableName()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WALKeyImpl.getTableName()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.wal.WALKeyImpl
类名称：WALKeyImpl
方法名：getTableName

WALKeyImpl.getTableName介绍

暂无

代码示例

代码示例来源：origin: apache/hbase

  1. private List<List<Entry>> filterBatches(final List<List<Entry>> oldEntryList, TableName table) {
  2.  return oldEntryList
  3.    .stream().map(entries -> entries.stream()
  4.      .filter(e -> !e.getKey().getTableName().equals(table)).collect(Collectors.toList()))
  5.    .collect(Collectors.toList());
  6. }

代码示例来源：origin: apache/hbase

  1. @Override
  2.  public Entry filter(Entry entry) {
  3.   if (entry.getKey().getTableName().isSystemTable()) {
  4.    return null;
  5.   }
  6.   return entry;
  7.  }
  8. }

代码示例来源：origin: apache/hbase

  1. @Override
  2. public Entry filter(Entry entry) {
  3.  if (ReplicationUtils.contains(this.peer.getPeerConfig(), entry.getKey().getTableName())) {
  4.   return entry;
  5.  } else {
  6.   return null;
  7.  }
  8. }

代码示例来源：origin: apache/hbase

  1. private Entry createEntry(RegionInfo region, long seqId) {
  2.  WALKeyImpl key = mock(WALKeyImpl.class);
  3.  when(key.getTableName()).thenReturn(tableName);
  4.  when(key.getEncodedRegionName()).thenReturn(region.getEncodedNameAsBytes());
  5.  when(key.getSequenceId()).thenReturn(seqId);
  6.  Entry entry = mock(Entry.class);
  7.  when(entry.getKey()).thenReturn(key);
  8.  return entry;
  9. }

代码示例来源：origin: apache/hbase

  1. String tmpDirName, Configuration conf) throws IOException {
  2. FileSystem walFS = FSUtils.getWALFileSystem(conf);
  3. Path tableDir = FSUtils.getWALTableDir(conf, logEntry.getKey().getTableName());
  4. String encodedRegionName = Bytes.toString(logEntry.getKey().getEncodedRegionName());
  5. Path regionDir = HRegion.getRegionDir(tableDir, encodedRegionName);

代码示例来源：origin: apache/hbase

  1. @Override
  2. public Entry next(Entry reuse) throws IOException {
  3.  Entry e = reuse;
  4.  if (e == null) {
  5.   e = new Entry();
  6.  }
  7.  boolean hasEntry = false;
  8.  try {
  9.   hasEntry = readNext(e);
  10.  } catch (IllegalArgumentException iae) {
  11.   TableName tableName = e.getKey().getTableName();
  12.   if (tableName != null && tableName.equals(TableName.OLD_ROOT_TABLE_NAME)) {
  13.    // It is old ROOT table edit, ignore it
  14.    LOG.info("Got an old ROOT edit, ignoring ");
  15.    return next(e);
  16.   }
  17.   else throw iae;
  18.  }
  19.  edit++;
  20.  if (compressionContext != null && emptyCompressionContext) {
  21.   emptyCompressionContext = false;
  22.  }
  23.  return hasEntry ? e : null;
  24. }

代码示例来源：origin: apache/hbase

  1. fam -> filterByExcludeTableCfs(entry.getKey().getTableName(), Bytes.toString(fam),
  2.    excludeTableCfs));
  3. } else {
  4.  if (filterByExcludeTableCfs(entry.getKey().getTableName(),
  5.   Bytes.toString(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()),
  6.   excludeTableCfs)) {
  7.   fam -> filterByTableCfs(entry.getKey().getTableName(), Bytes.toString(fam), tableCfs));
  8. } else {
  9.  if (filterByTableCfs(entry.getKey().getTableName(),
  10.   Bytes.toString(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength()),
  11.   tableCfs)) {

代码示例来源：origin: apache/hbase

  1. long seqId = entry.getKey().getSequenceId();
  2. ReplicationBarrierResult barrierResult = MetaTableAccessor.getReplicationBarrierResult(conn,
  3.  entry.getKey().getTableName(), row, entry.getKey().getEncodedRegionName());
  4. LOG.debug("Replication barrier for {}: {}", entry, barrierResult);
  5. long[] barriers = barrierResult.getBarriers();

代码示例来源：origin: apache/hbase

  1. cleanUpHFileRefs(entry.getEdit());
  2. TableName tableName = entry.getKey().getTableName();
  3. source.getSourceMetrics().setAgeOfLastShippedOpByTable(entry.getKey().getWriteTime(),
  4.   tableName.getNameAsString());

代码示例来源：origin: apache/hbase

  1. Assert.assertEquals(entry.getKey().getTableName(), tableName);
  2. Assert.assertEquals(entry.getEdit().getCells().size(), 1);
  3. Cell cell = entry.getEdit().getCells().get(0);

代码示例来源：origin: apache/hbase

  1. assertTrue(Bytes.equals(hri.getEncodedNameAsBytes(),
  2.  entry.getKey().getEncodedRegionName()));
  3. assertTrue(htd.getTableName().equals(entry.getKey().getTableName()));
  4. assertTrue(Bytes.equals(row, 0, row.length, val.getRowArray(), val.getRowOffset(),
  5.  val.getRowLength()));

代码示例来源：origin: apache/phoenix

  1. @Override
  2. public WAL.Entry filter(WAL.Entry entry) {
  3.  //if the WAL.Entry's table isn't System.Catalog or System.Child_Link, it auto-passes this filter
  4.  //TODO: when Phoenix drops support for pre-1.3 versions of HBase, redo as a WALCellFilter
  5.  if (!SchemaUtil.isMetaTable(entry.getKey().getTableName().getName())){
  6.   return entry;
  7.  }
  8.  List<Cell> cells = entry.getEdit().getCells();
  9.  List<Cell> cellsToRemove = Lists.newArrayList();
  10.  for (Cell cell : cells) {
  11.   if (!isTenantRowCell(cell)){
  12.    cellsToRemove.add(cell);
  13.   }
  14.  }
  15.  cells.removeAll(cellsToRemove);
  16.  if (cells.size() > 0) {
  17.   return entry;
  18.  } else {
  19.   return null;
  20.  }
  21. }

代码示例来源：origin: apache/hbase

  1. public static void doRead(ProtobufLogReader reader, boolean withTrailer, RegionInfo hri,
  2.   TableName tableName, int columnCount, int recordCount, byte[] row, long timestamp)
  3.   throws IOException {
  4.  if (withTrailer) {
  5.   assertNotNull(reader.trailer);
  6.  } else {
  7.   assertNull(reader.trailer);
  8.  }
  9.  for (int i = 0; i < recordCount; ++i) {
  10.   WAL.Entry entry = reader.next();
  11.   assertNotNull(entry);
  12.   assertEquals(columnCount, entry.getEdit().size());
  13.   assertArrayEquals(hri.getEncodedNameAsBytes(), entry.getKey().getEncodedRegionName());
  14.   assertEquals(tableName, entry.getKey().getTableName());
  15.   int idx = 0;
  16.   for (Cell val : entry.getEdit().getCells()) {
  17.    assertTrue(Bytes.equals(row, 0, row.length, val.getRowArray(), val.getRowOffset(),
  18.     val.getRowLength()));
  19.    assertArrayEquals(toValue(i, idx), CellUtil.cloneValue(val));
  20.    idx++;
  21.   }
  22.  }
  23.  assertNull(reader.next());
  24. }

代码示例来源：origin: org.apache.hbase/hbase-server

  1. private Entry createEntry(RegionInfo region, long seqId) {
  2.  WALKeyImpl key = mock(WALKeyImpl.class);
  3.  when(key.getTableName()).thenReturn(tableName);
  4.  when(key.getEncodedRegionName()).thenReturn(region.getEncodedNameAsBytes());
  5.  when(key.getSequenceId()).thenReturn(seqId);
  6.  Entry entry = mock(Entry.class);
  7.  when(entry.getKey()).thenReturn(key);
  8.  return entry;
  9. }

代码示例来源：origin: org.apache.phoenix/phoenix-core

  1. @Override
  2. public WAL.Entry filter(WAL.Entry entry) {
  3.  //if the WAL.Entry's table isn't System.Catalog, it auto-passes this filter
  4.  //TODO: when Phoenix drops support for pre-1.3 versions of HBase, redo as a WALCellFilter
  5.  if (!SchemaUtil.isMetaTable(entry.getKey().getTableName().getName())){
  6.   return entry;
  7.  }
  8.  List<Cell> cells = entry.getEdit().getCells();
  9.  List<Cell> cellsToRemove = Lists.newArrayList();
  10.  for (Cell cell : cells) {
  11.   if (!isTenantRowCell(cell)){
  12.    cellsToRemove.add(cell);
  13.   }
  14.  }
  15.  cells.removeAll(cellsToRemove);
  16.  if (cells.size() > 0) {
  17.   return entry;
  18.  } else {
  19.   return null;
  20.  }
  21. }

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

  1. @Override
  2. public WAL.Entry filter(WAL.Entry entry) {
  3.  //if the WAL.Entry's table isn't System.Catalog or System.Child_Link, it auto-passes this filter
  4.  //TODO: when Phoenix drops support for pre-1.3 versions of HBase, redo as a WALCellFilter
  5.  if (!SchemaUtil.isMetaTable(entry.getKey().getTableName().getName())){
  6.   return entry;
  7.  }
  8.  List<Cell> cells = entry.getEdit().getCells();
  9.  List<Cell> cellsToRemove = Lists.newArrayList();
  10.  for (Cell cell : cells) {
  11.   if (!isTenantRowCell(cell)){
  12.    cellsToRemove.add(cell);
  13.   }
  14.  }
  15.  cells.removeAll(cellsToRemove);
  16.  if (cells.size() > 0) {
  17.   return entry;
  18.  } else {
  19.   return null;
  20.  }
  21. }

代码示例来源：origin: org.apache.hbase/hbase-server

  1. assertEquals(columnCount, entry.getEdit().size());
  2. assertArrayEquals(hri.getEncodedNameAsBytes(), entry.getKey().getEncodedRegionName());
  3. assertEquals(tableName, entry.getKey().getTableName());
  4. int idx = 0;
  5. for (Cell val : entry.getEdit().getCells()) {

代码示例来源：origin: org.apache.hbase/hbase-server

  1. Assert.assertEquals(entry.getKey().getTableName(), tableName);
  2. Assert.assertEquals(entry.getEdit().getCells().size(), 1);
  3. Cell cell = entry.getEdit().getCells().get(0);

代码示例来源：origin: org.apache.hbase/hbase-server

  1. assertTrue(Bytes.equals(hri.getEncodedNameAsBytes(),
  2.  entry.getKey().getEncodedRegionName()));
  3. assertTrue(htd.getTableName().equals(entry.getKey().getTableName()));
  4. assertTrue(Bytes.equals(row, 0, row.length, val.getRowArray(), val.getRowOffset(),
  5.  val.getRowLength()));

内容来源于网络，如有侵权，请联系作者删除！

WALKeyImpl

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com