twitter-realtime-websocket:使用Spark Streaming分析Twitter数据，使用Akka a...

＃对Twitter流数据进行简单分析该应用程序对Twitter流数据进行简单的实时分析。 自开始接收数据以来或自最后一分钟以来，它可识别推文中最流行的主题标签或语言（不包括转推），它在浏览器上提供实时更新。 它使用Spark流，Spark SQL，Akka，Play，WebSocket。 大部分的应用程序都是用Scala编写的，除了提供的报告是用JavaScript编写的。 ##应用程序结构 推文收集器和分析器 Web应用程序 ##推文收集器和分析器 ### Tweets集合从Twitter流中收集tweet，将它们转换为Json格式并存储到文件中。 它使用Spark流API和Twitter API。 需要4个Twitter令牌来收集这些推文。 它们由生成。 Twitter流处理应该是轻量级的，以避免内存不足。 因此，它仅将这些推文另存为文件到目录中，并允许另一个进程来处理这些文件。