Uses of Class
com.zendesk.maxwell.schema.ddl.InvalidSchemaError
-
Packages that use InvalidSchemaError Package Description com.zendesk.maxwell.recovery allows users to continue a stream after changing masterscom.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 InvalidSchemaError in com.zendesk.maxwell.recovery
Methods in com.zendesk.maxwell.recovery that throw InvalidSchemaError Modifier and Type Method Description List<ResolvedSchemaChange>
RecoverySchemaStore. processSQL(String sql, String currentDatabase, Position position)
-
Uses of InvalidSchemaError in com.zendesk.maxwell.schema
Methods in com.zendesk.maxwell.schema that throw InvalidSchemaError Modifier and Type Method Description void
Table. changeColumn(int idx, ColumnPosition position, ColumnDef definition, List<DeferredPositionUpdate> deferred)
static void
SchemaStoreSchema. ensureMaxwellSchema(Connection connection, String schemaDatabaseName)
Database
Schema. findDatabaseOrThrow(String name)
Table
Database. findTableOrThrow(String table)
protected void
MysqlSavedSchema. handleVersionUpgrades(ConnectionPool pool)
void
Table. moveColumn(String name, ColumnPosition position)
List<ResolvedSchemaChange>
MysqlSchemaStore. processSQL(String sql, String currentDatabase, Position position)
List<ResolvedSchemaChange>
SchemaStore. processSQL(String sql, String currentDatabase, Position position)
Process a DDL statement Parse the given SQL, applying the changes to the schema.void
Table. renameColumn(int idx, String name)
void
Table. replaceColumn(int idx, ColumnDef definition)
protected List<ResolvedSchemaChange>
AbstractSchemaStore. resolveSQL(Schema schema, String sql, String currentDatabase)
static MysqlSavedSchema
MysqlSavedSchema. restore(MaxwellContext context, Position targetPosition)
static MysqlSavedSchema
MysqlSavedSchema. restore(ConnectionPool pool, Long serverID, CaseSensitivity caseSensitivity, Position targetPosition)
static MysqlSavedSchema
MysqlSavedSchema. restoreFromSchemaID(Long schemaID, Connection conn, CaseSensitivity sensitivity)
protected void
MysqlSavedSchema. restoreFromSchemaID(Connection conn, Long schemaID)
-
Uses of InvalidSchemaError in com.zendesk.maxwell.schema.ddl
Methods in com.zendesk.maxwell.schema.ddl that throw InvalidSchemaError Modifier and Type Method Description void
RenameColumnMod. apply(Table table, List<DeferredPositionUpdate> deferred)
void
ResolvedDatabaseAlter. apply(Schema schema)
void
ResolvedDatabaseCreate. apply(Schema schema)
void
ResolvedDatabaseDrop. apply(Schema schema)
abstract void
ResolvedSchemaChange. apply(Schema originalSchema)
void
ResolvedTableAlter. apply(Schema schema)
void
ResolvedTableCreate. apply(Schema schema)
void
ResolvedTableDrop. apply(Schema schema)
ResolvedDatabaseAlter
DatabaseAlter. resolve(Schema s)
ResolvedDatabaseCreate
DatabaseCreate. resolve(Schema schema)
ResolvedDatabaseDrop
DatabaseDrop. resolve(Schema schema)
abstract ResolvedSchemaChange
SchemaChange. resolve(Schema schema)
ResolvedTableAlter
TableAlter. resolve(Schema schema)
ResolvedTableCreate
TableCreate. resolve(Schema schema)
-