def merge_accumulators(self, accumulators, *args, **kwargs):
    merged_accumulator = self.create_accumulator()
    for accumulator in accumulators:
        for i in accumulator._sample_heap:
            merged_accumulator.add(i)
    return merged_accumulator
def merge_accumulators(self, accumulators, *args, **kwargs):
    merged_accumulator = self.create_accumulator()
    for accumulator in accumulators:
        for i in accumulator._sample_heap:
            merged_accumulator.add(i)
    return merged_accumulator