METHOD_0 ( ) { org . apache . avro . Schema schema = new org . apache . avro . Schema . METHOD_1 ( ) . parse ( org . apache . beam . IDENT_0 . IDENT_1 . IDENT_2 . com . google . common . io . IDENT_3 . getResource ( STRING_0 ) . METHOD_2 ( ) ) ; org . apache . avro . IDENT_4 . IDENT_5 IDENT_6 = new org . apache . avro . IDENT_4 . IDENT_7 . METHOD_3 ( schema ) ; IDENT_6 . put ( "name" , STRING_1 ) ; IDENT_6 . put ( STRING_2 , INT_0 ) ; IDENT_6 . put ( STRING_3 , org . apache . beam . IDENT_0 . IDENT_1 . IDENT_2 . com . google . common . collect . Lists . newArrayList ( STRING_4 , STRING_5 ) ) ; METHOD_4 ( org . apache . beam . IDENT_0 . IDENT_1 . IDENT_2 . com . google . common . collect . Lists . newArrayList ( IDENT_6 ) , schema ) ; org . apache . beam . sdk . values . IDENT_8 < org . apache . avro . IDENT_4 . IDENT_5 > input = pipeline . apply ( org . apache . beam . sdk . io . IDENT_9 . METHOD_5 ( schema ) . from ( IDENT_10 . getAbsolutePath ( ) ) ) ; input . apply ( org . apache . beam . sdk . io . IDENT_9 . METHOD_6 ( schema ) . to ( IDENT_11 . getAbsolutePath ( ) ) ) ; pipeline . run ( ) ; java . util . List < org . apache . avro . IDENT_4 . IDENT_5 > records = METHOD_7 ( ) ; "<AssertPlaceHolder>" ; } METHOD_7 ( ) { java . util . List < org . apache . avro . IDENT_4 . IDENT_5 > records = org . apache . beam . IDENT_0 . IDENT_1 . IDENT_2 . com . google . common . collect . Lists . newArrayList ( ) ; org . apache . avro . IDENT_4 . IDENT_12 < org . apache . avro . IDENT_4 . IDENT_5 > IDENT_13 = new org . apache . avro . IDENT_4 . METHOD_8 ( ) ; try ( org . apache . avro . file . IDENT_14 < org . apache . avro . IDENT_4 . IDENT_5 > IDENT_15 = new org . apache . avro . file . METHOD_9 ( new java . io . File ( ( ( IDENT_11 ) + STRING_6 ) ) , IDENT_13 ) ) { for ( org . apache . avro . IDENT_4 . IDENT_5 record : IDENT_15 ) { records . add ( record ) ; } } return records ; }
org . junit . Assert . assertEquals ( org . apache . beam . IDENT_0 . IDENT_1 . IDENT_2 . com . google . common . collect . Lists . newArrayList ( IDENT_6 ) , records )