Package org.apache.flink.cdc.runtime.operators.sink

Class SchemaEvolutionClient

java.lang.Object

org.apache.flink.cdc.runtime.operators.sink.SchemaEvolutionClient

public class SchemaEvolutionClient
extends Object

Client for DataSinkWriterOperator interact with Schema Registry (Could be distributed or regular) when table schema evolution happened.

Constructor Summary

Constructors

Constructor	Description
SchemaEvolutionClient(org.apache.flink.runtime.jobgraph.tasks.TaskOperatorEventGateway toCoordinator, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID)

Method Summary

Modifier and Type	Method	Description
Optional<Schema>	getLatestEvolvedSchema(TableId tableId)
Optional<Schema>	getLatestOriginalSchema(TableId tableId)
void	notifyFlushSuccess(int subtask, int sourceSubTaskId)	send FlushSuccessEvent to Schema Registry.
void	registerSubtask(int subtask)	send SinkWriterRegisterEvent to Schema Registry.

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaEvolutionClient

public SchemaEvolutionClient(org.apache.flink.runtime.jobgraph.tasks.TaskOperatorEventGateway toCoordinator,
                             org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID)

Method Detail

registerSubtask

public void registerSubtask(int subtask)
                     throws IOException

send SinkWriterRegisterEvent to Schema Registry.

Throws:

IOException

notifyFlushSuccess

public void notifyFlushSuccess(int subtask,
                               int sourceSubTaskId)
                        throws IOException

send FlushSuccessEvent to Schema Registry.

Throws:

IOException

getLatestEvolvedSchema

public Optional<Schema> getLatestEvolvedSchema(TableId tableId)
                                        throws Exception

Throws:

Exception

getLatestOriginalSchema

public Optional<Schema> getLatestOriginalSchema(TableId tableId)
                                         throws Exception

Throws:

Exception