String tableName = getTableName(entities.get(0).getClass()).toCql();
Batch b = insert ? createInsertBatchQuery(tableName, entities, options, cassandraConverter)
: createUpdateBatchQuery(tableName, entities, options, cassandraConverter);
AsynchronousQueryListener aql = listener == null ? null : new AsynchronousQueryListener() {
@Override
public void onQueryComplete(ResultSetFuture rsf) {
try {
rsf.getUninterruptibly();