METHOD_0 ( ) { final org . apache . flink . table . api . IDENT_0 schema = METHOD_1 ( ) ; final org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_4 IDENT_5 = new org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_3 . METHOD_2 ( false , schema , java . util . Collections . singletonList ( new org . apache . flink . streaming . IDENT_1 . elasticsearch . IDENT_6 . METHOD_3 ( IDENT_7 , IDENT_8 , IDENT_9 ) ) , IDENT_10 , IDENT_11 , IDENT_12 , IDENT_13 , new org . apache . flink . IDENT_14 . json . METHOD_4 ( schema . METHOD_5 ( ) ) , org . elasticsearch . common . IDENT_15 . IDENT_16 . IDENT_17 , new org . apache . flink . streaming . IDENT_1 . IDENT_2 . METHOD_6 ( ) , METHOD_7 ( ) ) ; final org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_18 IDENT_19 = new org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_3 . METHOD_8 ( new org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_3 . METHOD_9 ( ) , org . apache . flink . api . common . IDENT_20 . IDENT_21 . METHOD_10 ( IDENT_21 . IDENT_22 , schema . METHOD_5 ( ) ) ) ; IDENT_5 . METHOD_11 ( IDENT_19 ) ; final IDENT_23 . Builder < org . apache . flink . api . java . tuple . IDENT_24 < java . lang . Boolean , org . apache . flink . types . IDENT_25 > > IDENT_26 = new org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_23 . Builder < > ( java . util . Collections . singletonList ( new < org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_7 , org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_8 , org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_9 > org . apache . http . METHOD_12 ( ) ) , new < org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_10 , org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_11 , org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_12 , org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_13 > org . apache . flink . streaming . IDENT_1 . elasticsearch . IDENT_6 . METHOD_13 ( new org . apache . flink . IDENT_14 . json . METHOD_4 ( schema . METHOD_5 ( ) ) , IDENT_16 . IDENT_17 , IDENT_27 . IDENT_28 , new int [ 0 ] ) ) ; IDENT_26 . METHOD_14 ( new org . apache . flink . streaming . IDENT_1 . IDENT_2 . METHOD_6 ( ) ) ; IDENT_26 . METHOD_15 ( true ) ; IDENT_26 . METHOD_16 ( IDENT_29 . IDENT_30 . IDENT_31 ) ; IDENT_26 . METHOD_17 ( INT_0 ) ; IDENT_26 . METHOD_18 ( 3 ) ; IDENT_26 . METHOD_19 ( 100 ) ; IDENT_26 . METHOD_20 ( 1000 ) ; IDENT_26 . METHOD_21 ( 1 ) ; IDENT_26 . METHOD_22 ( new org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_27 . METHOD_23 ( 100 , STRING_0 ) ) ; "<AssertPlaceHolder>" ; } METHOD_21 ( int ) { org . apache . flink . util . IDENT_32 . METHOD_24 ( ( IDENT_33 > 0 ) , STRING_1 ) ; this . IDENT_34 . put ( org . apache . flink . streaming . IDENT_1 . IDENT_2 . IDENT_35 , java . lang . String . valueOf ( IDENT_33 ) ) ; }
org . junit . Assert . assertEquals ( IDENT_26 , IDENT_5 . builder )