Checkpoints the {@link MysqlSourceState} for the source at the given {@link Mutation} position.

@return whether the given resource is registered.

Decrement the counter by one.

mapping between column type to java type BIT => BitSet ENUM, YEAR TINY, SHORT, INT24, LONG => int SET, LONGLONG => long FLOAT => float DOUBLE => value

@return the key for a {@link MysqlMutation} in the following format: "[database_name][table_name][primary_key_value]".

Gets the key for an object. @param object the object to get the key for. @return the resulting key.

@return columns of the table that have changed value as a result of this mutation

Gets the {@link Mutation} with the earliest id from the last published {@link Mutation}s across all {@link Destination}s in the pool. <p>Note: If the

@return the last published {@link Mutation} to the underlying {@link Destination}.

The is currently a replication of the logic in {@code kafka.producer.DefaultPartitioner}

@return all partitions for a given registered resource.

Increment the counter by one.

Initializes the source and prepares to start streaming.

Updates the {@link TableCache} with {@link com.airbnb.spinaltap.mysql.mutation.schema.Table} information corresponding to the {@link TableMapEvent}. T

Action to perform when an error is caught on send.