private void merge(ElementWrapper bloomFilterWrapper) {
      BloomKFilter.mergeBloomFilterBytes(bfAggregation, bfAggregationStart, bfAggregationLength,
          bloomFilterWrapper.bytes, bloomFilterWrapper.start, bloomFilterWrapper.length,
          bloomFilterWrapper.modifiedStart,
          bloomFilterWrapper.modifiedStart + bloomFilterWrapper.modifiedLength);
    }
Executor.shutdownNow() is supposed to send Thread.interrupt to worker threads, and they are
supposed to finish their work.
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorUDAFBloomFilterMerge.java