@InterfaceAudience.Private public class NamespaceTableCfWALEntryFilter extends Object implements WALEntryFilter, WALCellFilter
Modifier and Type | Field and Description |
---|---|
private BulkLoadCellFilter |
bulkLoadFilter |
private static org.slf4j.Logger |
LOG |
private ReplicationPeer |
peer |
Constructor and Description |
---|
NamespaceTableCfWALEntryFilter(ReplicationPeer peer) |
Modifier and Type | Method and Description |
---|---|
WAL.Entry |
filter(WAL.Entry entry)
Applies the filter, possibly returning a different Entry instance.
|
private boolean |
filterByExcludeTableCfs(TableName tableName,
String family,
Map<TableName,List<String>> excludeTableCfs) |
private boolean |
filterByTableCfs(TableName tableName,
String family,
Map<TableName,List<String>> tableCfs) |
Cell |
filterCell(WAL.Entry entry,
Cell cell)
Applies the filter, possibly returning a different Cell instance.
|
private static final org.slf4j.Logger LOG
private final ReplicationPeer peer
private BulkLoadCellFilter bulkLoadFilter
public NamespaceTableCfWALEntryFilter(ReplicationPeer peer)
public WAL.Entry filter(WAL.Entry entry)
WALEntryFilter
filter
in interface WALEntryFilter
entry
- Entry to filterpublic Cell filterCell(WAL.Entry entry, Cell cell)
WALCellFilter
filterCell
in interface WALCellFilter
entry
- Entry which contains the cellcell
- Cell to filterprivate boolean filterByExcludeTableCfs(TableName tableName, String family, Map<TableName,List<String>> excludeTableCfs)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.