METHOD_0 ( ) { final java . util . Map < org . apache . kafka . streams . IDENT_0 . IDENT_1 < java . lang . String > , java . lang . Long > results = new java . util . HashMap ( ) ; final org . apache . kafka . streams . IDENT_0 . IDENT_2 < org . apache . kafka . streams . IDENT_0 . IDENT_1 < java . lang . String > , java . lang . Long > table = IDENT_3 . METHOD_1 ( org . apache . kafka . streams . IDENT_0 . IDENT_4 . with ( METHOD_2 ( INT_0 ) ) ) . count ( org . apache . kafka . streams . IDENT_0 . IDENT_5 . as ( STRING_0 ) ) ; table . METHOD_3 ( ) . METHOD_4 ( results :: put ) ; METHOD_5 ( results ) ; "<AssertPlaceHolder>" ; } METHOD_6 ( ) { return IDENT_6 ? METHOD_7 ( ) : null ; }
org . junit . Assert . assertEquals ( table . METHOD_6 ( ) , STRING_0 )