apache-flink
-
如何根据数据将一个数据流输出到不同的输出? 在Apache Flink中,我有一个元组流。让我们假设一个非常简单的.元组的值字段中可以有任意值(例如'P1','P2'等)。可能值的集合是有限的,但我事先不知道完整的集合(所以可能有一个“P362”)
-
无法解析为某个值的替换:AWS Lambda 中的 ${akka.stream.materializer} 我有一个java应用程序,其中我正在使用.因此,基本上,我试图用代码做的是创建两个记录很少的数据集,然后将它们与必要的字段一起注册为两个表。 因此,当我尝试在那里执行它时,我被抛
-
Apache Flink: java.lang.NoClassDefFoundError 我正在尝试 可能出了什么问题?任何依赖项,版本? 注意:如果我注释有问题的行,程序运行没有问题。还要注意的是,此错误也出现在某些Kafka()样本上;我看到了amamaraws.kafka.samples.CustomMM2Re
-
如何在Apache Flink中查找和更新数据库中的记录状态? 我正在开发一个数据流应用程序,我正在研究将Apache Flink用于此项目的可能性。这样做的主要原因是它支持不错的高级流构造,与Java 8的Stream API非常相似。 我将接收与数据库中的特定记录相对
-
如何将流数据与数据流/光束中的大型历史数据集相结合 我正在调查通过Google Dataflow / Apache Beam处理来自Web用户会话的日志,并且需要将用户进入(流式传输)时的日志与上个月用户会话的历史记录相结合。 我研究了以下方法: 使用30天的固定窗口
标签