METHOD_0 ( ) { IDENT_0 . put ( IDENT_1 . IDENT_2 , org . apache . kafka . common . serialization . IDENT_3 . String ( ) . getClass ( ) ) ; IDENT_0 . put ( IDENT_1 . IDENT_4 , org . apache . kafka . common . serialization . IDENT_3 . String ( ) . getClass ( ) ) ; final org . apache . kafka . streams . IDENT_5 builder = new org . apache . kafka . streams . METHOD_1 ( ) ; final java . lang . String [ ] keys = new java . lang . String [ ] { STRING_0 , STRING_1 , STRING_2 , STRING_3 , STRING_4 } ; final java . util . Set < org . apache . kafka . streams . IDENT_6 < java . lang . String , java . lang . String > > IDENT_7 = new java . util . HashSet ( java . util . Arrays . asList ( new org . apache . kafka . streams . METHOD_2 ( keys [ 0 ] , "1" ) , new org . apache . kafka . streams . METHOD_2 ( keys [ 1 ] , "1" ) , new org . apache . kafka . streams . METHOD_2 ( keys [ 2 ] , STRING_5 ) , new org . apache . kafka . streams . METHOD_2 ( keys [ 3 ] , STRING_6 ) , new org . apache . kafka . streams . METHOD_2 ( keys [ 4 ] , "2" ) ) ) ; org . apache . kafka . streams . integration . utils . IDENT_8 . METHOD_3 ( IDENT_9 , IDENT_7 , org . apache . kafka . test . TestUtils . METHOD_4 ( org . apache . kafka . streams . integration . IDENT_10 . IDENT_11 . METHOD_5 ( ) , org . apache . kafka . common . serialization . IDENT_12 . class , org . apache . kafka . common . serialization . IDENT_12 . class , new java . util . Properties ( ) ) , IDENT_13 ) ; final org . apache . kafka . streams . IDENT_14 . IDENT_15 < java . lang . String , java . lang . String > IDENT_16 = builder . table ( IDENT_9 ) ; IDENT_16 . METHOD_6 ( ( ( org . apache . kafka . streams . IDENT_14 . IDENT_17 < java . lang . String , java . lang . Long > ) ( Long :: valueOf ) ) , org . apache . kafka . streams . IDENT_14 . IDENT_18 . < java . lang . String , java . lang . Long , org . apache . kafka . streams . state . IDENT_19 < org . apache . kafka . common . utils . IDENT_20 , byte [ ] > > as ( STRING_7 ) . METHOD_7 ( org . apache . kafka . common . serialization . IDENT_3 . Long ( ) ) ) . METHOD_8 ( ) . to ( IDENT_21 , org . apache . kafka . streams . IDENT_14 . IDENT_22 . with ( org . apache . kafka . common . serialization . IDENT_3 . String ( ) , org . apache . kafka . common . serialization . IDENT_3 . Long ( ) ) ) ; IDENT_23 = new org . apache . kafka . streams . METHOD_9 ( builder . build ( ) , IDENT_0 ) ; IDENT_23 . start ( ) ; METHOD_10 ( IDENT_21 , 5 ) ; final org . apache . kafka . streams . state . IDENT_24 < java . lang . String , java . lang . Long > IDENT_25 = IDENT_23 . store ( STRING_7 , org . apache . kafka . streams . state . IDENT_26 . METHOD_11 ( ) ) ; for ( final org . apache . kafka . streams . METHOD_2 < java . lang . String , java . lang . String > IDENT_27 : IDENT_7 ) { "<AssertPlaceHolder>" ; } } get ( org . apache . kafka . connect . data . Field ) { java . lang . Object val = values [ field . index ( ) ] ; if ( ( val == null ) && ( ( field . schema ( ) . METHOD_12 ( ) ) != null ) ) { val = field . schema ( ) . METHOD_12 ( ) ; } return val ; }
org . junit . Assert . assertEquals ( java . lang . Long . valueOf ( IDENT_27 . value ) , IDENT_25 . get ( IDENT_27 . key ) )