Base implementation for Data Store source (Such as MySQL, DynamoDB). @param <E> The event type produced by the source

Represents the base configuration for a {@link MysqlSource}.

Base abstract implementation of {@link Source}. @param <E> The {@link SourceEvent} type produced by the given {@link Source}.

Exception thrown when a DynamoDB attribute value cannot be deserialized.

Responsible for mapping a list of objects. @param <T> The mapped from object type. @param <R> The mapped to object type.

Represents a mapper that maps a {@link com.github.shyiko.mysql.binlog.event.Event} to a {@link com.airbnb.spinaltap.mysql.event.BinlogEvent}.

Represents a {@link MysqlSource} implement based on open-source library <a href="https://github.com/shyiko/mysql-binlog-connector-java">.

Lifecycle listener methods are called synchronized in BinaryLogClient. We should not enter critical sections in SpinalTap code path to avoid deadlocks

Represents a Binlog event

Represents the position in a binlog file.

Represents a {@link Destination} implement with a bounded in-memory buffer. This is used to solve the Producer-Consumer problem between {@link com.air

Represents a chain of {@link Filter}s, where all {@link Filter} conditions need to pass. @param <T> the filtered object type.

Maps an object according to the registered mapper by {@link Class} type.

Represents a MySQL column.

An enumeration of the supported data types for a MySQL {@link Column}.

Exception thrown when a MySQL column value cannot be deserialized.

Represents additional metadata on a MySQL {@link Column}.

A utility class for MySQL {@link Column} SerDe supoort.

Utility methods for concurrency operations

A monotone counter

Represents a MySQL data source configuration.

Responsible for determining the object value, as a function of the current value and new value. @param <T> the object value type.

Represents a {@link com.airbnb.spinaltap.common.util.Mapper} that maps a {@link MysqlDeleteMutation} to its corresponding thrift {@link Mutation} form

Represents a {@link com.airbnb.spinaltap.common.util.Mapper} of a {@link DeleteEvent}s to the corresponding list of {@link com.airbnb.spinaltap.mysql.

Represents the receiving end of the {@link com.airbnb.spinaltap.common.pipe.Pipe}, where {@link Mutation}s are published, i.e. a Sink.

Represents a {@link com.airbnb.spinaltap.common.destination.Destination} configuration.

Responsible for metrics collection for a {@link Destination}.

Represents a pool of {@link Destination}s, where events are routed to the appropriate {@link Destination} given a partitioning function based on {@lin

Our own version of the Counter class that multiplexes tagged metrics to tagged and non-tagged versions, because Datadog is not capable of averaging ac

Our own version of the Histogram class that multiplexes tagged metrics to tagged and non-tagged versions, because Datadog is not capable of averaging

Represents a {@link com.airbnb.spinaltap.common.util.Filter} for duplicate {@link BinlogEvent}s that have already been streamed. This is used for serv

Responsible for handling {@code SpinaltapException}s.

Represents a {@link Validator} that asserts {@link BinlogEvent}s are streamed in order of event id (offset). The implement assumes {@code validate} is

Represents a {@link com.airbnb.spinaltap.common.util.Filter} for {@link BinlogEvent}s based on a predefined whitelist of event class types.

Responsible for filtering object @param <T> The filtered object type

Represents a {@link com.airbnb.spinaltap.common.util.Mapper} that keeps track of {@link GTIDEvent}s, which will be included in {@link com.airbnb.spina

This is an improvement of com.github.shyiko.mysql.binlog.GtidSet

A Histogram interface used to record and analyze the distribution of values.

Represents a {@link com.airbnb.spinaltap.common.util.Mapper} that maps a {@link MysqlInsertMutation} to its corresponding thrift {@link Mutation} form

Represents a {@link com.airbnb.spinaltap.common.util.Mapper} of a {@link WriteEvent} to a list of {@link com.airbnb.spinaltap.mysql.mutation.MysqlMuta

Reflects that the binlog position set in the {@link com.airbnb.spinaltap.mysql.MysqlSource} client is invalid.

Joins two objects to produce a third. @param <S> The first object type. @param <T> The second object type. @param <R> The result object type.

Utility class for json operations and components.

Represents an implement of {@link com.airbnb.spinaltap.common.destination.Destination} using <a href="https://kafka.apache.org">Apache Kafka</a>.

Represents an implement of {@link DestinationBuilder} for {@link KafkaDestination}s.

Represents the Kafka producer configuration used in {@link KafkaDestination}.

Responsible for providing a key for an object. @param <T> The object type. @param <T> The key type.

Base {@link Destination} implement using <a href="https://en.wikipedia.org/wiki/Observer_pattern">observer pattern</a> to allow listening to streamed

Base {@link Source} implement using <a href="https://en.wikipedia.org/wiki/Observer_pattern">observer pattern</a> to allow listening to streamed event

Represents a destination listener to get notified of events and lifecycle changes.

Represents a source listener to get notified of events and lifecycle changes.

Responsible for mapping between objects. @param <T> The mapped from object type. @param <R> The mapped to object type.

Base class which represents a data entity change (mutation). @param <T> The data entity type (ex: Row, Record, etc...)

Responsible for validating that {@link Mutation}s are streamed in order. This is typically used as a {@link com.airbnb.spinaltap.common.source.Source.

Represents a {@link Validator} that asserts parity of the {@link com.airbnb.spinaltap.mysql.mutation.schema.Table} schema with the {@link com.airbnb.s

Represents a MySQL server connection and context with utility functions

Represents the configuration for a {@link com.airbnb.spinaltap.mysql.MysqlSource}

Responsible for metrics collection on operations for {@link com.airbnb.spinaltap.common.destination.Destination} and associated components for a given

Base {@link com.airbnb.spinaltap.common.util.Filter} implement for MySQL {@link BinlogEvent}s