def add_mock_hadoop_output(parts):
 output_subdir = get_mock_dir('output', iso_now())
 for (i, part) in enumerate(parts):
  part_path = os.path.join(output_subdir, ('part-%05d' % i))
  with open(part_path, 'wb') as part_file:
   part_file.write(part)

def add_mock_hadoop_output ( parts ) : output_subdir = get_mock_dir ( 'output' , iso_now ( ) ) for ( i , part ) in enumerate ( parts ) : part_path = os . path . join ( output_subdir , ( 'part-%05d' % i ) ) with open ( part_path , 'wb' ) as part_file : part_file . write ( part )
add mock output which will be used by the next fake streaming job that mockhadoop will run .