.findById(Integer.toString(partition))
.orElse(new StateDocument(partition));
recordHandler.addPartition(partition, document.state);
.findById(Integer.toString(partition))
.orElse(new StateDocument(partition));
recordHandler.addPartition(partition, document.state);
log.info("{} - removing partition: {}", id, partition);
this.partitions.remove(partition);
Map<String, AdderResult> state = recordHandler.removePartition(partition);
log.info("{} - removing partition: {}", id, partition);
this.partitions.remove(partition);
Map<String, AdderResult> state = recordHandler.removePartition(partition);
}
Map<String, List<AdderResult>> results = adderResults.removePartition(partition);
stateRepository.save(new StateDocument(partition, state, results));
}
Map<String, List<AdderResult>> results = adderResults.removePartition(partition);
stateRepository.save(new StateDocument(partition, state, results));