我对apachestorm还不熟悉，但我当然知道它的目的是处理流数据。我的问题是：什么是“流”的要求，以便它可以处理风暴使用萌芽？在我的例子中，我有一个用c++编写的应用程序，我想扩展它来生成流数据，可以从storm中读取。但是如何开始，如何为我的应用程序创建一个接口，流应该是什么样子？谢谢你的帮助
vs3odd8k1#
如你所知，storm有一个喷口的概念，它从某个源读取数据并向它的螺栓发出一个元组流。喷口可以以任何形式写来读任何东西，这由你来决定。现在有一个从kafka服务器读取数据的官方实现，但是只要实现它，就可以编写从数据库、文件或网络连接获取数据的东西。在spout和bolt之间，数据可以以任何形式传递：基本类型、字符串、对象、字节数组。
1条答案
按热度按时间vs3odd8k1#
如你所知，storm有一个喷口的概念，它从某个源读取数据并向它的螺栓发出一个元组流。喷口可以以任何形式写来读任何东西，这由你来决定。现在有一个从kafka服务器读取数据的官方实现，但是只要实现它，就可以编写从数据库、文件或网络连接获取数据的东西。
在spout和bolt之间，数据可以以任何形式传递：基本类型、字符串、对象、字节数组。