METHOD_0 ( ) { @ org . apache . beam . runners . spark . IDENT_0 . METHOD_1 ( STRING_0 ) java . lang . IDENT_1 < org . apache . beam . sdk . util . IDENT_2 < java . lang . Integer > > IDENT_3 = java . util . Arrays . asList ( METHOD_2 ( 0 ) , METHOD_2 ( 1 ) , METHOD_2 ( 3 ) , METHOD_2 ( 4 ) ) ; final org . apache . beam . sdk . util . IDENT_2 . IDENT_4 < java . lang . Integer > IDENT_5 = IDENT_2 . IDENT_4 . of ( org . apache . beam . sdk . IDENT_6 . IDENT_7 . of ( ) , IDENT_8 . IDENT_9 . INSTANCE ) ; final org . apache . beam . sdk . IDENT_6 . IDENT_10 < org . apache . beam . sdk . util . IDENT_2 < java . lang . Integer > > IDENT_11 = org . apache . beam . sdk . IDENT_6 . IDENT_10 . of ( IDENT_5 ) ; org . apache . beam . runners . spark . IDENT_0 . IDENT_12 . IDENT_13 < java . lang . Integer > IDENT_14 = org . apache . beam . runners . spark . IDENT_0 . IDENT_12 . IDENT_13 . of ( IDENT_3 , IDENT_11 ) ; java . io . ByteArrayOutputStream IDENT_15 = new java . io . ByteArrayOutputStream ( ) ; java . io . IDENT_16 IDENT_17 = new java . io . METHOD_3 ( IDENT_15 ) ; IDENT_17 . METHOD_4 ( IDENT_14 ) ; java . io . IDENT_18 IDENT_19 = new java . io . METHOD_5 ( new java . io . ByteArrayInputStream ( IDENT_15 . toByteArray ( ) ) ) ; @ org . apache . beam . runners . spark . IDENT_0 . METHOD_1 ( STRING_0 ) org . apache . beam . runners . spark . IDENT_0 . IDENT_12 . IDENT_13 < java . lang . Integer > IDENT_20 = ( ( org . apache . beam . runners . spark . IDENT_0 . IDENT_12 . IDENT_13 < java . lang . Integer > ) ( IDENT_19 . METHOD_6 ( ) ) ) ; "<AssertPlaceHolder>" ; } METHOD_7 ( org . apache . beam . sdk . IDENT_6 . IDENT_9 ) { if ( ! ( ( IDENT_21 ) instanceof org . apache . beam . sdk . IDENT_6 . IDENT_9 ) ) { java . io . ByteArrayInputStream IDENT_22 = new java . io . ByteArrayInputStream ( ( ( byte [ ] ) ( this . IDENT_21 ) ) ) ; try { value = IDENT_23 . decode ( IDENT_22 ) ; } catch ( java . io . IOException e ) { throw new java . lang . IllegalStateException ( ( STRING_1 + IDENT_23 ) , e ) ; } this . IDENT_21 = IDENT_23 ; } return value ; }
org . junit . Assert . assertEquals ( IDENT_3 , IDENT_20 . METHOD_7 ( IDENT_11 ) )