private void initExecutor() {
      LOG.info("Number of threads used for bloom filter merge: {}", numThreads);

      executor = Executors.newFixedThreadPool(numThreads);

      workers = new BloomFilterMergeWorker[numThreads];
      for (int f = 0; f < numThreads; f++) {
        workers[f] = new BloomFilterMergeWorker(bfBytes, 0, bfBytes.length, aborted);
        executor.submit(workers[f]);
      }
    }
class for storing the current aggregate value.
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorUDAFBloomFilterMerge.java