METHOD_0 ( ) { org . apache . beam . sdk . values . IDENT_0 < java . lang . String > IDENT_1 = new org . apache . beam . sdk . values . IDENT_0 < java . lang . String > ( STRING_0 ) { } ; org . apache . beam . sdk . values . IDENT_0 < java . lang . String > IDENT_2 = new org . apache . beam . sdk . values . IDENT_0 < java . lang . String > ( STRING_1 ) { } ; org . junit . rules . IDENT_3 IDENT_4 = new org . junit . rules . METHOD_1 ( ) ; IDENT_4 . create ( ) ; pipeline . apply ( org . apache . beam . sdk . IDENT_5 . IDENT_6 . of ( STRING_2 , STRING_3 , STRING_4 ) ) . apply ( org . apache . beam . sdk . IDENT_5 . IDENT_7 . of ( new org . apache . beam . sdk . IDENT_5 . IDENT_8 < java . lang . String , java . lang . String > ( ) { @ com . google . cloud . IDENT_9 . IDENT_10 . common . IDENT_11 public void METHOD_2 ( com . google . cloud . IDENT_9 . IDENT_10 . common . IDENT_12 c ) { if ( c . element ( ) . equals ( STRING_2 ) ) { c . output ( c . element ( ) ) ; } else { c . output ( IDENT_1 , c . element ( ) ) ; } } } ) . METHOD_3 ( IDENT_2 , org . apache . beam . sdk . values . IDENT_13 . of ( IDENT_1 ) ) ) . apply ( IDENT_14 . IDENT_15 . METHOD_4 ( ) . METHOD_5 ( org . apache . beam . sdk . options . IDENT_16 . IDENT_17 . of ( ( ( IDENT_4 . METHOD_6 ( ) . getAbsolutePath ( ) ) + STRING_5 ) ) ) . METHOD_7 ( IDENT_1 ) . build ( ) ) ; pipeline . run ( ) ; java . io . File file = new java . io . File ( ( ( IDENT_4 . METHOD_6 ( ) . getAbsolutePath ( ) ) + STRING_6 ) ) ; java . lang . String IDENT_18 = com . google . common . io . IDENT_19 . toString ( file , IDENT_20 . UTF_8 ) ; IDENT_4 . delete ( ) ; java . util . HashSet < java . lang . String > expected = new java . util . HashSet ( ) ; java . util . Collections . addAll ( expected , STRING_3 , STRING_4 ) ; java . util . HashSet < java . lang . String > result = new java . util . HashSet ( ) ; java . util . Collections . addAll ( result , IDENT_18 . split ( "\n" ) ) ; "<AssertPlaceHolder>" ; } toString ( com . google . cloud . IDENT_21 . Type , boolean ) { switch ( IDENT_22 . getCode ( ) ) { case IDENT_23 : return STRING_7 ; case IDENT_24 : return STRING_8 ; case IDENT_25 : return STRING_9 ; case IDENT_26 : return STRING_10 ; case IDENT_27 : return STRING_11 ; case IDENT_28 : return STRING_12 ; case IDENT_29 : return STRING_13 ; case IDENT_30 : { if ( IDENT_31 ) { com . google . cloud . IDENT_21 . Type element = IDENT_22 . METHOD_8 ( ) ; java . lang . String IDENT_32 = toString ( element , false ) ; return ( STRING_14 + IDENT_32 ) + STRING_15 ; } break ; } } throw new java . lang . IllegalArgumentException ( ( STRING_16 + IDENT_22 ) ) ; }
org . junit . Assert . assertEquals ( expected , result )