METHOD_0 ( ) { io . cdap . cdap . IDENT_0 . IDENT_1 IDENT_2 = new io . cdap . cdap . IDENT_0 . IDENT_1 . Builder ( ) . setName ( STRING_0 ) . build ( ) ; METHOD_1 ( ) . create ( IDENT_2 ) ; io . cdap . cdap . IDENT_0 . id . IDENT_3 IDENT_4 = IDENT_2 . METHOD_2 ( ) . dataset ( STRING_1 ) ; METHOD_3 ( io . cdap . cdap . api . dataset . lib . IDENT_5 . class . getName ( ) , IDENT_4 , io . cdap . cdap . api . dataset . lib . IDENT_6 . builder ( ) . METHOD_4 ( org . apache . hadoop . mapreduce . lib . input . IDENT_7 . class ) . build ( ) ) ; io . cdap . cdap . IDENT_0 . IDENT_1 IDENT_8 = new io . cdap . cdap . IDENT_0 . IDENT_1 . Builder ( ) . setName ( STRING_2 ) . build ( ) ; METHOD_1 ( ) . create ( IDENT_8 ) ; METHOD_3 ( IDENT_8 . METHOD_2 ( ) . dataset ( STRING_3 ) , STRING_4 ) ; org . apache . IDENT_9 . IDENT_10 . IDENT_11 IDENT_12 = this . < io . cdap . cdap . api . dataset . lib . IDENT_5 > METHOD_5 ( IDENT_4 ) . get ( ) . METHOD_6 ( STRING_5 ) ; try ( java . io . IDENT_13 IDENT_14 = new java . io . METHOD_7 ( IDENT_12 . METHOD_8 ( ) , true , STRING_6 ) ) { for ( int i = 0 ; i < 50 ; i ++ ) { IDENT_14 . println ( java . lang . String . valueOf ( i ) ) ; } } io . cdap . cdap . test . IDENT_15 IDENT_16 = METHOD_9 ( IDENT_17 . IDENT_18 , io . cdap . cdap . spark . app . IDENT_19 . class ) ; java . util . Map < java . lang . String , java . lang . String > args = new java . util . HashMap ( ) ; args . put ( io . cdap . cdap . spark . app . IDENT_20 . METHOD_10 ( ) , IDENT_2 . METHOD_2 ( ) . METHOD_11 ( ) ) ; args . put ( io . cdap . cdap . spark . app . IDENT_20 . METHOD_12 ( ) , IDENT_8 . METHOD_2 ( ) . METHOD_11 ( ) ) ; args . put ( io . cdap . cdap . spark . app . IDENT_20 . METHOD_13 ( ) , STRING_3 ) ; io . cdap . cdap . api . dataset . lib . IDENT_21 . METHOD_14 ( args , STRING_5 ) ; io . cdap . cdap . test . IDENT_22 IDENT_23 = IDENT_16 . METHOD_15 ( io . cdap . cdap . spark . app . IDENT_20 . class . METHOD_16 ( ) ) . start ( args ) ; IDENT_23 . METHOD_17 ( IDENT_24 . IDENT_25 , 10 , TimeUnit . IDENT_26 ) ; IDENT_23 . METHOD_18 ( INT_0 , TimeUnit . IDENT_26 ) ; io . cdap . cdap . test . IDENT_27 < io . cdap . cdap . api . dataset . lib . IDENT_28 > IDENT_29 = METHOD_5 ( IDENT_8 . METHOD_2 ( ) . dataset ( STRING_3 ) ) ; io . cdap . cdap . api . dataset . lib . IDENT_28 results = IDENT_29 . get ( ) ; for ( int i = 0 ; i < 50 ; i ++ ) { byte [ ] key = java . lang . String . valueOf ( i ) . getBytes ( IDENT_30 . UTF_8 ) ; "<AssertPlaceHolder>" ; } } read ( java . lang . String ) { byte [ ] read = IDENT_31 . read ( key ) ; return read == null ? null : io . cdap . cdap . api . common . IDENT_32 . METHOD_19 ( read ) ; }
org . junit . Assert . assertArrayEquals ( key , results . read ( key ) )