parameters: (self)
return_statement: return process
docstring: Convert all SideInputs as prepared nodes in LogicalPlan
  
          Returns:
            LogicalPlan.Node:  processed node
docstring_summary: Convert all SideInputs as prepared nodes in LogicalPlan
docstring_tokens: Convert all SideInputs as prepared nodes in LogicalPlan
function: def process_with_side_inputs(self):
          """
          Convert all SideInputs as prepared nodes in LogicalPlan
  
          Returns:
            LogicalPlan.Node:  processed node
          """
          from bigflow.core import logical_plan
          common_scope = logical_plan.LogicalPlan.Scope.common_scope(self.__nodes)
          plan = self.get_input().plan()
  
          process = plan.process(common_scope, self.__nodes)
          if process.input_size() != len(self.__nodes):
              raise ValueError("Invalid input size")
  
          for i in xrange(0, len(self.__nodes) - 1):
              process.input(i).prepare_before_processing()
  
          return process
function_tokens: def process_with_side_inputs ( self ) : from bigflow . core import logical_plan common_scope = logical_plan . LogicalPlan . Scope . common_scope ( self . __nodes ) plan = self . get_input ( ) . plan ( ) process = plan . process ( common_scope , self . __nodes ) if process . input_size ( ) != len ( self . __nodes ) : raise ValueError ( "Invalid input size" ) for i in xrange ( 0 , len ( self . __nodes ) - 1 ) : process . input ( i ) . prepare_before_processing ( ) return process