public static < IN , OUT > SingleOutputStreamOperator < OUT > orderedWait ( DataStream < IN > in , AsyncFunction < IN , OUT > func , long timeout , TimeUnit timeUnit , int capacity ) { return addOperator ( in , func , timeUnit . toMillis ( timeout ) , capacity , OutputMode . ORDERED ) ; }
Add an AsyncWaitOperator . The order to process input records is guaranteed to be the same as input ones .