METHOD_0 ( ) { java . util . List < com . google . IDENT_0 . IDENT_1 > messages = com . streamsets . pipeline . lib . util . IDENT_2 . METHOD_1 ( IDENT_3 , IDENT_4 , com . streamsets . pipeline . lib . util . IDENT_2 . METHOD_2 ( ) ) ; for ( int i = 0 ; i < ( messages . size ( ) ) ; i ++ ) { com . google . IDENT_0 . IDENT_1 m = messages . get ( i ) ; com . streamsets . pipeline . api . IDENT_5 record = com . streamsets . pipeline . sdk . IDENT_6 . create ( ) ; com . streamsets . pipeline . api . Field field = com . streamsets . pipeline . lib . util . IDENT_7 . METHOD_3 ( record , "" , IDENT_3 , IDENT_8 , m ) ; "<AssertPlaceHolder>" ; com . streamsets . pipeline . lib . util . IDENT_2 . METHOD_4 ( field , i ) ; } } METHOD_3 ( com . streamsets . pipeline . api . IDENT_5 , java . lang . String , com . google . IDENT_0 . IDENT_9 , java . util . Map , java . lang . Object ) { java . util . IDENT_10 < java . lang . String , com . streamsets . pipeline . api . Field > IDENT_11 = new java . util . METHOD_5 ( ) ; java . util . Map < java . lang . String , com . google . IDENT_0 . IDENT_12 . IDENT_13 > IDENT_14 = new java . util . METHOD_5 ( ) ; for ( com . google . IDENT_0 . IDENT_12 . IDENT_13 IDENT_15 : IDENT_16 . METHOD_6 ( ) ) { IDENT_14 . put ( IDENT_15 . getName ( ) , IDENT_15 ) ; } java . util . Map < com . google . IDENT_0 . IDENT_12 . IDENT_13 , java . lang . Object > values = ( ( com . google . IDENT_0 . IDENT_1 ) ( message ) ) . METHOD_7 ( ) ; for ( com . google . IDENT_0 . IDENT_12 . IDENT_13 IDENT_15 : IDENT_14 . values ( ) ) { java . lang . Object value = values . get ( IDENT_15 ) ; IDENT_11 . put ( IDENT_15 . getName ( ) , com . streamsets . pipeline . lib . util . IDENT_7 . METHOD_8 ( record , IDENT_17 , IDENT_15 , IDENT_18 , value ) ) ; } if ( IDENT_18 . containsKey ( IDENT_16 . METHOD_9 ( ) ) ) { for ( com . google . IDENT_0 . IDENT_12 . IDENT_13 IDENT_15 : IDENT_18 . get ( IDENT_16 . METHOD_9 ( ) ) ) { if ( values . containsKey ( IDENT_15 ) ) { java . lang . Object value = values . get ( IDENT_15 ) ; IDENT_11 . put ( IDENT_15 . getName ( ) , com . streamsets . pipeline . lib . util . IDENT_7 . METHOD_8 ( record , IDENT_17 , IDENT_15 , IDENT_18 , value ) ) ; } } } com . google . IDENT_0 . IDENT_19 IDENT_20 = ( ( com . google . IDENT_0 . IDENT_1 ) ( message ) ) . METHOD_10 ( ) ; if ( ! ( IDENT_20 . METHOD_11 ( ) . isEmpty ( ) ) ) { java . io . ByteArrayOutputStream IDENT_21 = new java . io . ByteArrayOutputStream ( ) ; try { IDENT_20 . METHOD_12 ( IDENT_21 ) ; IDENT_21 . METHOD_13 ( ) ; IDENT_21 . close ( ) ; } catch ( java . io . IOException e ) { throw new com . streamsets . pipeline . lib . parser . METHOD_14 ( com . streamsets . pipeline . lib . parser . IDENT_0 . IDENT_22 . IDENT_23 , e . toString ( ) , e ) ; } java . lang . String path = ( IDENT_17 . isEmpty ( ) ) ? com . streamsets . pipeline . lib . util . IDENT_7 . IDENT_24 : IDENT_17 ; byte [ ] bytes = org . apache . commons . codec . IDENT_25 . IDENT_26 . METHOD_15 ( IDENT_21 . toByteArray ( ) ) ; record . METHOD_16 ( ) . METHOD_17 ( ( ( com . streamsets . pipeline . lib . util . IDENT_7 . IDENT_27 ) + path ) , new java . lang . String ( bytes , java . nio . IDENT_28 . IDENT_29 . UTF_8 ) ) ; } return com . streamsets . pipeline . api . Field . METHOD_18 ( IDENT_11 ) ; }
org . junit . Assert . assertNotNull ( field )