if(cohortEntry == null) {
cohortEntry = new CohortEntry(batched.getTransactionID(),
dataTree.newReadWriteTransaction(batched.getTransactionID(), batched.getTransactionChainID()),
cohortRegistry, schema, batched.getVersion());
if(cohortEntry == null) {
cohortEntry = new CohortEntry(batched.getTransactionID(),
dataTree.newReadWriteTransaction(batched.getTransactionID(), batched.getTransactionChainID()),
cohortRegistry, schema, batched.getVersion());