org.apache.hadoop.hbase.replication

Class NamespaceTableCfWALEntryFilter

java.lang.Object

org.apache.hadoop.hbase.replication.NamespaceTableCfWALEntryFilter

All Implemented Interfaces:

WALCellFilter, WALEntryFilter

@InterfaceAudience.Private
public class NamespaceTableCfWALEntryFilter
extends Object
implements WALEntryFilter, WALCellFilter

Filter a WAL Entry by the peer config: replicate_all flag, namespaces config, table-cfs config, exclude namespaces config, and exclude table-cfs config. If replicate_all flag is true, it means all user tables will be replicated to peer cluster. But you can set exclude namespaces or exclude table-cfs which can't be replicated to peer cluster. Note: set a exclude namespace means that all tables in this namespace can't be replicated. If replicate_all flag is false, it means all user tables can't be replicated to peer cluster. But you can set namespaces or table-cfs which will be replicated to peer cluster. Note: set a namespace means that all tables in this namespace will be replicated.

Field Summary

Fields

Modifier and Type	Field and Description
private BulkLoadCellFilter	bulkLoadFilter
private static org.slf4j.Logger	LOG
private ReplicationPeer	peer

Constructor Summary

Constructors

Constructor and Description
NamespaceTableCfWALEntryFilter(ReplicationPeer peer)

Method Summary

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.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

peer

private final ReplicationPeer peer

bulkLoadFilter

private BulkLoadCellFilter bulkLoadFilter

Constructor Detail

NamespaceTableCfWALEntryFilter

public NamespaceTableCfWALEntryFilter(ReplicationPeer peer)

Method Detail

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.

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.

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.

filterByExcludeTableCfs

private boolean filterByExcludeTableCfs(TableName tableName,
                                        String family,
                                        Map<TableName,List<String>> excludeTableCfs)

filterByTableCfs

private boolean filterByTableCfs(TableName tableName,
                                 String family,
                                 Map<TableName,List<String>> tableCfs)