1

我想将螺栓输出写入 csv 文件。考虑一下，如果我正在从 spout 读取数据并将其传递给 bolt，bolt 进行一些计算，然后将该数据写入 csv 文件，尽管我正在运行 2 个 spout 和 4 个 bolts 实例。

在 csv 文件中，我正在编写一次列，并在该多个数据下编写如下

Example: Columns:  Empid,EmpSal,Address
           1,1000,Add1
           2,1500,Add2
           3,200,Add3

但由于螺栓列名称的多个实例在 csv 文件中重复如下：

Empid,EmpSal,Address
            1,1000,Add1
            Empid,EmpSal,Address
            2,1500,Add2
            ....

所以任何人都知道为什么列重复

提前致谢

4

1 回答 1

2

虽然我不太明白你的问题，但最好有一个用作蓄电池的螺栓。在您处理完数据并且您的 CSV 文件已准备好归档后；您将数据发送到充当写入器的 Bolt，并且只有该 Bolt 写入 CSV 文件。即使您有该 Bolt 的多个实例，通过正确的同步，也很容易确保文件的正确性。

我使用 Storm 和 Clojure，所以并发部分真的很简单！

于 2013-08-22T18:27:06.113 回答