METHOD_0 ( ) { org . apache . hadoop . hbase . client . IDENT_0 p = new org . apache . hadoop . hbase . client . METHOD_1 ( b ( "test" ) ) ; org . apache . hadoop . hbase . IDENT_1 IDENT_2 = new org . apache . hadoop . hbase . METHOD_2 ( b ( "test" ) , b ( STRING_0 ) , b ( STRING_1 ) , java . lang . System . currentTimeMillis ( ) , b ( "value" ) ) ; p . add ( IDENT_2 ) ; client . put ( p ) ; IDENT_3 . IDENT_4 . IDENT_5 . core . client . io . IDENT_6 < org . apache . hadoop . hbase . METHOD_2 > IDENT_7 = IDENT_3 . IDENT_4 . IDENT_5 . core . client . io . IDENT_6 . get ( ) ; IDENT_3 . IDENT_4 . IDENT_5 . core . client . dataset . IDENT_8 < IDENT_3 . IDENT_4 . IDENT_5 . core . client . util . IDENT_9 < org . apache . hadoop . hbase . io . IDENT_10 , org . apache . hadoop . hbase . client . Result > > input = flow . METHOD_3 ( source ) ; IDENT_3 . IDENT_4 . IDENT_5 . core . client . dataset . IDENT_8 < org . apache . hadoop . hbase . IDENT_11 > IDENT_12 = IDENT_3 . IDENT_4 . IDENT_5 . core . client . IDENT_13 . IDENT_14 . of ( input ) . METHOD_4 ( IDENT_3 . IDENT_4 . IDENT_5 . hbase . util . IDENT_15 . METHOD_5 ( ) ) . output ( ) ; IDENT_3 . IDENT_4 . IDENT_5 . core . client . IDENT_13 . IDENT_16 . of ( IDENT_12 ) . METHOD_4 ( ( c ) -> ( ( org . apache . hadoop . hbase . METHOD_2 ) ( c ) ) ) . output ( ) . METHOD_6 ( IDENT_7 ) ; new IDENT_3 . IDENT_4 . IDENT_5 . executor . IDENT_17 . METHOD_7 ( ) . METHOD_8 ( flow ) . join ( ) ; "<AssertPlaceHolder>" ; } METHOD_9 ( ) { return IDENT_18 ; }
org . junit . Assert . assertEquals ( java . util . Collections . singletonList ( IDENT_2 ) , IDENT_7 . METHOD_9 ( ) )