private void processValues(
    Aggregation myagg,
    ColumnVector inputColumn,
    int batchSize, boolean selectedInUse, int[] selected){

    VectorUDAFBloomFilterMerge.Aggregation agg = (VectorUDAFBloomFilterMerge.Aggregation)myagg;

    agg.mergeBloomFilterBytesFromInputColumn((BytesColumnVector) inputColumn, batchSize,
        selectedInUse, selected);
  }
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