def test_modify_left_param(self):
    ' inner function'
    inp = self._pipeline.parallelize([[1, 2, 3], [6, 5, 4]])

    def _sum(x, y):
        x[0] += y[0]
        x[1] += y[1]
        x[2] += y[2]
        return x
    result = transforms.union(inp.reduce(_sum), inp.reduce(_sum)).get()
    self.assertEqual([[7, 7, 7], [7, 7, 7]], result)
inner function
def test_modify_left_param(self):
    ' '
    inp = self._pipeline.parallelize([[1, 2, 3], [6, 5, 4]])

    def _sum(x, y):
        x[0] += y[0]
        x[1] += y[1]
        x[2] += y[2]
        return x
    result = transforms.union(inp.reduce(_sum), inp.reduce(_sum)).get()
    self.assertEqual([[7, 7, 7], [7, 7, 7]], result)