<s> from sahara . service . edp . oozie . workflow_creator import base_workflow 
 from sahara . service . edp . oozie . workflow_creator import base_workflow <EOL> class MapReduceWorkFlowCreator ( base_workflow . OozieWorkflowCreator ) : <EOL> def __init__ ( self ) : <EOL> super ( MapReduceWorkFlowCreator , self ) . __init__ ( '<STR_LIT>' ) <EOL> def build_workflow_xml ( self , prepare = None , <EOL> job_xml = None , configuration = None , <EOL> files = None , archives = None , <EOL> streaming = None ) : <EOL> prepare = prepare or { } <EOL> files = files or [ ] <EOL> archives = archives or [ ] <EOL> streaming = streaming or { } <EOL> for k in sorted ( prepare ) : <EOL> self . _add_to_prepare_element ( k , prepare [ k ] ) <EOL> for k in sorted ( streaming ) : <EOL> self . _add_to_streaming_element ( k , streaming [ k ] ) <EOL> self . _add_job_xml_element ( job_xml ) <EOL> self . _add_configuration_elements ( configuration ) <EOL> self . _add_files_and_archives ( files , archives ) </s>
