METHOD_0 ( ) { com . google . IDENT_0 . IDENT_1 IDENT_2 = METHOD_1 ( io . cdap . cdap . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 . class ) . METHOD_2 ( ) ; org . apache . IDENT_7 . IDENT_8 . IDENT_9 IDENT_10 = IDENT_2 . getInstance ( org . apache . IDENT_7 . IDENT_8 . IDENT_9 . class ) ; io . cdap . cdap . IDENT_11 . id . IDENT_12 IDENT_13 = IDENT_14 . IDENT_15 . METHOD_3 ( "test" ) ; io . cdap . cdap . IDENT_16 . IDENT_17 IDENT_18 = new io . cdap . cdap . IDENT_16 . client . METHOD_4 ( IDENT_10 ) ; IDENT_18 . METHOD_5 ( new io . cdap . cdap . IDENT_16 . METHOD_6 ( IDENT_13 ) ) ; java . util . List < java . lang . String > messages = new java . util . ArrayList ( ) ; for ( int i = 0 ; i < 10 ; i ++ ) { java . lang . String msg = STRING_0 + i ; IDENT_18 . METHOD_7 ( io . cdap . cdap . IDENT_16 . client . IDENT_19 . of ( IDENT_13 ) . METHOD_8 ( msg ) . build ( ) ) ; messages . add ( msg ) ; } try ( io . cdap . cdap . api . dataset . lib . IDENT_20 < io . cdap . cdap . IDENT_16 . data . IDENT_21 > iterator = IDENT_18 . METHOD_9 ( IDENT_13 ) . METHOD_10 ( 10 ) . METHOD_11 ( ) ) { java . util . List < java . lang . String > IDENT_22 = java . util . stream . IDENT_23 . stream ( java . util . IDENT_24 . METHOD_12 ( iterator , 0 ) , false ) . map ( IDENT_21 :: IDENT_25 ) . map ( ByteBuffer :: IDENT_26 ) . map ( java . nio . IDENT_27 . IDENT_28 . UTF_8 :: decode ) . map ( IDENT_29 :: toString ) . collect ( java . util . stream . IDENT_30 . toList ( ) ) ; "<AssertPlaceHolder>" ; } } METHOD_11 ( ) { io . cdap . cdap . IDENT_16 . store . IDENT_31 IDENT_32 = IDENT_33 . get ( ) ; try { return new io . cdap . cdap . IDENT_16 . service . IDENT_34 . METHOD_13 ( IDENT_32 ) ; } catch ( java . lang . Throwable t ) { METHOD_14 ( IDENT_32 ) ; throw t ; } }
org . junit . Assert . assertEquals ( messages , IDENT_22 )