Skip to content
Browse files

add "raw" shortcut for RawFileOutputFormat and MultipleRawFileOutputF…

…ormat
  • Loading branch information...
1 parent de09b7d commit ea2f84e8a8518d9365eb090e93cb23ed6d1e36ae @dangra dangra committed
Showing with 2 additions and 0 deletions.
  1. +2 −0 dumbo/backends/streaming.py
View
2 dumbo/backends/streaming.py
@@ -154,11 +154,13 @@ def run(self):
outputformat_shortcuts = \
{'code': 'fm.last.feathers.output.MultipleSequenceFiles',
'text': 'fm.last.feathers.output.MultipleTextFiles',
+ 'raw': 'fm.last.feathers.output.MultipleRawFileOutputFormat',
'sequencefile': 'fm.last.feathers.output.MultipleSequenceFiles'}
else:
outputformat_shortcuts = \
{'code': 'org.apache.hadoop.mapred.SequenceFileOutputFormat',
'text': 'org.apache.hadoop.mapred.TextOutputFormat',
+ 'raw': 'fm.last.feathers.output.RawFileOutputFormat',
'sequencefile': 'org.apache.hadoop.mapred.SequenceFileOutputFormat'}
outputformat_shortcuts.update(configopts('outputformats', self.prog))
outputformat = addedopts['outputformat'][0]

0 comments on commit ea2f84e

Please sign in to comment.
Something went wrong with that request. Please try again.