METHOD_0 ( ) { java . util . List < org . apache . flink . api . java . tuple . IDENT_0 < byte [ ] , byte [ ] > > data = new java . util . ArrayList ( INT_0 ) ; for ( int i = 0 ; i < INT_0 ; ++ i ) { data . add ( new org . apache . flink . api . java . tuple . METHOD_1 ( ( STRING_0 + i ) . getBytes ( ) , ( STRING_1 + i ) . getBytes ( ) ) ) ; } try ( org . IDENT_1 . IDENT_2 db = org . IDENT_1 . IDENT_2 . METHOD_2 ( IDENT_3 . METHOD_3 ( ) . getAbsolutePath ( ) ) ; org . IDENT_1 . IDENT_4 options = new org . IDENT_1 . METHOD_4 ( ) . METHOD_5 ( true ) ; org . IDENT_1 . IDENT_5 IDENT_6 = db . METHOD_6 ( new org . IDENT_1 . METHOD_7 ( "test" . getBytes ( ) ) ) ; org . apache . flink . IDENT_7 . streaming . state . IDENT_8 IDENT_9 = new org . apache . flink . IDENT_7 . streaming . state . METHOD_8 ( db , options , 200 ) ) { for ( org . apache . flink . api . java . tuple . METHOD_1 < byte [ ] , byte [ ] > item : data ) { IDENT_9 . put ( IDENT_6 , item . IDENT_10 , item . IDENT_11 ) ; } IDENT_9 . METHOD_9 ( ) ; for ( org . apache . flink . api . java . tuple . METHOD_1 < byte [ ] , byte [ ] > item : data ) { "<AssertPlaceHolder>" ; } } } get ( long , java . util . concurrent . TimeUnit ) { return delegate . get ( IDENT_12 , unit ) ; }
org . junit . Assert . assertArrayEquals ( item . IDENT_11 , db . get ( IDENT_6 , item . IDENT_10 ) )