@InterfaceAudience.Private public class NamespaceTableCfWALEntryFilter extends Object implements WALEntryFilter, WALCellFilter
Modifier and Type | Field and Description |
---|---|
private BulkLoadCellFilter |
bulkLoadFilter |
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.
|
Cell |
filterCell(WAL.Entry entry,
Cell cell)
Applies the filter, possibly returning a different Cell instance.
|
private final ReplicationPeer peer
private BulkLoadCellFilter bulkLoadFilter
public NamespaceTableCfWALEntryFilter(ReplicationPeer peer)
public WAL.Entry filter(WAL.Entry entry)
WALEntryFilter
Applies the filter, possibly returning a different Entry instance. If null is returned, the entry will be skipped.
Notice that you are free to modify the cell list of the give entry, but do not change the content of the cell, it may be used by others at the same time(and usually you can not modify a cell unless you cast it to the implementation class, which is not a good idea).
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 filterCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.