Initial commit.
Started working on the binlog consumer.
Added the basic structure that will allow mysql events to be queued for flushing into Cassandra.
Implemented basic transaction support (no rolling back yet).
Added rollback support.
Producers now receive mutations that represent insert, update, or delete. Started putting together a way to map data to Cassandra.
Mutations now contain the db, table, and affected rows based on the
mutationtype (Insert, Update, Delete).
Organized project into multiple files.
Mutations now have access to Table objets with column names.
Column values are now passed through to all mutations.
Columns and Tables now use ColumnMetadata that includes the name and type of the column.
Hacking the hack that cleans up the show create table strings even further to keep varchar(XX) and only strip out int(eger)(XX) for now.
Isolated the cleanup hack in it's own method.
Mutations are now returned by mappers and the writers can execute them. Data can now be moved from MySQL to Cassandra.
Moved CF declarations outside the map method.
The binlog position is now recorded after every flush of the producers and when the binlog consumer disconnects.
Moved out hardcoded Cassandra config into application.conf
We now rely on the information-schema to find out the column names
instead of parsing "show create table".
Producers are now loaded and configured via the application.conf
Added a quick and dirty stdout producer and the ability to set a
producer to enabled = true / false in the config.