METHOD_0 ( ) { org . apache . beam . sdk . IDENT_0 p = org . apache . beam . sdk . IDENT_0 . create ( options ) ; p . apply ( org . apache . beam . sdk . io . IDENT_1 . from ( 0 ) . to ( IDENT_2 ) ) . apply ( org . apache . beam . sdk . IDENT_3 . IDENT_4 . of ( new org . apache . beam . sdk . io . IDENT_5 . datastore . IDENT_6 . METHOD_1 ( options . METHOD_2 ( ) , options . METHOD_3 ( ) , IDENT_7 , 0 ) ) ) . apply ( org . apache . beam . sdk . io . IDENT_5 . datastore . IDENT_8 . v1 ( ) . write ( ) . METHOD_4 ( project ) ) ; p . run ( ) ; long IDENT_9 = org . apache . beam . sdk . io . IDENT_5 . datastore . IDENT_6 . METHOD_5 ( options , project , IDENT_7 ) ; "<AssertPlaceHolder>" ; } METHOD_5 ( org . apache . beam . sdk . io . IDENT_5 . datastore . IDENT_10 , java . lang . String , java . lang . String ) { com . google . datastore . v1 . client . IDENT_11 datastore = org . apache . beam . sdk . io . IDENT_5 . datastore . IDENT_6 . METHOD_6 ( options , project ) ; com . google . datastore . v1 . Query query = org . apache . beam . sdk . io . IDENT_5 . datastore . IDENT_6 . METHOD_7 ( options . METHOD_2 ( ) , options . METHOD_3 ( ) , IDENT_7 ) ; org . apache . beam . sdk . io . IDENT_5 . datastore . IDENT_6 . IDENT_12 reader = new org . apache . beam . sdk . io . IDENT_5 . datastore . IDENT_6 . METHOD_8 ( datastore , query , options . METHOD_3 ( ) ) ; long IDENT_13 = 0 ; while ( reader . METHOD_9 ( ) ) { reader . METHOD_10 ( ) ; IDENT_13 ++ ; } return IDENT_13 ; }
org . junit . Assert . assertEquals ( IDENT_2 , IDENT_9 )