Package com.zendesk.maxwell.recovery

Class RecoveryFilter

java.lang.Object

com.zendesk.maxwell.filtering.Filter

com.zendesk.maxwell.recovery.RecoveryFilter

public class RecoveryFilter
extends Filter

filter out (via a blacklist) everything except for `maxwell`.`positions`. this makes a possibly out of sync schema harmless.

Constructor Summary

Constructors

Constructor	Description
RecoveryFilter(String maxwellDatabaseName)

Method Summary

Modifier and Type	Method	Description
boolean	isTableBlacklisted(String databaseName, String tableName)

Methods inherited from class com.zendesk.maxwell.filtering.Filter

addRule, couldIncludeFromColumnFilters, couldIncludeFromColumnFilters, getRules, includes, includes, includes, includes, isDatabaseBlacklisted, isMaxwellDB, isSystemBlacklisted, isSystemWhitelisted, set, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

RecoveryFilter

public RecoveryFilter(String maxwellDatabaseName)

Method Detail

isTableBlacklisted

public boolean isTableBlacklisted(String databaseName,
                                  String tableName)

Overrides:

isTableBlacklisted in class Filter