Uses of Class
com.zendesk.maxwell.filtering.Filter
-
Packages that use Filter Package Description com.zendesk.maxwell top level classes concerned with instantiating and running a Maxwell replicator.com.zendesk.maxwell.filtering filtering allows users to choose what data to output in a streamcom.zendesk.maxwell.recovery allows users to continue a stream after changing masterscom.zendesk.maxwell.replication concerns the operation of the binlog replicatorcom.zendesk.maxwell.schema stores and updates (via SQL parsing) a view of the mysql schemacom.zendesk.maxwell.schema.ddl the mysql DDL schema parser lives here. -
-
Uses of Filter in com.zendesk.maxwell
Fields in com.zendesk.maxwell declared as Filter Modifier and Type Field Description Filter
MaxwellConfig. filter
Configuration for including/excluding rowsMethods in com.zendesk.maxwell that return Filter Modifier and Type Method Description Filter
MaxwellContext. getFilter()
get the current active filter -
Uses of Filter in com.zendesk.maxwell.filtering
Methods in com.zendesk.maxwell.filtering with parameters of type Filter Modifier and Type Method Description static boolean
Filter. couldIncludeFromColumnFilters(Filter filter, String database, String table, Set<String> columnNames)
static boolean
Filter. includes(Filter filter, String database, String table)
static boolean
Filter. includes(Filter filter, String database, String table, Map<String,Object> data)
-
Uses of Filter in com.zendesk.maxwell.recovery
Subclasses of Filter in com.zendesk.maxwell.recovery Modifier and Type Class Description class
RecoveryFilter
filter out (via a blacklist) everything except for `maxwell`.`positions`. -
Uses of Filter in com.zendesk.maxwell.replication
Methods in com.zendesk.maxwell.replication with parameters of type Filter Modifier and Type Method Description void
TableCache. processEvent(Schema schema, Filter filter, Boolean ignoreMissingSchema, Long tableId, String dbName, String tblName)
Constructors in com.zendesk.maxwell.replication with parameters of type Filter Constructor Description BinlogConnectorReplicator(SchemaStore schemaStore, AbstractProducer producer, BootstrapController bootstrapper, MaxwellMysqlConfig mysqlConfig, Long replicaServerID, String maxwellSchemaDatabaseName, Metrics metrics, Position start, boolean stopOnEOF, String clientID, HeartbeatNotifier heartbeatNotifier, Scripting scripting, Filter filter, boolean ignoreMissingSchema, MaxwellOutputConfig outputConfig, float bufferMemoryUsage, int replicationReconnectionRetries, int binlogEventQueueSize)
BinlogConnectorReplicator(SchemaStore schemaStore, AbstractProducer producer, BootstrapController bootstrapper, MaxwellMysqlConfig mysqlConfig, Long replicaServerID, String maxwellSchemaDatabaseName, Metrics metrics, Position start, boolean stopOnEOF, String clientID, HeartbeatNotifier heartbeatNotifier, Scripting scripting, Filter filter, MaxwellOutputConfig outputConfig, float bufferMemoryUsage, int replicationReconnectionRetries)
-
Uses of Filter in com.zendesk.maxwell.schema
Constructors in com.zendesk.maxwell.schema with parameters of type Filter Constructor Description AbstractSchemaStore(ConnectionPool replicationConnectionPool, ConnectionPool schemaConnectionPool, CaseSensitivity caseSensitivity, Filter filter)
MysqlSchemaStore(ConnectionPool maxwellConnectionPool, ConnectionPool replicationConnectionPool, ConnectionPool schemaConnectionPool, Long serverID, Position initialPosition, CaseSensitivity caseSensitivity, Filter filter, boolean readOnly)
-
Uses of Filter in com.zendesk.maxwell.schema.ddl
Methods in com.zendesk.maxwell.schema.ddl with parameters of type Filter Modifier and Type Method Description boolean
DatabaseAlter. isBlacklisted(Filter filter)
boolean
DatabaseCreate. isBlacklisted(Filter filter)
boolean
DatabaseDrop. isBlacklisted(Filter filter)
abstract boolean
SchemaChange. isBlacklisted(Filter filter)
boolean
TableAlter. isBlacklisted(Filter filter)
boolean
TableCreate. isBlacklisted(Filter filter)
boolean
TableDrop. isBlacklisted(Filter filter)
boolean
ResolvedSchemaChange. shouldOutput(Filter filter)
boolean
ResolvedTableAlter. shouldOutput(Filter filter)
-