METHOD_0 ( ) { METHOD_1 ( ) ; org . apache . IDENT_0 . IDENT_1 pipeline = new org . apache . IDENT_0 . impl . IDENT_2 . METHOD_2 ( org . apache . IDENT_0 . io . IDENT_3 . IDENT_4 . class , conf ) ; int [ ] IDENT_5 = new int [ ] { 0 , 1 } ; org . apache . IDENT_0 . io . IDENT_3 . IDENT_6 < org . apache . IDENT_0 . test . IDENT_3 . IDENT_7 . Person > source = new org . apache . IDENT_0 . io . IDENT_3 . IDENT_6 < org . apache . IDENT_0 . test . IDENT_3 . IDENT_7 . Person > ( new org . apache . hadoop . fs . Path ( IDENT_8 , STRING_0 ) , org . apache . IDENT_0 . types . IDENT_3 . IDENT_9 . METHOD_3 ( org . apache . IDENT_0 . test . IDENT_3 . IDENT_7 . Person . class ) , IDENT_5 ) ; org . apache . IDENT_0 . IDENT_10 < org . apache . IDENT_0 . test . IDENT_3 . IDENT_7 . Person > IDENT_11 = pipeline . read ( source ) ; java . util . List < org . apache . IDENT_0 . test . IDENT_3 . IDENT_7 . Person > result = com . google . common . collect . Lists . newArrayList ( IDENT_11 . METHOD_4 ( ) ) ; org . apache . IDENT_0 . test . IDENT_3 . IDENT_7 . Person expected = new org . apache . IDENT_0 . test . IDENT_3 . IDENT_7 . Person ( STRING_1 , INT_0 , null ) ; "<AssertPlaceHolder>" ; } METHOD_4 ( ) { try { IDENT_12 = source . read ( pipeline . METHOD_5 ( ) ) ; } catch ( java . io . IOException e ) { org . apache . IDENT_0 . METHOD_4 . IDENT_13 . LOG . error ( STRING_2 , source , e ) ; throw new org . apache . IDENT_0 . METHOD_6 ( e ) ; } }
org . junit . Assert . assertEquals ( com . google . common . collect . Lists . newArrayList ( expected ) , result )