BeamPacketizer: Send on batchSize or emitMillis; allow queueSize >= batchSize.