我在flink上做了一些poc，但我找不到关于如何在kafka流中实现类似于KGroupTable的用例的文档，如下所示我想从收到的交易中汇总账户余额的用<
浏览 5提问于2020-05-23得票数 0
1回答
有什么方法可以用Flink CEP库创建这个模式吗？input List(1,2,2,2,3,3,2,1,1,1,3,0,1)List(2,2,2,3)List(1,1,1)
我知道有很多方法可以通过Flink如果是这样的话，Flink CEP是否可以传递上下文或修改流中的事件，并将一些额外的数据传递给下一个条件？
浏览 6提问于2022-09-10得票数 0
回答已采纳
我对Flink相当陌生，在技术用例方面需要一些帮助。我有一个在GKE上运行的flink应用程序，并使用自定义接收器将记录(从Kafka源)写入BigQuery。目前，记录被一个接一个地写入接收器中，因此每个kafka消息都会得到自己对BigQuery的插入api调用，这并不理想，因为我们需要执行批量插入，并且单独插入每个记录将非常昂贵。我不知道如何在Flink中实现这个功能，因此我正在寻找实现此功能的方
浏览 5提问于2022-10-18得票数 2
回答已采纳
我很难理解操作符状态是如何在并行操作符实例之间分布的，以获得所需的结果。}假设我们运行的并行性= 2，这意味着我们有两个并行操作符(MultiplyNumber)实例( Operator1和Operator2)这意味着所有偶数都应该乘以2和3，所有奇数都应该乘以4和5。
但这不是我所期望的结果。
浏览 0提问于2018-05-26得票数 2
回答已采纳
在处理了这数百万的事件/数据之后，哪里是保存信息的最佳地方？我看到一个关闭的提到了Parquet格式，但是，默认的是HDFS吗？我关心的是储蓄后(哪里？)如果它是容易的(快！)才能检索到数据？
浏览 3提问于2015-08-11得票数 5
2回答
我已经编写了一个使用Guava缓存的Flink作业。缓存对象是在main()函数中调用的run()函数中创建和使用的。main() {}
//create and use Guava cache object here如果我以某种程度的并行性运行这个Flink所以这就像
incoming_stream.process(new ProcessFunction() { //Use Guava Cache here }
浏览 6提问于2019-03-27得票数 0
我正在尝试在Flink中实现这篇科学论文(https://www.cse.ust.hk/~yike/pods10-cdsample.pdf)中的算法2(第4页)，如果有人能帮助我完成这项任务，我会很高兴，如何在Flink中实现广播，等等)。
浏览 22提问于2020-08-19得票数 0
工作负载的语义如下：如何在Flink中对此用例进行水平扩展？我想同时处理事件，但是所有的事件处理都依赖于同一状态。在我的用例中，状态的大小将首先上升到，然后在1TB左右波动。
浏览 0提问于2021-04-08得票数 0
回答已采纳
1回答
背景
我想将运行在DB上的作业移到Flink，使系统更“实时”工作。此作业将每10秒重新计算所有帐户的“状态”，如果该值满足某些条件，我们将通知用户。数据可以从DB表中读取，也可以从卡夫卡topic.PriceStream:加载--卡夫卡主题包含这样的股票价格：{“名称”："stockName"，“价格”：currentPrice}StockStream: A Kafka主题包含帐户买卖的股票数量(正数或负数)，如：{“帐户”：accountNumber，“股票”：“stockName”，“数量”：changingNum
浏览 1提问于2022-03-10得票数 0
2回答
我必须将文档管理服务实现为编排层，该编排层在底层服务之间进行编排，如存储、解析、防病毒扫描等。要求该层具有灵活性，以便可以快速实现不同类型文档的不同流另一种思考方式是--工作流。
浏览 7提问于2019-10-23得票数 3
1回答
我是flink的新手，我们的用例处理无状态计算。读取事件、处理事件并保存到数据库中。但是Flink文档从来没有提到过无状态处理。任何示例存储库，用于查找无状态示例或文档。最后，对于这个用例，哪个Flink模型有效？流应用程序或事件驱动应用程序。
浏览 21提问于2020-12-09得票数 2
1回答
我有一个java应用程序，它通过从数据库查询表并将其输入kafka主题来对批处理进行flink批处理。我该如何定期安排这件事。有flink调度程序吗？例如，我的java应用程序应该在后台继续运行，flink调度程序应该定期查询数据库中的表，flink批处理处理它并输入kafka(flink批处理和输入kafka已经完成了我的应用程序的一部分)。
浏览 2提问于2016-11-29得票数 4
回答已采纳
关于Flink中的新sourceSinks接口，我有一个问题。我目前实现了一个新的自定义DynamicTableSinkFactory、DynamicTableSink、SinkFunction和OutputFormat。我以JDBC连接器为例，使用Scala。
记录必须被接受为org.apache.flink.table.data.RowData。该框架提供运行时转换器，以便接收器仍然可以在公共数据结构上工作，并在开始时执行转换。
浏览 5提问于2021-01-15得票数 0
回答已采纳
2回答
apache文档中的所有过滤示例都会根据全局阈值显示过滤的简单情况。假设我们有一个传感器数据流。无论是在Apache中还是在普通Java中。
谢谢
浏览 4提问于2021-04-30得票数 0
回答已采纳
我的Flink作业需要在不同的时间写入不同的Cassandra表。对于这个场景，Cassandra连接器的动态表名或动态查询，或者Flink作业的动态接收器都适合我。
浏览 10提问于2020-03-01得票数 0
回答已采纳
流以JSON格式非常详细地到达，应该被推送到ElasticSearch中，但是这些数据的一些聚合应该被添加到关系数据库中，甚至是图形数据库中。对于ElasticSearch、Neo4J等消费者来说，这是一个很好的Kafka / Storm用例吗？此外，我还想从初始流中为我的监控系统派生一些信息，这样我也可能有一个监控消费者。如果这个用例看起来像Kafka和Storm这样的东西，那么这更多的是一个架构问题。谢谢Philipp
浏览 14提问于2016-08-23得票数 0
我正在使用Flink SQL来处理批处理情况。如何使用FLINK SQL获取每个组的top-n记录？
浏览 13提问于2019-02-01得票数 0
回答已采纳
1回答
流在Hadoop中的应用
、、、、
在这个例子中，我确实看到他们创建了一个单独的应用程序(类似于流应用程序)，该应用程序生成和消费数据，并在数据上应用模式匹配。他们现在还没有在.Till(如卡夫卡)之间放置一个流层，单应用程序就足以满足这一目的，这使得它非常优化。我有几个问题我没有得到回答：
如果像卡夫卡/动态)这样的流层出现在
浏览 2提问于2016-06-13得票数 0
我是Flink的新手，我的理解是遵循API调用将并行读取给定我们将日志文件存储在S3中。要求是为多个客户端请求提供服务，以便使用时间戳从不同的文件夹读取数据。是否有可能在单个
浏览 49提问于2017-07-18得票数 2
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
