共有1个答案
根据您的任务描述，Apache Flink看起来很适合您的用例。
通常，Flink提供低延迟和高吞吐量，并有一个参数来调整这些。您可以从Redis或Cassandra读写数据。但是，您也可以在Flink中内部存储状态。Flink也有对Windows的复杂支持。您可以阅读Flink网站上的博客，查看文档以获取更多信息，或者跟随Flink培训学习API。
-
最近我尝试使用ApacheFlink进行快速批处理。我有一个表，它有一个列：value和一个不相关的索引列 基本上我想计算每5行值的平均值和范围。然后我将根据我刚才计算的平均值计算平均值和标准偏差。所以我想最好的方法是使用窗口。 看起来是这样的 但是我不知道用。我试过，但它说没有这样的输入。我只希望它在从源代码读取时按顺序分组。但是它必须是一个时间属性，所以我不能使用索引列作为排序。 我是否必须添
-
SQLAlchemy 1.4 / 2.0 Tutorial 此页是 SQLAlchemy 1.4/2.0教程 . 上一页： 使用数据 |下一步： |next| 使用ORM进行数据操作 上一节 使用数据 仍然从核心的角度关注SQL表达式语言，以便在主要的SQL语句结构中提供连续性。本节将构建 Session 以及它如何与这些结构相互作用。 先决条件部分 -本教程以ORM为重点的部分建立在本文档前面两
-
我有2个使用kafka主题创建的流，我正在使用DataStream API加入它们。我希望将连接（应用）的结果发布到另一个kafka主题。我在外部主题中看不到连接的结果。 我确认我向两个源主题发布了正确的数据。不确定哪里出了问题。下面是代码片段， 创建的流如下所示。 流连接使用等于的连接执行，如下所示。 如下所述， 有什么线索吗，哪里出了问题？我可以在拓扑中看到可用的消息，谢谢
-
本文向大家介绍android使用SharedPreferences进行数据存储，包括了android使用SharedPreferences进行数据存储的使用技巧和注意事项，需要的朋友参考一下 很多时候我们开发的软件需要向用户提供软件参数设置功能，例如我们常用的QQ，用户可以设置是否允许陌生人添加自己为好友。对于软件配置参数的保存，如果是window软件通常我们会采用ini文件进行保存，如果是j2s
-
我目前正在从事一个利用Spring数据Neo4j的项目。每当创建节点时，我都希望创建一个包含创建日期和用户的引用审核节点。 我提出的一个解决方案是编写一个AOP方面，它与我的服务层的create方法挂钩。这对于没有级联的实体很好，但是级联的实体呢？它们没有在我的服务层中显式传递，因此我的AOP类不会拦截它们。JPA中是否有类似实体侦听器的概念，或者如何连接到该机制中？
-
本文向大家介绍使用Python Pandas进行数据分析，包括了使用Python Pandas进行数据分析的使用技巧和注意事项，需要的朋友参考一下 在本教程中，我们将看到使用Python pandas库进行的数据分析。图书馆的熊猫都是用C语言编写的。因此，我们在速度上没有任何问题。它以数据分析而闻名。我们在熊猫中有两种类型的数据存储结构。它们是Series和DataFrame。让我们一一看。 1.