from btoddb / flume-ng-cassandra-sink