Package org.apache.hadoop.hbase.replication

Class ChainWALEntryFilter

java.lang.Object

org.apache.hadoop.hbase.replication.ChainWALEntryFilter

All Implemented Interfaces:

WALEntryFilter

Direct Known Subclasses:

ChainWALEmptyEntryFilter

@LimitedPrivate("Replication")
public class ChainWALEntryFilter
extends Object
implements WALEntryFilter

A WALEntryFilter which contains multiple filters and applies them in chain order

Field Summary

Fields

Modifier and Type	Field	Description
private WALCellFilter[]	cellFilters
private final WALEntryFilter[]	filters

Constructor Summary

Constructors

Constructor	Description
ChainWALEntryFilter(List<WALEntryFilter> filters)
ChainWALEntryFilter(WALEntryFilter... filters)

Method Summary

Modifier and Type	Method	Description
WAL.Entry	filter(WAL.Entry entry)	Applies the filter, possibly returning a different Entry instance.
private Cell	filterCell(WAL.Entry entry, Cell cell)
protected void	filterCells(WAL.Entry entry)
protected WAL.Entry	filterEntry(WAL.Entry entry)
void	initCellFilters()
void	setSerial(boolean serial)	Tell the filter whether the peer is a serial replication peer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

filters

private final WALEntryFilter[] filters

cellFilters

private WALCellFilter[] cellFilters

Constructor Details

ChainWALEntryFilter

public ChainWALEntryFilter(WALEntryFilter... filters)

ChainWALEntryFilter

public ChainWALEntryFilter(List<WALEntryFilter> filters)

Method Details

setSerial

public void setSerial(boolean serial)

Description copied from interface: WALEntryFilter

Tell the filter whether the peer is a serial replication peer.

For serial replication, usually you should not filter out an entire entry, unless the peer config does not contain the table, because we need the region name and sequence id of the entry to advance the pushed sequence id, otherwise the replication may be blocked. You can just filter out all the cells of the entry to stop it being replicated to peer cluster,or just rely on the WALCellFilter.filterCell(Entry, org.apache.hadoop.hbase.Cell) method to filter all the cells out.

Specified by:

setSerial in interface WALEntryFilter

Parameters:

serial - true if the peer is a serial replication peer, otherwise false

initCellFilters

public void initCellFilters()

filter

public WAL.Entry filter(WAL.Entry entry)

Description copied from interface: 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).

Specified by:

filter in interface WALEntryFilter

Parameters:

entry - Entry to filter

Returns:

a (possibly modified) Entry to use. Returning null or an entry with no cells will cause the entry to be skipped for replication.

filterEntry

protected WAL.Entry filterEntry(WAL.Entry entry)

filterCells

protected void filterCells(WAL.Entry entry)

filterCell

private Cell filterCell(WAL.Entry entry,
 Cell cell)