METHOD_0 ( ) { java . lang . String key = STRING_0 ; redis . IDENT_0 . IDENT_1 . IDENT_2 IDENT_1 = org . apache . beam . sdk . io . redis . IDENT_3 . create ( org . apache . beam . sdk . io . redis . IDENT_4 . IDENT_5 , IDENT_6 . METHOD_1 ( ) ) . connect ( ) ; org . apache . beam . sdk . values . IDENT_7 < org . apache . beam . sdk . values . IDENT_8 < java . lang . String , java . lang . String > > write = IDENT_9 . apply ( org . apache . beam . sdk . IDENT_10 . IDENT_11 . of ( org . apache . beam . sdk . values . IDENT_8 . of ( key , STRING_1 ) , org . apache . beam . sdk . values . IDENT_8 . of ( key , "1" ) , org . apache . beam . sdk . values . IDENT_8 . of ( key , "2" ) , org . apache . beam . sdk . values . IDENT_8 . of ( key , STRING_2 ) , org . apache . beam . sdk . values . IDENT_8 . of ( key , "2" ) , org . apache . beam . sdk . values . IDENT_8 . of ( key , STRING_3 ) , org . apache . beam . sdk . values . IDENT_8 . of ( key , STRING_1 ) , org . apache . beam . sdk . values . IDENT_8 . of ( key , STRING_4 ) ) ) ; write . apply ( org . apache . beam . sdk . io . redis . IDENT_12 . write ( ) . METHOD_2 ( org . apache . beam . sdk . io . redis . IDENT_4 . IDENT_5 , IDENT_6 . METHOD_1 ( ) ) . METHOD_3 ( Method . IDENT_13 ) ) ; IDENT_9 . run ( ) ; long count = IDENT_1 . METHOD_4 ( key ) ; "<AssertPlaceHolder>" ; } run ( ) { METHOD_5 ( ) ; }
org . junit . Assert . assertEquals ( 6 , count )