In this answer: Batch Size based on Global Table the Queue size is change by a global table. I have a process where queues are filled as they empty by a supply that varies. The operators pulls from queue1 once the downstream queue2 is empty and queue1 has stopped accumulating. So, I see how to have a queue size value changed by a Global Table. Now is the a simple way for a downstream queue's (queue2 and so on) batch size be changed by queue1? Basically, look at value in queue1 when it is time to load queue 2. This way all queues in the stream will have the same batch size value and that set value will change every time the queue1 loads a new batch.