METHOD_0 ( ) { for ( int IDENT_0 = 0 ; IDENT_0 < 10 ; IDENT_0 ++ ) { int IDENT_1 = new java . util . METHOD_1 ( ) . METHOD_2 ( INT_0 ) ; org . apache . flink . runtime . io . IDENT_2 . IDENT_3 . IDENT_4 . IDENT_5 channel = IDENT_6 . METHOD_3 ( ) ; org . apache . flink . runtime . io . IDENT_2 . IDENT_3 . IDENT_7 writer = this . IDENT_6 . METHOD_4 ( channel ) ; org . apache . flink . table . runtime . io . IDENT_8 IDENT_9 = new org . apache . flink . table . runtime . io . METHOD_5 ( writer , IDENT_10 , org . apache . flink . table . runtime . io . IDENT_11 . IDENT_12 ) ; for ( int i = 0 ; i < IDENT_1 ; i ++ ) { IDENT_9 . METHOD_6 ( i ) ; } IDENT_9 . close ( ) ; int IDENT_13 = IDENT_9 . METHOD_7 ( ) ; org . apache . flink . table . runtime . io . IDENT_14 IDENT_15 = new org . apache . flink . table . runtime . io . METHOD_8 ( channel , IDENT_6 , IDENT_10 , org . apache . flink . table . runtime . io . IDENT_11 . IDENT_12 , IDENT_13 ) ; for ( int i = 0 ; i < IDENT_1 ; i ++ ) { "<AssertPlaceHolder>" ; } IDENT_15 . close ( ) ; } } METHOD_9 ( ) { final int v = this . IDENT_16 . METHOD_10 ( this . position ) ; this . position += 4 ; return v ; }
org . junit . Assert . assertEquals ( i , IDENT_15 . METHOD_9 ( ) )