H A D | bucketing_test.py | 108 def reduce_func(_, xs): function in function:GroupByWindowTest.testReduceFuncError 119 grouping.group_by_window(lambda x, _: x % 2, reduce_func, 132 def reduce_func(key, window): function in function:GroupByWindowTest.testConsumeWindowDatasetMoreThanOnce 147 reduce_func, 4))
|