Package org.apache.flink.cdc.runtime.operators.schema.common

Class SchemaManager

java.lang.Object

org.apache.flink.cdc.runtime.operators.schema.common.SchemaManager

@Internal
public class SchemaManager
extends Object

Schema manager handles schema changes for tables, and manages historical schema versions of tables.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SchemaManager.Serializer	Serializer for SchemaManager.

Field Summary

Fields

Modifier and Type	Field	Description
static SchemaManager.Serializer	SERIALIZER

Constructor Summary

Constructors

Constructor	Description
SchemaManager()
SchemaManager(Map<TableId,SortedMap<Integer,Schema>> originalSchemas, Map<TableId,SortedMap<Integer,Schema>> evolvedSchemas, SchemaChangeBehavior behavior)
SchemaManager(SchemaChangeBehavior schemaChangeBehavior)

Method Summary

Modifier and Type	Method	Description
void	applyEvolvedSchemaChange(SchemaChangeEvent schemaChangeEvent)	Apply schema change to a table.
void	applyOriginalSchemaChange(SchemaChangeEvent schemaChangeEvent)	Apply schema change to a table.
boolean	equals(Object o)
boolean	evolvedSchemaExists(TableId tableId)
Set<TableId>	getAllOriginalTables()
SchemaChangeBehavior	getBehavior()
Schema	getEvolvedSchema(TableId tableId, int version)	Get schema at the specified version of a table.
Optional<Schema>	getLatestEvolvedSchema(TableId tableId)	Get the latest evolved schema of the specified table.
Optional<Schema>	getLatestOriginalSchema(TableId tableId)	Get the latest original schema of the specified table.
Schema	getOriginalSchema(TableId tableId, int version)	Get schema at the specified version of a table.
int	hashCode()
boolean	originalSchemaExists(TableId tableId)
void	registerNewEvolvedSchema(TableId tableId, Schema newSchema)
void	registerNewOriginalSchema(TableId tableId, Schema newSchema)
boolean	schemaExists(Map<TableId,SortedMap<Integer,Schema>> schemaMap, TableId tableId)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

SERIALIZER

public static final SchemaManager.Serializer SERIALIZER

Constructor Detail

SchemaManager

public SchemaManager()

SchemaManager

public SchemaManager(SchemaChangeBehavior schemaChangeBehavior)

SchemaManager

public SchemaManager(Map<TableId,SortedMap<Integer,Schema>> originalSchemas,
                     Map<TableId,SortedMap<Integer,Schema>> evolvedSchemas,
                     SchemaChangeBehavior behavior)

Method Detail

getBehavior

public SchemaChangeBehavior getBehavior()

schemaExists

public final boolean schemaExists(Map<TableId,SortedMap<Integer,Schema>> schemaMap,
                                  TableId tableId)

originalSchemaExists

public final boolean originalSchemaExists(TableId tableId)

evolvedSchemaExists

public final boolean evolvedSchemaExists(TableId tableId)

getAllOriginalTables

public final Set<TableId> getAllOriginalTables()

getLatestEvolvedSchema

public Optional<Schema> getLatestEvolvedSchema(TableId tableId)

Get the latest evolved schema of the specified table.

getLatestOriginalSchema

public Optional<Schema> getLatestOriginalSchema(TableId tableId)

Get the latest original schema of the specified table.

getEvolvedSchema

public Schema getEvolvedSchema(TableId tableId,
                               int version)

Get schema at the specified version of a table.

getOriginalSchema

public Schema getOriginalSchema(TableId tableId,
                                int version)

Get schema at the specified version of a table.

applyOriginalSchemaChange

public void applyOriginalSchemaChange(SchemaChangeEvent schemaChangeEvent)

Apply schema change to a table.

applyEvolvedSchemaChange

public void applyEvolvedSchemaChange(SchemaChangeEvent schemaChangeEvent)

Apply schema change to a table.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

registerNewOriginalSchema

@VisibleForTesting
public void registerNewOriginalSchema(TableId tableId,
                                      Schema newSchema)

registerNewEvolvedSchema

@VisibleForTesting
public void registerNewEvolvedSchema(TableId tableId,
                                     Schema newSchema)

toString

public String toString()

Overrides:

toString in class Object