public void addEvent(InputInitializerEvent event) {
    if(!queue.offer(event)) {
      throw new IllegalStateException("Queue full");
    }
  }
DynamicPartitionPruner takes a list of assigned partitions at runtime (split
generation) and prunes them using events generated during execution of the
dag.
ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DynamicPartitionPruner.java