private Shard shard;
private CohortEntry(final ReadWriteShardDataTreeTransaction transaction, final short clientVersion) {
+ this.cohort = null;
this.transaction = Preconditions.checkNotNull(transaction);
this.transactionId = transaction.getIdentifier();
this.clientVersion = clientVersion;
}
}
+ boolean isSealed() {
+ return cohort != null;
+ }
+
Optional<SortedSet<String>> getParticipatingShardNames() {
return cohort != null ? cohort.getParticipatingShardNames() : Optional.empty();
}