flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dmitry Golubets <dgolub...@gmail.com>
Subject Three input stream operator and back pressure
Date Mon, 16 Jan 2017 23:20:43 GMT

there are only *two *interfaces defined at the moment:

Is there any way to define an operator with arbitrary number of inputs?

My another concern is how to maintain *backpressure *in the operator?
Let's say I read events from two Kafka sources, both of which are ordered
by time. I want to merge them keeping the global order. But to do it, I
need to stop block one input if another one has no data yet.

Best regards,

View raw message