"<Switching to the 'reduce' phase>.......");
MapReduceTransaction mr_ts = (MapReduceTransaction)this.ts;
mr_ts.setReducePhase();
assert(mr_ts.isReducePhase());
mr_ts.resetTransaction();
if (hstore_site.getHStoreConf().site.mr_reduce_blocking){
if (debug.val)
LOG.debug(ts + ": $$$ normal reduce blocking execution way");
// calling this hstore_site.transactionStart function will block the executing engine on each partition