我有来自Kafka的流，我正在使用Flink进行操作。流的一部分由我正在监视的一个Integer组成，它表示高度。我想将“高度”和“计数器”保存到Tuple2的列表中，其中第一个f0是高度，第二个元素f1是以前在流中看到相同高度的次数。Tuples170，2 输入: 170 -> ListofTuples170,2 Tuples170，2 输入: 120 -> ListofTuples170,2 Tuples170，2 输入: 140 ->列表
浏览 20提问于2020-12-29得票数 0
回答已采纳
我正在尝试为ArangoDB编写一个自定义的ArangoDB。我使用CassandraOutputFormat.java作为灵感，交换了相关的驱动程序和调用等等。我用Java编写了这篇文章，因为我找不到OutputFormat的Scala示例。ArangoDB的Flink程序是用Scala编写的。，11)类型参数(长、长)不符合类ArangoOutputFormat的类型参数界限<：org.apache.flink</e
浏览 3提问于2016-09-09得票数 1
回答已采纳
2回答
我正在编写一个使用Flink的Scala流处理程序。我有一个数据流，我首先将其映射到包含json4s JValues的元组。现在我想根据这些JValues来过滤这些元组。我认为这会很简单，但我找不到任何好的例子来说明如何按列过滤Flink元组。有人知道怎么做吗？谢谢
浏览 6提问于2018-01-15得票数 0
回答已采纳
我在摆弄元组列表，我想知道，从元组列表中同时获取最大的第一和第二值的最快方法是什么？例如，假设我们有如下所示的元组列表：最大的第一个值是3，最大的第二个值是4，因此我想得到元组(3, 4)。最快的方法是什么？
浏览 6提问于2014-04-11得票数 1
回答已采纳
首先，cassandraInputFormat只返回一个元组，我更希望没有tuple12，只需要使用pojo来定义它期望返回的内容。因此，我不知道这是否只是我必须接受的东西，是否有一种方法可以使用pojo代替cassandraConnector ()，或者使用cassandraInputFormat不是获取数据的最佳方式。另一个问题是，即使我从cassandraInputFormat中提取的数据(不管是元组还是非元组)，我也不知道如何将它设置为数据源。
浏览 4提问于2017-05-11得票数 0
回答已采纳
根据元组的开头或结尾，从python列表中删除元组(并用删除的元组更新列表)的最快方法是什么？), ('b', 'e'), ('c', 'd'),
('c', 'e
浏览 19提问于2018-08-26得票数 0
回答已采纳
我正在使用Flink，我正在使用Kafka连接器。我从flink收到的消息是一个逗号分隔的项目列表。"'在我的例子中，我必须编写自己的反序列化程序来实现DeserializationSchema并返回一个元组或Pojo。所以基本上用我自己的函数替换SimpleStringSchema()。https://github.com/apache/flink-pla
浏览 69提问于2020-10-24得票数 1
回答已采纳
我的Flink处理器监听Kafka，处理器中的业务逻辑涉及调用外部REST服务，并且这些服务可能会宕机。我想把元组重新放回处理器中，有没有办法这样做？我已经使用了Storm，我们将能够使元组失效，这样元组将不会被确认。因此，相同的元组将被重放到处理器。 在Flink中，一旦消息被Flink-Kafka Consumer消费，元组就会被自动确认。有一些方法可以解决这个问题。一种这样<
浏览 32提问于2020-03-31得票数 1
1回答
从上个星期开始，我用scala中的Flink构建了一个DataStream程序。但我的行为很奇怪，弗林克比我想象的要多。我的processFunction中有一个4 processFunction的元组( INT，long)，我用它在不同的时间范围内得到不同的唯一计数器，并且我预计大部分内存都被这个列表使用了。java.util.ArrayList
11: 8615581
浏览 1提问于2018-02-12得票数 1
我有一个序列列表，如：seq = [(1,2,3,4) , (1,2,4,3) (1,3,2,4) (1,3,4,2)]，等等。另一个列表包含索引的元组(index , value)及其相应的值，如：pos = [(3 , 4) , (1 , 2)] (在索引3，必须有4，在索引1，必须有2)。如何过滤出seq列表，以便删除不在pos列表中相应索引处的值的所有元组。例如，如果我有上面的seq和pos
浏览 1提问于2020-11-22得票数 0
回答已采纳
我的Flink管道目前使用一个Pojo，其中包含一些列表和映射( Strings)，按照 private List<String> myList =现在，Flink抱怨这些列表：
Exception in thread "main" java.lang.UnsupportedOperationException: Generic types haveat org.apache.flink
浏览 16提问于2020-01-18得票数 3
回答已采纳
1回答
我对Haskell非常陌生，我试图过滤包含字符串和字符串列表的元组列表。我想根据字符串列表是否包含某个字符串进行筛选。我想要创建一个列表列表，其中每个列表都是每个元组的第一个元素，对于过滤器，每个元组的计算结果都是true。示例：progLanguages =
[ ("CptS12
浏览 7提问于2022-02-25得票数 2
回答已采纳
3回答
我想在flink中缓冲一个数据流。我最初的想法是将100条数据缓存到一个列表或元组中，然后使用insert into values (???)将数据批量插入到clickhouse中。你有没有更好的方法呢？
浏览 36提问于2021-09-16得票数 1
我正在尝试一个简单的Flink程序，它只接受一个文件，反转文件中的字符串并写出它。例如。：import java.util.StringJoiner;
import org.apache.flink.api
浏览 1提问于2017-06-30得票数 0
回答已采纳
1回答
我有一个应该插入到数据库中的dicts inserts列表。由于一些元素已经在db db_entry_ids中，所以我想将它们过滤掉。我希望有一些简单的方法来提高效率。
PS：d["entry_id"]是一个字符串，db_entry_ids也是一个字符串列表。因此，id可能有点误导人。
浏览 0提问于2018-10-07得票数 1
回答已采纳
在storm中，我们执行collector.fail(元组)来重放元组。Flink中的类似方法是什么？
浏览 14提问于2019-02-22得票数 0
假设有一个字符串列表。我想从列表中获取n个字符串，并将其存储为一个元组。然后我想制作一个字典，其中最近创建的元组是关键字。做这件事最快的方法是什么？
浏览 10提问于2019-11-11得票数 0
3回答
高效的对象搜索/过滤
、、、、
在过滤类中，出于功能目的，我决定首先从表中获取所有数据，然后使用类本身过滤结果。我有一个表示表中所有数据的对象列表；我想知道过滤此结果以将其添加到jTable中的最快或更有效的方法是什么。我正在寻找它来模仿来自SQL的“喜欢”指令，与Java编程。
浏览 0提问于2012-06-22得票数 1
我想做一些DataSet转换，但是Flink中的最大列Tuple是Tuple25，包含25列。java.lang.IllegalArgumentException: The tuple type exceedsthe maximum supported arity
如果我不扩展Tuple类，我将这些行成功地映射为元组<
浏览 0提问于2018-06-17得票数 2
回答已采纳
我有一个元组列表，需要重复访问索引。最快的方法是将元组和它们的索引存储在一个数据块中吗？还是有更好的方法？
如果在有序的元组列表中存在一个元组，我需要有效地访问它的索引。我可以想到两种方法:调用列表中的.index，或者将元组作为键存储在字典中，以索引为值，并通过字典查找来查
浏览 4提问于2016-03-31得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
