用螺栓创建csv文件

Question

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

在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
            ....

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

提前感谢

Answer 1

虽然我不太明白你的问题，但最好是有一个螺栓，作为一个累加器。在您完成了对数据的处理之后，您的CSV文件已经准备好了；您可以将数据发送到充当编写器的Bolt，并且只有这个Bolt是写到CSV文件的。即使有多个Bolt实例，只要有正确的同步，也很容易确保文件的正确性。

我将Storm与Clojure一起使用，因此并发部分非常简单和简单！