我有一个Ruby Map/Reduce管道,其中STDIO被添加到映射器等
cat input.csv | mapper.rb | sort | reducer.rb > output.csv
在mapper中有一行。Rb,看起来像这样:
ARGF.each do |line|
(field1, field2, field3) = line.split("t")
# etc...
end
我该如何在《Elixir》中做到这一点?
另外,我在某处读到File.stream!比IO.stream快得多。在这个特殊的例子中,我可以去掉cat,直接加载文件,如果这样更快的话。
使用IO.stream
。File.stream!
对于文件更快,当涉及到IO时不要担心。