1. chango
  2. inferno

Commits

t1m  committed 7cb60d4

adding sort_buffer_size param to inferno

  • Participants
  • Parent commits bc26f34
  • Branches default

Comments (0)

Files changed (2)

File inferno/lib/job.py

View file
                   combiner=self.rule.combiner_function,
                   reduce_output_stream=self.rule.reduce_output_stream,
                   sort=self.rule.sort,
+                  sort_buffer_size=self.rule.sort_buffer_size,
                   profile=self.settings.get('profile'),
                   partition=self.rule.partition_function,
                   required_files=self.rule.required_files,

File inferno/lib/rule.py

View file
                  result_tag=None,
                  save=False,
                  sort=True,
+                 sort_buffer_size='10%',
                  sorted_results=True,
 
                  # keysets
         self.result_tag = result_tag
         self.save = save
         self.sort = sort
+        self.sort_buffer_size = sort_buffer_size
         if result_iterator_override:
             self.result_iterator = result_iterator_override
         elif self.sort and sorted_results: