Adds a {@link Listener} to the destination.

Registers a list of {@link Pipe}s for the give resource partition @param name The resource name @param partition the partition name @param pipes the

Action to perform after a {@link SourceEvent}s has been received.

Action to perform after a list of {@link Mutation}s has been published.

Action to perform after the {@link Destination} has started.

Process all {@link Mutation}s in the buffer, and sends them to the underlying {@link Destination}.

Resets the state of the validator

Persists the state history in the backing repository.

Whether we can compare two BinlogFilePos using Binlog file position (without GTIDSet)

Checkpoints the source according to the last streamed {@link Mutation} in the pipe

Opens the {@link Source} and {@link Destination} to initiate event streaming

Initializes the destination and prepares for {@link Mutation} publishing. <p>The operation should be idempotent.

Attempts to shutdown the {@link ExecutorService}. If the service does not terminate within the specified timeout, a force shutdown will be triggered.

Stops event streaming for the pipe.

The Java type is an 8-bit signed two's complement integer. But MySql byte is not. So when looking up the column type from a MySql byte, it must be upc

Closes the {@link Source} and {@link Destination} to terminate event streaming, and checkpoints the last recorded {@link Source} state.

Stops {@link Mutation} publishing and closes the destination. <p>The operation should be idempotent.

Checks whether the {@link Table} schema matches the given column schema.