public void delete(Iterable<SystemStreamPartition> systemStreamPartitions) {
    for (SystemStreamPartition systemStreamPartition : systemStreamPartitions) {
      LOG.info("Deleting the partition: {} from store.", systemStreamPartition);
      String serializedSSPAsJson = serializeSSPToJson(systemStreamPartition);
      metadataStore.delete(serializedSSPAsJson);
    }
    metadataStore.flush();
  }
Deletes the system stream partitions from the underlying metadata store.
@param systemStreamPartitions the system stream partitions to delete.
samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskPartitionAssignmentManager.java