def test_side_input(self):
    inp = [1, 9, 6, 2]
    fn = (lambda x, y: (x + y))
    expect = reduce(fn, inp)
    self._pipeline.parallelize(1)
    result = self._pipeline.parallelize(inp).reduce(fn).get()
    self.assertEqual(expect, result)
def test_side_input(self):
    inp = [1, 9, 6, 2]
    fn = (lambda x, y: (x + y))
    expect = reduce(fn, inp)
    self._pipeline.parallelize(1)
    result = self._pipeline.parallelize(inp).reduce(fn).get()
    self.assertEqual(expect, result)