} catch (IOException iOException) {
throw new CassandraAggregationException("Failed to write exchange", exchange, iOException);
}
}
protected void initSelectStatement() {
<BUG>String cql = generateSelect(table,
</BUG>
getAllColumns(),
<BUG>pkColumns).toString();
LOGGER.debug("Generated Select {}", cql);

selectStatement = applyConsistencyLevel(getSession().prepare(cql), readConsistencyLevel);
}</BUG>
@Override

} catch (IOException iOException) {
throw new CassandraAggregationException("Failed to write exchange", exchange, iOException);
}
}
protected void initSelectStatement() {
Select select = generateSelect(table,
getAllColumns(),
pkColumns);
select = (Select) applyConsistencyLevel(select, readConsistencyLevel);
LOGGER.debug("Generated Select {}", select);
selectStatement = getSession().prepare(select);
}
@Override
