How to safely remove data in overlap configuration

final LevelMembers memberToMask =
    new LevelMembers(LevelIdentifier.simple("Country"), List.of("US", "France"));
final CompletableFuture<IMaskingOperationReport> maskingResult =
    dataNode.maskMembers(memberToMask, branch, retryNumber);

// Create LevelMembers records
final LevelMembers countryMemberToMask =
    new LevelMembers(LevelIdentifier.simple("Country"), List.of("US", "France"));
final LevelMembers currencyMemberToMask =
    new LevelMembers(LevelIdentifier.simple("Currency"), List.of("USD", "EUR"));
// Mask members on both data cubes (with 3 retries)
final CompletableFuture<IMaskingOperationReport> maskingA =
    dataCubeA.maskMembers(countryMemberToMask, IEpoch.MASTER_BRANCH_NAME, 3);
final CompletableFuture<IMaskingOperationReport> maskingB =
    dataCubeB.maskMembers(currencyMemberToMask, IEpoch.MASTER_BRANCH_NAME, 3);
// Wait for both masking operations to complete
CompletableFuture.allOf(maskingA, maskingB).join();
// Check that both masking operations were successful
final IMaskingOperationReport maskingReportA = maskingA.join();
final IMaskingOperationReport maskingReportB = maskingB.join();
if (!maskingReportA.isSuccessful() || !maskingReportB.isSuccessful()) {
  throw new IllegalStateException(
      "Masking failed. Report A: " + maskingReportA + ", Report B: " + maskingReportB);
}
// Now it is safe to remove the data from the database:
try {
  transactionManager.startTransaction("baseStore");
  try {
    transactionManager.removeWhere(
        "baseStore", BaseConditions.in(FieldPath.of("country"), "US", "France"));
  } catch (final Exception exception) {
    transactionManager.rollbackTransaction();
    throw new RuntimeException("Problem while removing data in transaction", exception);
  }
  transactionManager.commitTransaction();
} catch (final Exception exception) {
  // Unmask members on both data cubes (with 3 retries)
  final CompletableFuture<IMaskingOperationReport> unmaskingA =
      dataCubeA.unmaskMembers(countryMemberToMask, IEpoch.MASTER_BRANCH_NAME, 3);
  final CompletableFuture<IMaskingOperationReport> unmaskingB =
      dataCubeB.unmaskMembers(currencyMemberToMask, IEpoch.MASTER_BRANCH_NAME, 3);
  // Wait for both unmasking operations to complete
  CompletableFuture.allOf(unmaskingA, unmaskingB).join();
  // Check that both unmasking operations were successful
  final IMaskingOperationReport unmaskingReportA = unmaskingA.join();
  final IMaskingOperationReport unmaskingReportB = unmaskingB.join();
  if (!unmaskingReportA.isSuccessful() || !unmaskingReportB.isSuccessful()) {
    throw new IllegalStateException(
        "Unmasking failed. Report A: " + unmaskingReportA + ", Report B: " + unmaskingReportB);
  }
}

final IDistributedActivePivotVersion version = distributedCube.getHead();
final IDistributionInformation distributionInfo = version.getDistributionInformation();
final MemberMapping maskedMembers = distributionInfo.getMaskedMemberMapping();