class SaveToCassandraOperationsService {

    public Insert createInsertStatement(String streamName, List<ColumnNameTypeValue> columns, String timestampColumnName) {
        Insert insert = QueryBuilder.insertInto(addQuotes(STREAMING.STREAMING_KEYSPACE_NAME), addQuotes(streamName));
        for (ColumnNameTypeValue column : columns) {
            insert.value(addQuotes(column.getColumn()), column.getValue());
        }
        insert.value(addQuotes(timestampColumnName), UUIDs.timeBased());
        return insert;
    }

    public  SaveToCassandraOperationsService(Session session);

}