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

WALKeyImpl.getReplicationScopes介绍

暂无

代码示例

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

@Override
 public Cell filterCell(Entry entry, Cell cell) {
  NavigableMap<byte[], Integer> scopes = entry.getKey().getReplicationScopes();
  if (scopes == null || scopes.isEmpty()) {
   return null;
  }
  byte[] family = CellUtil.cloneFamily(cell);
  if (CellUtil.matchingColumn(cell, WALEdit.METAFAMILY, WALEdit.BULK_LOAD)) {
   return bulkLoadFilter.filterCell(cell, new Predicate<byte[]>() {
    @Override
    public boolean apply(byte[] family) {
     return !hasGlobalScope(scopes, family);
    }
   });
  }
  return hasGlobalScope(scopes, family) ? cell : null;
 }
}

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

@Test
public void testBulkLoadWALEditsWithoutBulkLoadReplicationEnabled() throws Exception {
 NavigableMap<byte[], Integer> scope = new TreeMap<>(Bytes.BYTES_COMPARATOR);
 // 1. Get the bulk load wal edit event
 WALEdit logEdit = getBulkLoadWALEdit(scope);
 // 2. Create wal key
 WALKeyImpl logKey = new WALKeyImpl(scope);
 // 3. Get the scopes for the key
 ReplicationSourceWALActionListener.scopeWALEdits(logKey, logEdit, conf);
 // 4. Assert that no bulk load entry scopes are added if bulk load hfile replication is disabled
 assertNull("No bulk load entries scope should be added if bulk load replication is disabled.",
  logKey.getReplicationScopes());
}

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

@Test
public void testBulkLoadWALEdits() throws Exception {
 // 1. Get the bulk load wal edit event
 NavigableMap<byte[], Integer> scope = new TreeMap<>(Bytes.BYTES_COMPARATOR);
 WALEdit logEdit = getBulkLoadWALEdit(scope);
 // 2. Create wal key
 WALKeyImpl logKey = new WALKeyImpl(scope);
 // 3. Enable bulk load hfile replication
 Configuration bulkLoadConf = HBaseConfiguration.create(conf);
 bulkLoadConf.setBoolean(HConstants.REPLICATION_BULKLOAD_ENABLE_KEY, true);
 // 4. Get the scopes for the key
 ReplicationSourceWALActionListener.scopeWALEdits(logKey, logEdit, bulkLoadConf);
 NavigableMap<byte[], Integer> scopes = logKey.getReplicationScopes();
 // Assert family with replication scope global is present in the key scopes
 assertTrue("This family scope is set to global, should be part of replication key scopes.",
  scopes.containsKey(f1));
 // Assert family with replication scope local is not present in the key scopes
 assertFalse("This family scope is set to local, should not be part of replication key scopes",
  scopes.containsKey(f2));
}

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

@Test
public void testBulkLoadWALEditsWithoutBulkLoadReplicationEnabled() throws Exception {
 NavigableMap<byte[], Integer> scope = new TreeMap<>(Bytes.BYTES_COMPARATOR);
 // 1. Get the bulk load wal edit event
 WALEdit logEdit = getBulkLoadWALEdit(scope);
 // 2. Create wal key
 WALKeyImpl logKey = new WALKeyImpl(scope);
 // 3. Get the scopes for the key
 ReplicationSourceWALActionListener.scopeWALEdits(logKey, logEdit, conf);
 // 4. Assert that no bulk load entry scopes are added if bulk load hfile replication is disabled
 assertNull("No bulk load entries scope should be added if bulk load replication is disabled.",
  logKey.getReplicationScopes());
}

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

@Test
public void testBulkLoadWALEdits() throws Exception {
 // 1. Get the bulk load wal edit event
 NavigableMap<byte[], Integer> scope = new TreeMap<>(Bytes.BYTES_COMPARATOR);
 WALEdit logEdit = getBulkLoadWALEdit(scope);
 // 2. Create wal key
 WALKeyImpl logKey = new WALKeyImpl(scope);
 // 3. Enable bulk load hfile replication
 Configuration bulkLoadConf = HBaseConfiguration.create(conf);
 bulkLoadConf.setBoolean(HConstants.REPLICATION_BULKLOAD_ENABLE_KEY, true);
 // 4. Get the scopes for the key
 ReplicationSourceWALActionListener.scopeWALEdits(logKey, logEdit, bulkLoadConf);
 NavigableMap<byte[], Integer> scopes = logKey.getReplicationScopes();
 // Assert family with replication scope global is present in the key scopes
 assertTrue("This family scope is set to global, should be part of replication key scopes.",
  scopes.containsKey(f1));
 // Assert family with replication scope local is not present in the key scopes
 assertFalse("This family scope is set to local, should not be part of replication key scopes",
  scopes.containsKey(f2));
}