METHOD_0 ( ) { org . apache . beam . sdk . io . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 IDENT_4 = new org . apache . beam . sdk . io . IDENT_0 . IDENT_1 . IDENT_2 . METHOD_1 ( org . apache . beam . sdk . IDENT_5 . IDENT_0 . util . IDENT_6 . METHOD_2 ( IDENT_7 . IDENT_8 . METHOD_3 ( Integer . MAX_VALUE ) . METHOD_4 ( org . joda . time . IDENT_9 . METHOD_5 ( 10 ) ) . METHOD_6 ( org . joda . time . IDENT_9 . METHOD_5 ( 10 ) ) . METHOD_7 ( ) ) ) ; java . util . Set < java . lang . String > IDENT_10 = org . IDENT_11 . collections . IDENT_12 . METHOD_8 ( ) ; for ( int i = 0 ; i < 5 ; i ++ ) { com . google . api . services . IDENT_1 . model . IDENT_13 IDENT_14 = new com . google . api . services . IDENT_1 . model . METHOD_9 ( ) ; IDENT_14 . METHOD_10 ( STRING_0 ) ; org . apache . beam . sdk . io . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_15 IDENT_16 = new org . apache . beam . sdk . io . IDENT_0 . IDENT_1 . IDENT_2 . METHOD_11 ( ( IDENT_17 ) -> { if ( ( new java . util . METHOD_12 ( ) . METHOD_13 ( 2 ) ) == 0 ) { throw new java . lang . RuntimeException ( STRING_1 ) ; } IDENT_14 . METHOD_14 ( new com . google . api . services . IDENT_1 . model . METHOD_15 ( ) . METHOD_16 ( "" ) . METHOD_17 ( "" ) . METHOD_18 ( IDENT_17 . METHOD_19 ( ) ) ) ; return null ; } , ( IDENT_17 ) -> { if ( ( IDENT_17 . METHOD_20 ( ) ) < 5 ) { IDENT_14 . METHOD_21 ( new com . google . api . services . IDENT_1 . model . METHOD_22 ( ) . METHOD_23 ( new com . google . api . services . IDENT_1 . model . METHOD_24 ( ) ) ) ; } else { IDENT_14 . METHOD_21 ( new com . google . api . services . IDENT_1 . model . METHOD_22 ( ) . METHOD_23 ( null ) ) ; } return IDENT_14 ; } , ( IDENT_17 ) -> { if ( IDENT_17 . METHOD_19 ( ) . equals ( IDENT_14 . METHOD_25 ( ) . METHOD_19 ( ) ) ) { return IDENT_14 ; } else { return null ; } } , 100 , ( STRING_2 + i ) ) ; IDENT_4 . METHOD_26 ( IDENT_16 , ( j ) -> { IDENT_10 . add ( j . IDENT_18 . METHOD_19 ( ) ) ; return null ; } ) ; } IDENT_4 . METHOD_27 ( ) ; java . util . Set < java . lang . String > IDENT_19 = org . apache . beam . IDENT_20 . IDENT_21 . IDENT_22 . com . google . common . collect . IDENT_23 . of ( STRING_3 , STRING_4 , STRING_5 , STRING_6 , STRING_7 ) ; "<AssertPlaceHolder>" ; } of ( java . lang . IDENT_24 , org . apache . beam . sdk . options . IDENT_25 , org . apache . beam . runners . IDENT_26 . IDENT_27 . IDENT_28 , org . apache . beam . runners . IDENT_26 . IDENT_27 . IDENT_29 , org . apache . beam . runners . IDENT_26 . IDENT_27 . IDENT_30 ) { return new org . apache . beam . runners . IDENT_26 . IDENT_27 . METHOD_28 ( IDENT_31 , options , context , IDENT_32 , IDENT_33 , org . apache . beam . runners . IDENT_26 . IDENT_27 . METHOD_28 . IDENT_34 ) ; }
org . junit . Assert . assertEquals ( IDENT_19 , IDENT_10 )