Tag: 数据流

Beam / Dataflow 2.2.0 – 从pcollection中提取前n个元素

有没有办法在梁pcollection中提取前n个元素？ 文档似乎没有表明任何此类function。 我认为这样的操作首先需要一个全局元素编号赋值然后一个filter – 拥有这个function会很好。 我使用Google DataFlow Java SDK 2.2.0 。

适用于Java的数据流编程API？

我正在寻找一个Java的数据流/并发编程API。 我知道有DataRush ，但它不是免费的。 我特别感兴趣的是多核数据处理，而不是分布式的，它排除了MapReduce或Hadoop 。 有什么想法吗？ 谢谢，罗洛

创建一种通过网络发送整数的有效方法。 TCP

如何将整数值转换为字节数组，然后通过字节流将它们发送到客户端程序，该程序将字节数组转换回整数？ 我的节目是乒乓球比赛。 一旦运行，它就会创建一个服务器，客户端现在使用对象流通过Internet连接到该服务器。 一切都运作良好，但似乎效率不高。 我的意思是球在试图通过更新循环保持同步时来回震动 。 我可能已经松散地编程了，但这是我能想到的最好的。 我希望有更多了解这种事情如何运作的人可以帮助我清除一些事情。 我的问题直截了当。 我需要知道更好的方式来更有效地在互联网上发送球位置和球员位置。 目前花费的时间太长了。 虽然，我可能会以错误的方式更新它。 流的构建方式： oostream = new ObjectOutputStream(new BufferedOutputStream(socket.getOutputStream())); oostream.flush(); oistream = new ObjectInputStream(new BufferedInputStream(socket.getInputStream())); 这是玩家2的更新循环： IntData id = new IntData(); while (running) { id.ballx = ballx; id.bally = bally; id.player2Y = player2Y; oostream.writeObject(id); oostream.flush(); Thread.sleep(updaterate); id = (IntData) oistream.readObject(); player1Y = id.player1Y; ballx = id.ballx; […]

基于Java的传感器数据收集库

我正在寻找一个可嵌入的Java库，它适用于以通用方式收集传感器数据的实时流 。 我计划用它来开发一个“集线器”应用程序，用于报告在基于JVM的服务器上运行的多个不同的传感器流（也将使用Clojure）。 需要掌握的关键事项： 各种常见传感器类型/ API的接口。 我很高兴能够自己构建我需要的东西，但是如果有一些标准的东西是开箱即用的话会很好。 适用于“软实时”使用，即相当低的延迟和低开销。 能够在运行时监视和管理流，收集统计信息等。 在合理许可的许可下开源，以便我可以将它与其他代码集成（Apache，EPL，BSD，LGPL都很好） 一个相当活跃的社区/开发者生态系统 是否有适合此配置文件的内容可供您推荐？