Module Expr Str Import alias Import alias identifier ImportFrom alias ImportFrom alias Import alias identifier ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias alias ClassDef bases AttributeLoad NameLoad attr body FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad Str Assign NameStore ListLoad Num Num Num Num Num Num Num Num Num Num Assign NameStore BinOpDiv Call NameLoad NameLoad Call NameLoad Call NameLoad NameLoad Assign NameStore Call NameLoad NameLoad Assign NameStore BinOpBitOr NameLoad Call NameLoad Str NameLoad Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Expr Call NameLoad NameLoad Call NameLoad ListLoad NameLoad keyword Str Expr Call NameLoad NameLoad Call NameLoad ListLoad NameLoad keyword Str Assign NameStore BinOpBitOr NameLoad Call NameLoad Str ListComp TupleLoad Str NameLoad comprehension NameStore NameLoad Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Expr Call NameLoad NameLoad Call NameLoad ListLoad TupleLoad Str NameLoad keyword Str Expr Call NameLoad NameLoad Call NameLoad ListLoad TupleLoad Str NameLoad keyword Str Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad Str Assign NameStore Dict Num Num Num Num Num Num Num Str Str Str Str Str Str Str Assign NameStore BinOpBitOr NameLoad Call NameLoad Str ListLoad Num Num Num Num Num Num Num Num Num Num Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Num Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Num Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Num Lambda arguments args NameParam NameParam NameParam defaults CompareLt Call NameLoad SubscriptLoad NameLoad Index NameLoad Call NameLoad SubscriptLoad NameLoad Index NameLoad NameLoad Expr Call NameLoad NameLoad Call NameLoad ListLoad ListLoad Num Num Num Num Num keyword Str Expr Call NameLoad NameLoad Call NameLoad ListLoad ListLoad Num Num Num Num keyword Str Expr Call NameLoad NameLoad Call NameLoad ListLoad ListLoad Num Num Num Num Num Num keyword Str Assign NameStore BinOpBitOr NameLoad Call NameLoad Str ListComp TupleLoad Str NameLoad comprehension NameStore ListLoad Num Num Num Num Num Num Num Num Num Num Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Num Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Num Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Num Lambda arguments args NameParam NameParam NameParam defaults CompareLt Call NameLoad SubscriptLoad NameLoad Index NameLoad Call NameLoad SubscriptLoad NameLoad Index NameLoad NameLoad Expr Call NameLoad NameLoad Call NameLoad ListLoad TupleLoad Str ListLoad Num Num Num Num Num keyword Str Expr Call NameLoad NameLoad Call NameLoad ListLoad TupleLoad Str ListLoad Num Num Num Num keyword Str Expr Call NameLoad NameLoad Call NameLoad ListLoad TupleLoad Str ListLoad Num Num Num Num Num Num keyword Str Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad Str Assign NameStore BinOpBitOr NameLoad Call NameLoad Str ListLoad Num Num Num Num Num Num Num Num Num Num Assign NameStore BinOpBitOr NameLoad Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Num Assign NameStore BinOpBitOr NameLoad Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Num Expr Call NameLoad NameLoad Call NameLoad ListLoad ListLoad Num Num Num Num Num keyword Str Expr Call NameLoad NameLoad Call NameLoad ListLoad ListLoad Num Num Num Num keyword Str Assign NameStore BinOpBitOr NameLoad Call NameLoad Str ListComp TupleLoad Str NameLoad comprehension NameStore ListLoad Num Num Num Num Num Num Num Num Num Num Assign NameStore BinOpBitOr NameLoad Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Num Assign NameStore BinOpBitOr NameLoad Call AttributeLoad NameLoad attr Str Call AttributeLoad NameLoad attr Num Expr Call NameLoad NameLoad Call NameLoad ListLoad TupleLoad Str ListLoad Num Num Num Num Num keyword Str Expr Call NameLoad NameLoad Call NameLoad ListLoad TupleLoad Str ListLoad Num Num Num Num keyword Str Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body For NameStore Call NameLoad Num body Assign NameStore Call NameLoad Str Assign NameStore BinOpBitOr NameLoad Call NameLoad Str ListLoad Num Num Num Num Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr BinOpMod Str NameLoad Num FunctionDef arguments args defaults body FunctionDef arguments args NameParam defaults body Expr Call Call NameLoad ListLoad Num ListLoad Call NameLoad NameLoad Expr Call Call NameLoad ListLoad Num ListLoad Call NameLoad SubscriptLoad NameLoad Index Num Assign NameStore Call NameLoad GeneratorExp Num comprehension NameStore SubscriptLoad NameLoad Index Num CompareEq NameLoad Num Assign NameStore Call NameLoad GeneratorExp Num comprehension NameStore SubscriptLoad NameLoad Index Num CompareEq NameLoad Num Expr Call Call NameLoad ListLoad Num Num ListLoad NameLoad NameLoad decorator_list Return NameLoad decorator_list Expr Call NameLoad NameLoad Call NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Str Assign NameStore BinOpBitOr NameLoad Call NameLoad Str Call NameLoad GeneratorExp ListLoad TupleLoad NameLoad Num TupleLoad NameLoad Num TupleLoad NameLoad Num TupleLoad NameLoad Num comprehension NameStore Call NameLoad Num ListLoad Assign NameStore BinOpBitOr NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Num FunctionDef arguments args defaults body FunctionDef arguments args NameParam defaults body For TupleStore NameStore NameStore NameLoad body Expr Call Call NameLoad ListLoad Num ListLoad Call NameLoad NameLoad Assign NameStore Call NameLoad GeneratorExp Num comprehension NameStore NameLoad CompareEq NameLoad Num Assign NameStore Call NameLoad GeneratorExp Num comprehension NameStore NameLoad CompareEq NameLoad Num Expr Call Call NameLoad ListLoad Num Num ListLoad NameLoad NameLoad decorator_list Return NameLoad decorator_list Expr Call NameLoad NameLoad Call NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad Str Assign NameStore BinOpBitOr BinOpBitOr NameLoad Call NameLoad ListLoad TupleLoad Str Num Num TupleLoad Str Num Num TupleLoad Str Num Num Call AttributeLoad Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr NameLoad Call AttributeLoad NameLoad attr NameLoad attr Expr Call NameLoad NameLoad Call NameLoad ListLoad TupleLoad Str BinOpDiv Num Num Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad Str Assign NameStore BinOpBitOr BinOpBitOr NameLoad Call NameLoad ListLoad Num Num Num Num Call AttributeLoad Call AttributeLoad NameLoad attr Call AttributeLoad Call AttributeLoad NameLoad attr NameLoad Call AttributeLoad NameLoad attr NameLoad attr attr Expr Call NameLoad NameLoad Call NameLoad ListLoad TupleLoad Num BinOpDiv Num Num Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad Str Assign NameStore ListLoad Num Num Num Num Num Num Num Num Num Num Assign NameStore BinOpBitOr NameLoad Call NameLoad Str NameLoad Assign NameStore BinOpBitOr NameLoad Call AttributeLoad NameLoad attr Str FunctionDef arguments args NameParam defaults body FunctionDef arguments args NameParam defaults body Expr Call Call NameLoad SubscriptLoad NameLoad Index Num SubscriptLoad NameLoad Index Num decorator_list Return NameLoad decorator_list Expr Call NameLoad NameLoad Call NameLoad ListLoad NameLoad Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad Str Assign NameStore ListLoad TupleLoad Num Num TupleLoad Num Num TupleLoad Num Num Assign NameStore BinOpBitOr NameLoad Call NameLoad Str NameLoad Assign NameStore BinOpBitOr NameLoad Call AttributeLoad NameLoad attr Str FunctionDef arguments args defaults body FunctionDef arguments args NameParam defaults body Expr Call Call NameLoad ListLoad Num ListLoad Call NameLoad NameLoad Expr Call Call NameLoad NameLoad Call AttributeLoad SubscriptLoad NameLoad Index Num attr decorator_list Return NameLoad decorator_list Expr Call NameLoad NameLoad Call NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad Str Expr Call NameLoad BinOpBitOr BinOpBitOr NameLoad Call NameLoad ListLoad Call NameLoad NameLoad Call NameLoad ListLoad Num Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad Str Assign NameStore BinOpBitOr BinOpBitOr NameLoad Call NameLoad ListLoad Call AttributeLoad Call NameLoad NameLoad attr Expr Call NameLoad NameLoad Call NameLoad ListLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam defaults body Assign NameStore BinOpBitOr NameLoad Call AttributeLoad Call NameLoad NameLoad attr Assign NameStore BinOpBitOr AttributeLoad NameLoad attr Call NameLoad ListLoad NameLoad Return BinOpBitOr NameLoad Call NameLoad Lambda arguments args NameParam NameParam defaults NameLoad NameLoad decorator_list decorator_list Assign NameStore Call NameLoad Str Assign NameStore BinOpBitOr BinOpBitOr NameLoad Call NameLoad Str ListLoad Call NameLoad Str Assign NameStore BinOpBitOr BinOpBitOr NameLoad Call NameLoad Str ListLoad Num Num Num Num Call NameLoad Str Expr Call NameLoad NameLoad Call NameLoad ListLoad Num keyword Str Expr Call NameLoad NameLoad Call NameLoad ListLoad Num keyword Str Expr Call AttributeLoad NameLoad attr decorator_list decorator_list If CompareEq NameLoad Str body Expr Call AttributeLoad NameLoad attr
N/A N/A Unit tests for our libraries of combine PTransforms. N/A unittest N/A google.cloud.dataflow df google.cloud.dataflow.pipeline Pipeline google.cloud.dataflow.transforms combiners N/A google.cloud.dataflow.transforms.combiners combine google.cloud.dataflow.transforms.core CombineGlobally google.cloud.dataflow.transforms.core Create google.cloud.dataflow.transforms.core Map google.cloud.dataflow.transforms.ptransform PTransform google.cloud.dataflow.transforms.util assert_that equal_to CombineTest N/A N/A unittest TestCase N/A test_builtin_combines N/A N/A self N/A N/A N/A pipeline N/A Pipeline DirectPipelineRunner N/A vals N/A 6 3 1 1 9 1 5 2 0 6 N/A mean N/A N/A sum vals N/A float N/A len vals N/A size N/A len vals N/A pcoll N/A pipeline N/A Create start vals N/A result_mean N/A pcoll N/A N/A N/A combine Mean Globally mean N/A result_count N/A pcoll N/A N/A N/A combine Count Globally count N/A N/A assert_that result_mean N/A equal_to N/A mean label assert:mean N/A N/A assert_that result_count N/A equal_to N/A size label assert:size N/A pcoll N/A pipeline N/A Create start-perkey N/A N/A a x N/A x vals N/A result_key_mean N/A pcoll N/A N/A N/A combine Mean PerKey mean-perkey N/A result_key_count N/A pcoll N/A N/A N/A combine Count PerKey count-perkey N/A N/A assert_that result_key_mean N/A equal_to N/A N/A a mean label key:mean N/A N/A assert_that result_key_count N/A equal_to N/A N/A a size label key:size N/A N/A N/A pipeline run N/A test_top N/A N/A self N/A N/A N/A pipeline N/A Pipeline DirectPipelineRunner N/A names N/A 0 1 2 3 5 6 9 zo one twoo three fiiive sssssix nniiinne N/A pcoll N/A pipeline N/A Create start N/A 6 3 1 1 9 1 5 2 0 6 N/A result_top N/A pcoll N/A N/A N/A combine Top Largest top 5 N/A result_bot N/A pcoll N/A N/A N/A combine Top Smallest bot 4 N/A result_cmp N/A pcoll N/A N/A N/A combine Top Of cmp 6 N/A N/A N/A a b names N/A N/A N/A len N/A names N/A a N/A len N/A names N/A b names N/A N/A assert_that result_top N/A equal_to N/A N/A 9 6 6 5 3 label assert:top N/A N/A assert_that result_bot N/A equal_to N/A N/A 0 1 1 1 label assert:bot N/A N/A assert_that result_cmp N/A equal_to N/A N/A 9 6 6 5 3 2 label assert:cmp N/A pcoll N/A pipeline N/A Create start-perkey N/A N/A a x N/A x N/A 6 3 1 1 9 1 5 2 0 6 N/A result_key_top N/A pcoll N/A N/A N/A combine Top LargestPerKey top-perkey 5 N/A result_key_bot N/A pcoll N/A N/A N/A combine Top SmallestPerKey bot-perkey 4 N/A result_key_cmp N/A pcoll N/A N/A N/A combine Top PerKey cmp-perkey 6 N/A N/A N/A a b names N/A N/A N/A len N/A names N/A a N/A len N/A names N/A b names N/A N/A assert_that result_key_top N/A equal_to N/A N/A a N/A 9 6 6 5 3 label key:top N/A N/A assert_that result_key_bot N/A equal_to N/A N/A a N/A 0 1 1 1 label key:bot N/A N/A assert_that result_key_cmp N/A equal_to N/A N/A a N/A 9 6 6 5 3 2 label key:cmp N/A N/A N/A pipeline run N/A test_top_shorthands N/A N/A self N/A N/A N/A pipeline N/A Pipeline DirectPipelineRunner N/A pcoll N/A pipeline N/A Create start N/A 6 3 1 1 9 1 5 2 0 6 N/A result_top N/A pcoll N/A N/A df CombineGlobally top N/A N/A combiners Largest 5 N/A result_bot N/A pcoll N/A N/A df CombineGlobally bot N/A N/A combiners Smallest 4 N/A N/A assert_that result_top N/A equal_to N/A N/A 9 6 6 5 3 label assert:top N/A N/A assert_that result_bot N/A equal_to N/A N/A 0 1 1 1 label assert:bot N/A pcoll N/A pipeline N/A Create start-perkey N/A N/A a x N/A x N/A 6 3 1 1 9 1 5 2 0 6 N/A result_ktop N/A pcoll N/A N/A df CombinePerKey top-perkey N/A N/A combiners Largest 5 N/A result_kbot N/A pcoll N/A N/A df CombinePerKey bot-perkey N/A N/A combiners Smallest 4 N/A N/A assert_that result_ktop N/A equal_to N/A N/A a N/A 9 6 6 5 3 label k:top N/A N/A assert_that result_kbot N/A equal_to N/A N/A a N/A 0 1 1 1 label k:bot N/A N/A N/A pipeline run N/A test_sample N/A N/A self N/A N/A N/A ix N/A xrange 300 N/A N/A pipeline N/A Pipeline DirectPipelineRunner N/A pcoll N/A pipeline N/A Create start N/A 1 1 2 2 N/A result N/A pcoll N/A N/A N/A combine Sample FixedSizeGlobally N/A sample-%d ix 3 matcher N/A N/A N/A N/A match N/A N/A actual N/A N/A N/A N/A N/A equal_to N/A 1 N/A N/A len actual N/A N/A N/A equal_to N/A 3 N/A N/A len N/A actual N/A 0 N/A num_ones N/A sum N/A 1 N/A x N/A actual N/A 0 N/A x 1 N/A num_twos N/A sum N/A 1 N/A x N/A actual N/A 0 N/A x 2 N/A N/A N/A equal_to N/A 1 2 N/A num_ones num_twos N/A N/A match N/A N/A N/A assert_that result N/A matcher N/A N/A N/A pipeline run N/A pipeline N/A Pipeline DirectPipelineRunner N/A pcoll N/A pipeline N/A Create start-perkey N/A sum N/A N/A N/A i 1 N/A i 1 N/A i 2 N/A i 2 N/A i N/A xrange 300 N/A N/A result N/A pcoll N/A N/A N/A combine Sample FixedSizePerKey sample 3 matcher N/A N/A N/A N/A match N/A N/A actual N/A N/A N/A N/A _ samples actual N/A N/A N/A N/A equal_to N/A 3 N/A N/A len samples N/A num_ones N/A sum N/A 1 N/A x samples N/A x 1 N/A num_twos N/A sum N/A 1 N/A x samples N/A x 2 N/A N/A N/A equal_to N/A 1 2 N/A num_ones num_twos N/A N/A match N/A N/A N/A assert_that result N/A matcher N/A N/A N/A pipeline run N/A test_tuple_combine_fn N/A N/A self N/A N/A N/A p N/A Pipeline DirectPipelineRunner N/A result N/A N/A p N/A Create N/A N/A a 100 0.0 N/A b 10 -1 N/A c 1 100 N/A N/A N/A N/A df CombineGlobally N/A N/A combine TupleCombineFn max N/A N/A combine MeanCombineFn sum without_defaults N/A N/A assert_that result N/A equal_to N/A N/A c N/A 111.0 3 99.0 N/A N/A N/A p run N/A test_tuple_combine_fn_without_defaults N/A N/A self N/A N/A N/A p N/A Pipeline DirectPipelineRunner N/A result N/A N/A p N/A Create N/A 1 1 2 3 N/A N/A N/A N/A df CombineGlobally N/A N/A N/A N/A combine TupleCombineFn min N/A N/A combine MeanCombineFn max with_common_input without_defaults N/A N/A assert_that result N/A equal_to N/A N/A 1 N/A 7.0 4 3 N/A N/A N/A p run N/A test_to_list_and_to_dict N/A N/A self N/A N/A N/A pipeline N/A Pipeline DirectPipelineRunner N/A the_list N/A 6 3 1 1 9 1 5 2 0 6 N/A pcoll N/A pipeline N/A Create start the_list N/A result N/A pcoll N/A N/A combine ToList to list matcher N/A N/A expected N/A N/A match N/A N/A actual N/A N/A N/A N/A N/A equal_to N/A expected N/A 0 N/A actual N/A 0 N/A N/A match N/A N/A N/A assert_that result N/A matcher N/A the_list N/A N/A N/A pipeline run N/A pipeline N/A Pipeline DirectPipelineRunner N/A pairs N/A N/A 1 2 N/A 3 4 N/A 5 6 N/A pcoll N/A pipeline N/A Create start-pairs pairs N/A result N/A pcoll N/A N/A combine ToDict to dict matcher N/A N/A N/A N/A match N/A N/A actual N/A N/A N/A N/A N/A equal_to N/A 1 N/A N/A len actual N/A N/A N/A equal_to pairs N/A N/A N/A actual N/A 0 iteritems N/A N/A match N/A N/A N/A assert_that result N/A matcher N/A N/A N/A pipeline run N/A test_combine_globally_with_default N/A N/A self N/A N/A N/A p N/A Pipeline DirectPipelineRunner N/A N/A assert_that N/A N/A p N/A Create N/A N/A CombineGlobally sum N/A equal_to N/A 0 N/A N/A N/A p run N/A test_combine_globally_without_default N/A N/A self N/A N/A N/A p N/A Pipeline DirectPipelineRunner N/A result N/A N/A p N/A Create N/A N/A N/A N/A CombineGlobally sum without_defaults N/A N/A assert_that result N/A equal_to N/A N/A N/A N/A p run N/A test_combine_globally_with_default_side_input N/A N/A self N/A N/A CombineWithSideInput N/A PTransform N/A apply N/A N/A self pcoll N/A N/A N/A side N/A pcoll N/A N/A N/A CombineGlobally sum as_singleton_view N/A main N/A N/A pcoll pipeline N/A Create N/A None N/A N/A main N/A Map N/A N/A N/A _ s N/A s side N/A N/A N/A p N/A Pipeline DirectPipelineRunner N/A result1 N/A N/A p N/A Create label1 N/A N/A CombineWithSideInput L1 N/A result2 N/A N/A p N/A Create label2 N/A 1 2 3 4 N/A CombineWithSideInput L2 N/A N/A assert_that result1 N/A equal_to N/A 0 label r1 N/A N/A assert_that result2 N/A equal_to N/A 10 label r2 N/A N/A N/A p run N/A N/A N/A N/A __name__ __main__ N/A N/A N/A N/A unittest main