parameters: (self, fn, *side_inputs, **options)
return_statement: return transforms.flat_map(self, fn, *side_inputs, **options)
docstring: 对所有元素进行一对多映射，等同于
          :func:`bigflow.transforms.flat_map(self, fn, *side_inputs, **options)
          <bigflow.transforms.flat_map>`
  
          Args:
            fn (function):  变换函数
            *side_inputs:  参与运算的SideInputs
            **options:  可配置选项
  
          Returns:
            PCollection:  变换结果
  
          >>> _pipeline.parallelize([1, 3, 5, 7]).flat_map(lambda x: [x, x * 2]).get()
          [1, 2, 3, 5, 6, 7, 10, 14]
docstring_summary: 对所有元素进行一对多映射，等同于
          :func:`bigflow.transforms.flat_map(self, fn, *side_inputs, **options)
          <bigflow.transforms.flat_map>`
docstring_tokens: 对所有元素进行一对多映射，等同于 : func : bigflow . transforms . flat_map ( self fn * side_inputs ** options ) <bigflow . transforms . flat_map >
function: def flat_map(self, fn, *side_inputs, **options):
          """
          对所有元素进行一对多映射，等同于
          :func:`bigflow.transforms.flat_map(self, fn, *side_inputs, **options)
          <bigflow.transforms.flat_map>`
  
          Args:
            fn (function):  变换函数
            *side_inputs:  参与运算的SideInputs
            **options:  可配置选项
  
          Returns:
            PCollection:  变换结果
  
          >>> _pipeline.parallelize([1, 3, 5, 7]).flat_map(lambda x: [x, x * 2]).get()
          [1, 2, 3, 5, 6, 7, 10, 14]
          """
          return transforms.flat_map(self, fn, *side_inputs, **options)
function_tokens: def flat_map ( self , fn , * side_inputs , * * options ) : return transforms . flat_map ( self , fn , * side_inputs , * * options )