Package com.zendesk.maxwell.filtering

Class Filter

java.lang.Object

com.zendesk.maxwell.filtering.Filter

Direct Known Subclasses:

RecoveryFilter

public class Filter
extends Object

Constructor Summary

Constructors

Constructor	Description
Filter()
Filter(String filterString)
Filter(String maxwellDB, String filterString)

Method Summary

Modifier and Type	Method	Description
void	addRule(String filterString)
static boolean	couldIncludeFromColumnFilters(Filter filter, String database, String table, Set<String> columnNames)
boolean	couldIncludeFromColumnFilters(String database, String table, Set<String> columns)
List<FilterPattern>	getRules()
static boolean	includes(Filter filter, String database, String table)
static boolean	includes(Filter filter, String database, String table, Map<String,Object> data)
boolean	includes(String database, String table)
boolean	includes(String database, String table, Map<String,Object> values)
boolean	isDatabaseBlacklisted(String database)
boolean	isMaxwellDB(String database)
static boolean	isSystemBlacklisted(String databaseName, String tableName)
boolean	isSystemWhitelisted(String database, String table)
boolean	isTableBlacklisted(String database, String table)
void	set(String filterString)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

Filter

public Filter()

Filter

public Filter(String filterString)
       throws InvalidFilterException

Throws:

InvalidFilterException

Filter

public Filter(String maxwellDB,
              String filterString)
       throws InvalidFilterException

Throws:

InvalidFilterException

Method Detail

toString

public String toString()

Overrides:

toString in class Object

set

public void set(String filterString)
         throws InvalidFilterException

Throws:

InvalidFilterException

isSystemWhitelisted

public boolean isSystemWhitelisted(String database,
                                   String table)

isMaxwellDB

public boolean isMaxwellDB(String database)

addRule

public void addRule(String filterString)
             throws InvalidFilterException

Throws:

InvalidFilterException

getRules

public List<FilterPattern> getRules()

includes

public boolean includes(String database,
                        String table)

includes

public boolean includes(String database,
                        String table,
                        Map<String,Object> values)

couldIncludeFromColumnFilters

public boolean couldIncludeFromColumnFilters(String database,
                                             String table,
                                             Set<String> columns)

isTableBlacklisted

public boolean isTableBlacklisted(String database,
                                  String table)

isDatabaseBlacklisted

public boolean isDatabaseBlacklisted(String database)

isSystemBlacklisted

public static boolean isSystemBlacklisted(String databaseName,
                                          String tableName)

includes

public static boolean includes(Filter filter,
                               String database,
                               String table)

includes

public static boolean includes(Filter filter,
                               String database,
                               String table,
                               Map<String,Object> data)

couldIncludeFromColumnFilters

public static boolean couldIncludeFromColumnFilters(Filter filter,
                                                    String database,
                                                    String table,
                                                    Set<String> columnNames)