Retrieves the current object value.

Maps an object to another. @param object the object to map. @return the resulting mapped object.

Adds a new {@link SourceState} entry to the history.

Whether the source is started and processing events.

Increment the counter by one.

Sets the current object value. @param value the object value.

Initializes the source and prepares for event processing. <p>The operation should be idempotent.

The name of the source

@return the current size of the state history.

@return {@code True} if the history is empty, else {@code False}.

Applies the filter on the object @param object the object to filter @return {@code true} if the filter condition passes, {@code false} otherwise

@return the last {@link Mutation} that has been successfully published.

Stops event processing and closes the source. <p>The operation should be idempotent.

Adds a {@link Listener} to the source.

Clears the state of the source. <p>The operation should be idempotent.

Removes the most recently added {@link SourceState} entry from the history.

Returns the number of entities in the event

@return the {@link SourceState} record present in the repository.

Adds or replaces (if already exists) a {@link Table} entry in the cache for the given table id. @param tableId The table id @param tableName The tabl

Commits the source checkpoint on the specified {@link Mutation}. On source start, streaming will begin from the last marked checkpoint.

@return {@code True} if a cache entry exists for the given table id, otherwise {@code False}.

Delete the current object

Build the tagged metric for Datadog from a map for tags in a key:value format. <p>We could validate that the name and tags don't contain [, ] or , be

Updates the current object value given a {@link DataUpdater}. @param value the object value. @param updater the updater .

Validates a {@link Mutation} is received in order, otherwise triggers the specified handler.

Removes a {@link Listener} from the source.

Resets to the last valid {@link MysqlSourceState} recorded in the {@link StateHistory}.

Creates a new object. @param value the object value.

@return whether an object exists

@return the {@link Table} cache entry for the given table id if present, otherwise {@code null}

@return The name of the pipe.

Saves or updates the {@link SourceState} record in the repository

Validates the object. @param object the object

Clears the state of the destination. <p>The operation should be idempotent.

Use the primary key as the key of the ProducerRecord.

Processes an event produced by the {@link Source} and notifies {@link Source.Listener} subscribers of the corresponding {@link Mutation}s.

Adds a recorded value. @param value the length of the value