METHOD_0 ( ) { org . apache . flink . runtime . IDENT_0 . IDENT_1 . IDENT_2 IDENT_3 = new org . apache . flink . runtime . IDENT_0 . IDENT_1 . METHOD_1 ( ) ; org . apache . flink . runtime . IDENT_0 . IDENT_4 < java . lang . Long > store = new org . apache . flink . runtime . IDENT_0 . METHOD_2 ( org . apache . flink . runtime . IDENT_0 . IDENT_1 . IDENT_5 . METHOD_3 ( ) , IDENT_3 ) ; final java . util . Collection < java . lang . Long > input = new java . util . HashSet ( ) ; input . add ( 1L ) ; input . add ( INT_0 ) ; input . add ( INT_1 ) ; for ( java . lang . Long IDENT_6 : input ) { store . METHOD_4 ( ( "/" + IDENT_6 ) , IDENT_6 ) ; } org . apache . flink . runtime . IDENT_0 . IDENT_1 . IDENT_5 . METHOD_3 ( ) . METHOD_5 ( ) . METHOD_6 ( ( "/" + 2 ) , new byte [ 2 ] ) ; java . util . List < org . apache . flink . api . java . tuple . IDENT_7 < org . apache . flink . runtime . state . IDENT_8 < java . lang . Long > , java . lang . String > > IDENT_9 = store . METHOD_7 ( ) ; java . util . Collection < java . lang . Long > expected = new java . util . HashSet ( input ) ; expected . remove ( INT_0 ) ; java . util . Collection < java . lang . Long > actual = new java . util . HashSet ( expected . size ( ) ) ; for ( org . apache . flink . api . java . tuple . IDENT_7 < org . apache . flink . runtime . state . IDENT_8 < java . lang . Long > , java . lang . String > entry : IDENT_9 ) { actual . add ( entry . IDENT_10 . METHOD_8 ( ) ) ; } "<AssertPlaceHolder>" ; } METHOD_8 ( ) { try ( org . apache . flink . core . fs . IDENT_11 in = METHOD_9 ( ) ) { return org . apache . flink . util . IDENT_12 . METHOD_10 ( in , java . lang . Thread . METHOD_11 ( ) . METHOD_12 ( ) ) ; } }
org . junit . Assert . assertEquals ( expected , actual )