Hi, there are only *two *interfaces defined at the moment: *OneInputStreamOperator* and *TwoInputStreamOperator.*
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, Dmitry
