Creates the list of {@link Pipe}s for the {@link Source} constructed from the given {@link com.airbnb.spinaltap.common.config.SourceConfiguration}. @

Induces a delay given the configured delay time. @param mutation The {@link Mutation} for which to consider the delay @throws InterruptedException

@return the last mutation successfully sent to the pipe's {@link Destination}.

@return a collection representing the {@link SourceState}s currently in the state history.

@return the {@link Repository} of the history of {@link SourceState} objects for a given resource and partition.

@return the {@link Repository} of the {@link MysqlSourceState} object for a given resource and partition.

The format of the topic for a table from source in database is as follows: [source]-[database]-[table]

Initializes the {@link BinaryLogClient}.

Check if two BinlogFilePos are from the same source MySQL server

@return whether the pipe is currently streaming events

@return whether the destination is started and publishing {@link Mutation}s

Action to perform when an error is caught on processing an event.

Action to perform after a {@link Mutation}s has been detected.

Removes a resource partition. @param name the resource @param partition the partition

Resets the state of the {@link Validator}.

Partitions the {@link Mutation} list according to the supplied {@link KeyProvider} and routes to the corresponding {@link Destination}s

Starts event streaming for the pipe.

Starts all {@link Pipe}s for all managed resources.

Transform from TBase to the ProducerRecord.

Checks whether the table representation is valid