METHOD_0 ( ) { org . apache . beam . runners . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 IDENT_4 = new org . apache . beam . runners . IDENT_0 . IDENT_1 . IDENT_2 . METHOD_1 ( true ) ; java . util . List < org . apache . beam . sdk . IDENT_5 . IDENT_6 . IDENT_7 > IDENT_8 = org . apache . beam . IDENT_9 . IDENT_10 . IDENT_11 . com . google . common . collect . Lists . newArrayList ( new org . apache . beam . sdk . IDENT_5 . IDENT_6 . METHOD_2 ( new org . joda . time . METHOD_3 ( 0 ) , new org . joda . time . METHOD_3 ( 10 ) ) , new org . apache . beam . sdk . IDENT_5 . IDENT_6 . METHOD_2 ( new org . joda . time . METHOD_3 ( 5 ) , new org . joda . time . METHOD_3 ( 15 ) ) ) ; io . IDENT_0 . streaming . IDENT_12 . IDENT_13 . api . IDENT_14 . Context < org . apache . beam . sdk . util . IDENT_15 < java . lang . String > > context = new io . IDENT_0 . streaming . IDENT_12 . IDENT_13 . api . IDENT_14 . Context < org . apache . beam . sdk . util . IDENT_15 < java . lang . String > > ( ) { @ java . lang . Override public java . time . METHOD_3 METHOD_4 ( ) { return METHOD_3 . IDENT_16 ; } @ java . lang . Override public IDENT_15 < java . lang . String > element ( ) { return org . apache . beam . sdk . util . IDENT_15 . of ( STRING_0 , new org . joda . time . METHOD_3 ( 6 ) , IDENT_8 , IDENT_17 . IDENT_18 ) ; } } ; io . IDENT_0 . streaming . IDENT_12 . IDENT_13 . impl . IDENT_19 [ ] result = IDENT_4 . apply ( context ) ; java . util . List < io . IDENT_0 . streaming . IDENT_12 . IDENT_13 . impl . IDENT_19 > expected = org . apache . beam . IDENT_9 . IDENT_10 . IDENT_11 . com . google . common . collect . Lists . newArrayList ( ) ; for ( org . apache . beam . sdk . IDENT_5 . IDENT_6 . IDENT_7 IDENT_20 : IDENT_8 ) { expected . add ( org . apache . beam . runners . IDENT_0 . IDENT_1 . utils . IDENT_21 . METHOD_5 ( IDENT_20 ) ) ; } "<AssertPlaceHolder>" ; } equalTo ( T extends java . io . IDENT_22 ) { return org . apache . beam . sdk . testing . IDENT_23 . METHOD_6 ( ( ) -> org . hamcrest . Matchers . equalTo ( expected ) ) ; }
org . junit . Assert . assertThat ( result , org . hamcrest . Matchers . equalTo ( expected . toArray ( ) ) )