Package org.apache.hadoop.hbase.replication

Class ScopeWALEntryFilter

java.lang.Object

org.apache.hadoop.hbase.replication.ScopeWALEntryFilter

All Implemented Interfaces:

WALCellFilter, WALEntryFilter

@Private
public class ScopeWALEntryFilter
extends Object
implements WALEntryFilter, WALCellFilter

Keeps KVs that are scoped other than local

Field Summary

Fields

Modifier and Type	Field	Description
private final BulkLoadCellFilter	bulkLoadFilter

Constructor Summary

Constructors

Constructor	Description
ScopeWALEntryFilter()

Method Summary

Modifier and Type	Method	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 boolean	hasGlobalScope(NavigableMap<byte[],Integer> scopes, byte[] family)

Methods inherited from class java.lang.Object

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

Field Details

bulkLoadFilter

private final BulkLoadCellFilter bulkLoadFilter

Constructor Details

ScopeWALEntryFilter

public ScopeWALEntryFilter()

Method Details

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.

hasGlobalScope

private boolean hasGlobalScope(NavigableMap<byte[],Integer> scopes,
 byte[] family)

filterCell

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

Description copied from interface: WALCellFilter

Applies the filter, possibly returning a different Cell instance. If null is returned, the cell will be skipped.

Specified by:

filterCell in interface WALCellFilter

Parameters:

entry - Entry which contains the cell

cell - Cell to filter

Returns:

a (possibly modified) Cell to use. Returning null will cause the cell to be skipped for replication.