METHOD_0 ( ) { final byte [ ] value = new byte [ 0 ] ; java . lang . String IDENT_0 = STRING_0 ; org . apache . kafka . connect . util . IDENT_1 < java . lang . String , byte [ ] > IDENT_2 = mock ( org . apache . kafka . connect . util . IDENT_1 . class ) ; org . apache . kafka . connect . storage . IDENT_3 converter = mock ( org . apache . kafka . connect . storage . IDENT_3 . class ) ; final org . apache . kafka . connect . storage . IDENT_4 store = new org . apache . kafka . connect . storage . METHOD_1 ( new org . apache . kafka . common . utils . METHOD_2 ( ) , converter , org . apache . kafka . connect . storage . IDENT_5 . IDENT_6 , IDENT_2 ) ; java . util . Map < java . lang . String , java . lang . Object > IDENT_7 = new java . util . HashMap ( ) ; IDENT_7 . put ( STRING_1 , IDENT_0 ) ; IDENT_7 . put ( STRING_2 , STRING_3 ) ; IDENT_7 . put ( STRING_4 , 1L ) ; java . util . Map < java . lang . String , java . lang . Object > IDENT_8 = new java . util . HashMap ( ) ; IDENT_8 . put ( STRING_1 , org . apache . kafka . connect . storage . IDENT_5 . IDENT_9 ) ; IDENT_8 . put ( STRING_2 , STRING_5 ) ; IDENT_8 . put ( STRING_4 , 0L ) ; expect ( converter . METHOD_3 ( org . apache . kafka . connect . storage . IDENT_5 . IDENT_6 , value ) ) . andReturn ( new org . apache . kafka . connect . data . METHOD_4 ( null , IDENT_7 ) ) . andReturn ( new org . apache . kafka . connect . data . METHOD_4 ( null , IDENT_8 ) ) ; expect ( converter . METHOD_5 ( eq ( org . apache . kafka . connect . storage . IDENT_5 . IDENT_6 ) , METHOD_6 ( org . apache . kafka . connect . data . Schema . class ) , METHOD_6 ( org . apache . kafka . connect . data . IDENT_10 . class ) ) ) . METHOD_7 ( value ) ; final org . easymock . IDENT_11 < org . apache . kafka . IDENT_12 . IDENT_13 . IDENT_14 > IDENT_15 = METHOD_8 ( ) ; IDENT_2 . METHOD_9 ( eq ( STRING_6 ) , eq ( value ) , METHOD_10 ( IDENT_15 ) ) ; METHOD_11 ( ) . METHOD_12 ( new org . easymock . IDENT_16 < java . lang . IDENT_17 > ( ) { @ org . apache . kafka . connect . storage . Override public org . apache . kafka . connect . storage . IDENT_17 METHOD_13 ( ) throws java . lang . Throwable { IDENT_15 . getValue ( ) . METHOD_14 ( null , null ) ; store . read ( org . apache . kafka . connect . storage . IDENT_5 . METHOD_15 ( 1 , STRING_6 , value ) ) ; return null ; } } ) ; METHOD_16 ( ) ; store . read ( org . apache . kafka . connect . storage . IDENT_5 . METHOD_15 ( 0 , STRING_6 , value ) ) ; org . apache . kafka . connect . runtime . IDENT_18 status = new org . apache . kafka . connect . runtime . METHOD_17 ( org . apache . kafka . connect . storage . IDENT_5 . IDENT_19 , METHOD_17 . IDENT_20 . IDENT_21 , org . apache . kafka . connect . storage . IDENT_5 . IDENT_9 , 0 ) ; store . put ( status ) ; "<AssertPlaceHolder>" ; METHOD_18 ( ) ; } get ( org . apache . kafka . connect . data . Field ) { java . lang . Object val = values [ field . index ( ) ] ; if ( ( val == null ) && ( ( field . schema ( ) . METHOD_19 ( ) ) != null ) ) { val = field . schema ( ) . METHOD_19 ( ) ; } return val ; }
org . junit . Assert . assertEquals ( status , store . get ( org . apache . kafka . connect . storage . IDENT_5 . IDENT_19 ) )