Completely generic transaction storage, prepping for BPS integration
modularized cassandra logic from stream