(import java.nio.file.Files)(import java.nio.file.Paths)(import java.util.stream.Stream)(def path (Paths/get "." (into-array ["data" "10000000.test.log"])))(def stream (Files/lines path))這樣我就有了：stream#object[java.util.stream.ReferencePipeline$Head 0x50129b8f"java.util.stream.ReferencePipeline$Head@50129b8f"]有沒(méi)有辦法在不耗盡內(nèi)存的情況下迭代它？對(duì)SO的建議并沒(méi)有多大幫助。文件大約1G。
2 回答
浮云間
TA貢獻(xiàn)1829條經(jīng)驗(yàn) 獲得超4個(gè)贊
做與在 java 中做的同樣的事情。對(duì)其調(diào)用互操作方法，例如(.map stream ...)或其他任何方法，然后將其收集到最后的列表中，或減少它，或任何您需要執(zhí)行的操作。
Clojure 函數(shù)不實(shí)現(xiàn)流所需的接口，例如 java.util.function.Function，因此您需要使用 reify 而不是簡(jiǎn)單的fn：
(.map stream (reify java.util.function.Function (apply [this x] (foo x))))
拉丁的傳說(shuō)
TA貢獻(xiàn)1789條經(jīng)驗(yàn) 獲得超8個(gè)贊
梵蒂岡之花
TA貢獻(xiàn)1900條經(jīng)驗(yàn) 獲得超5個(gè)贊
我想迭代流 Java/命令式風(fēng)格以避免堆爆。我不需要減少流，我需要處理每一行并取出一個(gè)字段并將其發(fā)送出去。我認(rèn)為為此我可能最好使用doseq。
(doseq [l (iterator-seq (.iterator stream))] (println l))
添加回答
舉報(bào)
0/150
提交
取消