METHOD_0 ( ) { final int IDENT_0 = 6 ; final int IDENT_1 = 2 ; org . apache . beam . sdk . io . IDENT_2 . IDENT_3 transform = org . apache . beam . sdk . io . IDENT_2 . from ( new org . apache . beam . runners . flink . IDENT_4 . METHOD_1 ( ) ) ; org . apache . flink . streaming . api . IDENT_5 . IDENT_6 IDENT_7 = org . apache . flink . streaming . api . IDENT_5 . IDENT_6 . METHOD_2 ( ) ; IDENT_7 . METHOD_3 ( IDENT_1 ) ; IDENT_7 . METHOD_4 ( IDENT_0 ) ; org . apache . flink . streaming . api . IDENT_8 . IDENT_9 < ? > IDENT_10 = METHOD_5 ( transform , IDENT_11 . IDENT_12 . IDENT_13 , IDENT_7 ) ; org . apache . beam . runners . flink . IDENT_14 . IDENT_15 . streaming . io . IDENT_16 source = ( ( org . apache . beam . runners . flink . IDENT_14 . IDENT_15 . streaming . io . IDENT_16 ) ( ( ( org . apache . flink . streaming . api . IDENT_8 . IDENT_17 ) ( ( ( org . apache . flink . streaming . api . IDENT_8 . IDENT_18 ) ( IDENT_10 ) ) . METHOD_6 ( ) ) ) . METHOD_7 ( ) . METHOD_8 ( ) ) ) ; "<AssertPlaceHolder>" ; } METHOD_9 ( ) { return IDENT_19 ; }
org . junit . Assert . assertEquals ( IDENT_0 , source . METHOD_9 ( ) . size ( ) )