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 FilterMaxwellConfig. filterConfiguration for including/excluding rowsMethods in com.zendesk.maxwell that return Filter Modifier and Type Method Description FilterMaxwellContext. 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 booleanFilter. couldIncludeFromColumnFilters(Filter filter, String database, String table, Set<String> columnNames)static booleanFilter. includes(Filter filter, String database, String table)static booleanFilter. 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 classRecoveryFilterfilter 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 voidTableCache. 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 booleanDatabaseAlter. isBlacklisted(Filter filter)booleanDatabaseCreate. isBlacklisted(Filter filter)booleanDatabaseDrop. isBlacklisted(Filter filter)abstract booleanSchemaChange. isBlacklisted(Filter filter)booleanTableAlter. isBlacklisted(Filter filter)booleanTableCreate. isBlacklisted(Filter filter)booleanTableDrop. isBlacklisted(Filter filter)booleanResolvedSchemaChange. shouldOutput(Filter filter)booleanResolvedTableAlter. shouldOutput(Filter filter)
-