public void mergeBloomFilterBytesFromInputColumn(BytesColumnVector inputColumn,
        int batchSize, boolean selectedInUse, int[] selected) {
      if (executor == null) {
        initExecutor();
      }

      // split every bloom filter (represented by a part of a byte[]) across workers
      for (int j = 0; j < batchSize; j++) {
        if (!selectedInUse) {
          if (inputColumn.noNulls) {
            splitVectorAcrossWorkers(workers, inputColumn.vector[j], inputColumn.start[j],
                inputColumn.length[j]);
          } else if (!inputColumn.isNull[j]) {
            splitVectorAcrossWorkers(workers, inputColumn.vector[j], inputColumn.start[j],
                inputColumn.length[j]);
          }
        } else if (inputColumn.noNulls) {
          int i = selected[j];
          splitVectorAcrossWorkers(workers, inputColumn.vector[i], inputColumn.start[i],
              inputColumn.length[i]);
        } else {
          int i = selected[j];
          if (!inputColumn.isNull[i]) {
            splitVectorAcrossWorkers(workers, inputColumn.vector[i], inputColumn.start[i],
                inputColumn.length[i]);
          }
        }
      }
    }
class for storing the current aggregate value.
ql/src/java/org/apache/hadoop/hive/ql/exec/vector/expressions/aggregates/VectorUDAFBloomFilterMerge.java