我现在已经用print方法替换了foreach块中的'put‘。 问题是： 我需要执行两个操作-从位于父行中的两个元素获取数据。我一直在尝试了解如何做到这一点，但现在我想我需要帮助。
浏览 8提问于2020-04-25得票数 1
回答已采纳
2回答
我正在编写一个从CSV文件中获取数据的Java程序。对于每一行数据，我需要使用相应的头作为键将每个数据元素放入映射中。例如，headerRow7和dataElements7应该是映射中的键值对。下面是我传统上使用Java编写的代码：
private Map<String, Double> readLine(String[] headerRow, String[] dataElements) {headerToDataMap.put(headerRow[i], Double.v
浏览 0提问于2016-11-08得票数 3
在过去的Java中，我们可以循环一个集合，并且每个X项都会执行特定的操作-例如，将大量项保存到DB：List students = ....;for(i % 100 == 0){ reportProgressToSlack(...); }当尝试使用Streams做类似的事情时，我们得到一个错误：
int coun
浏览 0提问于2019-12-02得票数 3
我正在使用spring cloud streams来消费来自Kafka的消息。 可以从代码中读取Kafka消息密钥吗？ 我有一个卡夫卡主题，通常有两种类型的消息。根据消息键的不同，要执行的操作会有所不同。我看到了spring文档中只有以下几个要阅读的消息。在这里，我需要指定消息的实际映射(这里是Greetings类)。但是，我需要一种方法来读取消息键并确定可反序列化的Pojo public class Greetin
浏览 20提问于2019-02-13得票数 1
回答已采纳
我一直在使用streams，然后我注意到，当我执行以下操作时，它不会在控制台中产生输出： String[] is = {"Hello", "World", "My", "Name", "Is", "Jacky"};
Arrays.stream(is).peek(s -> System.out.println(s)); 我认为这是因为peek()是一个非终止流方法，应该使用<
浏览 15提问于2021-04-21得票数 1
回答已采纳
我正在尝试将一个映射转换为另一个映射，其中新的密钥只是原始密钥toString()。使用streams API，我按如下方式执行此操作： (Map.Entry如果原始映射恰好是一个HashMap，我并不介意返回一个TreeMap，但是如果删除了对元素的排序，那么另一种方式就会有问题。为了完成这项工作，我一直在
浏览 8提问于2017-06-17得票数 3
回答已采纳
我仍然可以用一个字符串来调用get()，如果这样的元素存在，我就会正确地获取存储的对象。 trick = "jack".concat(trick); }
浏览 1提问于2018-02-15得票数 1
1回答
菜鸟问题在这里。Typescript应用程序存储所有数据，Scala one与之交互。我需要一种简单的方法来解析映射中的项到case类，如果HazelCast数据保存在Scala中，这是很容易的，因为它可以转换，但当我尝试对从Typescript存储的数据执行此操作时，我得到以下结果
java.lang.ClassCastException:
浏览 2提问于2020-05-11得票数 0
2回答
我正在努力从Rx Java迁移到Java 8 lambdas。我找不到的一个例子是缓冲请求的方法。例如，在Rx Java中，我可以这样说。RX中的observable是一种"push“风格的observable，而as Streams使用的是java pull。这是否有可能在流中实现我自己的映射操作，或者无法发出会导致问题，因为doOnNext必须轮询前一个元素？
浏览 0提问于2015-02-22得票数 10
1回答
我对Redis streams非常感兴趣。(看起来有可能构建由append-log驱动的小型系统，如Kafka，但没有Kafka的所有开销。)它看起来很简单，可以通过XADD访问日志/流，并使用日志/流中的条目。但是如果你想跨两个流加入呢？ Kafka Streams、Flink、Spark等提供了这样做的方法。在Redis宇宙中有没有等价物？ 如果不是，我想我只需要实现我自己的东西，从两个流中消费，从消息中执行自
浏览 12提问于2019-03-23得票数 6
4回答
所以，我希望我的清单有：总有一种方法可以迭代并创建另一个列表，但是有没有更好的方法呢？(不一定要高效，但如果可以使用流在一行中完成，则foreach e.t.c.)。我尝试使用一个方法(charAPresent())执行以下操作，该方法检查传递的字符串是否包含字符'a‘，但不起作用：
List<
浏览 0提问于2019-06-12得票数 1
1回答
Set<String>>，假设它是{"a": {"a1", "a2", "a3"}, "b": {"b1", "b2", "b3"}, "c": {"c1", "c2"}, "d": {}} 我有一个映射键集的流，我想将流集的每个元素扁平映射到我的映射中相应值集的元素，例如 输入流： {
浏览 8提问于2019-10-12得票数 1
因为我使用Json值，所以没有设置默认的serdes。我处理一个KStream，使用必要的spring和product (json) serdes，但是下一步(地图操作)失败：props[StreamsConfig.APPLICATION_ID_CONFIGSerde<Product> = Serdes.serdeFrom(JsonPojoSerializer<Product>(), JsonPojoDeserializer(Product::class.j
浏览 0提问于2018-08-26得票数 0
回答已采纳
1回答
它们是初始化的，字段是通过两个源(比如文件和数据库)填充的。之后，我需要将一个类中的每个属性与另一个类相加，并在第三个结果类中生成两个类的总和。testFileValues.getA() + testDBValues.getA());有没有一种更干净的方法可以通过Java 8来实现这一点，比如lambda或streams？我想过
浏览 0提问于2019-06-13得票数 0
我想使用Java8中的函数映射将一个Map<String, Integer>转换为另一个Map<String, Long>，通过两个映射中的键将数据与函数进行匹配。您可以假设这两个映射具有相同的键。我尝试了以下方法：inputData.put("A",8);
inpu
浏览 23提问于2016-01-13得票数 16
回答已采纳
我有这个方法，它返回一个Map： public Map<String, List<ResourceManagementDTO>> getAccountsByGroupNameMap(final我设法找到了另一种返回LinkedHashMap的方法，但是使用该语法我不能再执行映射操作(将AccountManagement映射到ResourceManagementDTO)。.collect(groupingBy(acc -&
浏览 135提问于2020-09-04得票数 1
回答已采纳
我正在使用Java1.6运行我的应用程序，并计划将一些方面与Kafka集成。
我正在探索是否应该使用Kafka Consumer (使用poll())或使用KafkaStreams API。我们需要Java 1.7 / 1.8来使用Stream API吗？
浏览 3提问于2018-12-20得票数 0
2回答
我正在寻找一种实现非终端分组操作的方法，这样内存开销将是最小的。我知道我可以使用迭代器包装器和自己实现分组逻辑来实现迭代器。是否有更简单的方法来使用streams来实现这个功能呢？-编辑--
我找到了
浏览 3提问于2015-04-12得票数 8
回答已采纳
2回答
在使用interest属性对不同列表中的对象进行分类时，我遇到了问题。private String interest;}
我试图显示用户取决于一定的兴趣，但我觉得有一个更容易的方法做这比我已经尝试过我需要兴趣列表是动态的，而不是在switch中使用一组固定的元素，而且我也不知道是否有更好和更有效的方法，而不必为每个兴趣使用3 lists列表。String interest = u.get
浏览 2提问于2017-12-09得票数 4
回答已采纳
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
