Java 8 Streams - Map输出与预期不符
Java 8 Streams是Java编程语言中引入的一种函数式编程风格的API，用于处理集合数据。它提供了一种简洁、高效的方式来对集合进行转换、过滤和聚合操作。
在使用Java 8 Streams时，有时可能会遇到Map输出与预期不符的情况。这可能是由于以下原因导致的：
- 数据转换错误：在进行Map操作时，可能会出现数据转换错误的情况。例如，如果使用了错误的转换函数或者转换逻辑有误，就会导致Map输出与预期不符。解决这个问题的方法是仔细检查转换函数的逻辑，并确保它能正确地将输入数据转换为期望的输出格式。
- 并发问题：Java 8 Streams提供了并行处理集合数据的功能，可以通过parallelStream()方法来启用并行处理。然而，并行处理可能会引发并发问题，导致Map输出与预期不符。这可能是由于多个线程同时修改共享状态或竞争条件导致的。为了解决这个问题，可以考虑使用线程安全的数据结构或同步机制来保护共享状态，或者避免使用并行流。
- 数据源问题：Map操作的输入数据源可能存在问题，导致输出与预期不符。例如，如果数据源中包含了重复的元素或者不符合预期的数据结构，就会导致Map输出异常。解决这个问题的方法是检查数据源的内容和结构，并确保它们符合预期。
总结起来，当Java 8 Streams的Map输出与预期不符时，我们应该仔细检查数据转换逻辑、处理并发问题以及检查数据源的内容和结构。在解决问题时，可以参考腾讯云提供的相关产品和文档，例如腾讯云的云函数（SCF）和云数据库（TencentDB），以及相关的开发文档和示例代码。
参考链接：
- 腾讯云函数（SCF）：https://cloud.tencent.com/product/scf
- 腾讯云数据库（TencentDB）：https://cloud.tencent.com/product/tencentdb
相关·内容
我使用的是confluent 5.0.0版本* 我有一个如下的JSON数组： {
"name" : "David,Corral,Babu",
"age" : 23
} 通过使用kafka streams，我想根据"name“键值中的逗号标准将上述记录一分为二。输出应如下所示： {
"name" : "David",
"age" : 23
},
{
"name" : "Corral",
"ag
浏览 21提问于2019-01-11得票数 1
回答已采纳
我有卡夫卡流单元测试，基于一个非常伟大、可靠和方便的TopologyTestDriver：
try (TopologyTestDriver testDriver = new TopologyTestDriver(builder.build(),
streamsConfig(Serdes.String().getClass(), SpecificAvroSerde.class))) {
TestInputTopic<String, Event> inputTopic = testDriver.createInputTopic(inpu
浏览 3提问于2020-05-03得票数 0
我喜欢java8中的Streams概念。现在，我想在java Streams的帮助下将Java中的Map转换为排序列表。我只想显示列表而不将其存储在任何地方。我希望以下输出出现在结果列表中：
5, 7, 8, 10, 19, 20, 22, 28, 30, 35, 40, 45, 50 .
下面是我的代码：
Map<Integer, List<Integer>> obj=new HashMap<Integer, List<Integer>>();
obj.put(5, Arrays.asList(7,8,30));
ob
浏览 1提问于2017-04-20得票数 4
我正在尝试创建一个Kafka Streams应用程序来处理Avro记录，但我收到以下错误：
Exception in thread "streams-application-c8031218-8de9-4d55-a5d0-81c30051a829-StreamThread-1" org.apache.kafka.streams.errors.StreamsException: Deserialization exception handler is set to fail upon a deserialization error. If you would rather hav
浏览 3提问于2018-12-18得票数 6
回答已采纳
我是Java 8的新手，我正在研究streams，我有一个无法解决的问题：
int[] intArr = new {1,2,4,6,7,8};
我想使用Stream来获取数组中奇数位置的项。
预期结果：[1,4,7]
并使用流生成一个新的数组，该数组由：{intArr[i] + intArr[i+1]}组成
预期结果：[3,6,10,13,15]
浏览 0提问于2014-12-01得票数 0
我有一个kafka流应用程序，它映射/转换json消息并将输出流到一个主题。
KStream<String, String> logMessageStream = builder.stream(inputTopic, Consumed.with(stringSerde, stringSerde));
logMessageStream.map((k, v) -> { //Map record
try { // Map record to (requestId, message)
// readValue
浏览 0提问于2019-05-20得票数 0
回答已采纳
我需要使用java 8将<String, List<String>>映射为Map<String,String>，并假定值是唯一的。例如,
输入地图-
{"Fruit" -> ["apple","orange"], "Animal" -> ["Dog","Cat"]}
输出图
{"apple" -> "Fruit", "orange" -> "Fruit", "Dog&#
浏览 2提问于2019-10-01得票数 1
回答已采纳
我在TopologyTestDriver上遇到了一个问题，因为设置属性是必须的:当拓扑试图将记录发布到主题中时，它会转到配置中提供的"url“。我如何才能模拟指向MockedSchemaRegistry的访问？
要将avro中的记录写入主题，请使用mockSchemaRegistryClient.register
还有一个问题，我如何将stateStore加载到拓扑中？我正在初始化时创建stateStore (主题已经创建)
我的亲信：
testImplementation("org.junit.jupiter:junit-jupiter-api:5.3.1")
浏览 1提问于2018-10-17得票数 2
回答已采纳
我正在读取一个带有Java 8 streams的CSV文件，那么获取CSV文件中特定列的值的最佳方法是什么？
firstName,lastName,age,
tom,abraham,18,
liz,abraham,15,
tonny,paul,25
我想提取第二列，所以结果集应该是abraham;paul，Java8lambda和Streams如何做到这一点呢？
浏览 210提问于2018-08-27得票数 2
回答已采纳
如何使用java 8 streams api在这里获得预期的输出？
A1有B1，B2
A2有B1，B2，B3
B1，B2属于C1
B3属于C2
因此，对于C1，计数应为4作为B1，B2出现4次
同样，C2的计数将为1，因为B3出现1次
List<String> A= new ArrayList<>();
A.add("A1");
A.add("A2");
Map<String, List<String>> AMap = new HashMap<
浏览 1提问于2018-02-08得票数 4
回答已采纳
我将下面的json数据(在示例中)转换为List>，然后希望使用Java8 streams构建一个新的Map，输出应如下所示。有人能帮我一下吗？ Key value
Service1: DEACTIVATED
Service2: ACTIVATED
Service3: DEACTIVATED 例如： [
{
name=Service1,
desiredState=DEACTIVATED
},
{
name=Service2,
desiredState=ACTIVATED
},
{
name=Service3,
desiredState=DEAC
浏览 30提问于2021-07-15得票数 1
回答已采纳
4回答
我对Java 8非常陌生。
我想在Java8中执行下面的操作，可能使用streams。有办法做到这一点吗？主要目标是使用最好的java8方法将一个方法输出到另一个方法。
public Fob getFob(String paramString){
Optional<Foo> foo = getFoo(paramString);
if (foo.isPresent()) {
Optional<Bar> bar = getBar(foo.get().fooParamString);
if (bar.isPresent()) {
浏览 8提问于2019-11-14得票数 2
5回答
我已经看过了，但是我的问题有点不同。
我有一个"baseString"，n HashMap和一个输出字符串。我想用hashmap填充baseString，以构造json调用参数。
我已经用Java 7这样做了：
HashMap<String,Integer> element= getAllElement();
String baseElem="{\"index\":{}}\r\n" +
"{\"name\":\"$name$\",\"age\":$age$}&
浏览 0提问于2019-09-05得票数 2
回答已采纳
我有物品清单。每个对象都有属性"date“，我需要将这个列表转换为Map，其中键是"date”，而value是对象列表。
我可以通过使用标准foreach来实现这一点，但是使用Java 8和streams是否能够做到这一点呢？
浏览 4提问于2017-04-18得票数 3
回答已采纳
假设我有一个HashMap，并且我想要将相同的值插入到一个键列表中。在Java 8中，如何在不遍历所有键和插入值的情况下做到这一点？这更像是一个Java Streams问题。 下面是最简单的方法。这是我编写的示例代码，用于演示我想要实现的目标。 public void foo(List<String> keys, Integer value) {
Map<String, Integer> myMap = new HashMap<>();
for (String key : keys) {
myMap.put(key, va
浏览 21提问于2019-04-24得票数 3
我的问题可能太宽泛了，答案可能是简单的“不”，但我不得不问。
在Java7中是否有与(Java8) *等效的实现？
我熟悉(Java 8) streams，但我的项目要求是使用Java 7。
*不要与和混淆。
浏览 0提问于2015-05-05得票数 28
回答已采纳
如何通过相同索引的包含值将两个列表合并为一个列表。
我有2个列表，我想通过包含相同索引的值合并两个列表。
(如果可能，请推荐我使用java 8: Streams。)
List<String> a = Arrays.asList("1", "2", "3");
List<String> b = Arrays.asList("10", "20", "30");
输出：
{"11", "22", "33"}
浏览 22提问于2018-10-22得票数 0
我正在尝试弄清楚如何在以下情况下使用Java8 streams：
假设我有以下Map：
Map<String,String[]> map = { { "01": {"H01","H02","H03"}, {"11": {"B11","B12","B13"}} };
所需的输出将是：
map = { {"01": {"H02"}, {"11": {"B11"}};
我的尝试是：
map.entr
浏览 1提问于2018-04-13得票数 3
1回答
我试图发送一个ListKeyValue的主题，在一个卡夫卡流应用程序。但是流需要一个KeyValue。如何将KeyValues发送到流，而不是整个列表？
class MainTopology {
val createTopology = (sourceTopic: String, sinkTopic: String) => {
val builder = new StreamsBuilder()
builder.stream(sourceTopic)
.map[String, Option[JsonMessage]]((key, value) =>
浏览 1提问于2019-05-29得票数 2
回答已采纳
我尝试使用Streams API将以下Scala代码行转换为Java 8：
// Scala
util.Random.shuffle((1 to 24).toList)
为了用Java编写等价物，我创建了一系列整数：
IntStream.range(1, 25)
我怀疑在stream API中找到了一个toList方法，但IntStream只知道这个奇怪的方法：
collect(
Supplier<R> supplier, ObjIntConsumer<R> accumulator, BiConsumer<R,R> combiner)
如何使用Java
浏览 114提问于2013-11-19得票数 35
回答已采纳
1回答
我刚开始使用Java 8和streams，无法了解如何用Java 8编写这段代码：
Map<Integer, CarShop> result = new HashMap<>();
for (Car car : someListOfCars) {
List<CarProduct> listOfCarProducts = car.getCarProducts();
for (CarProduct product : listOfCarProducts) {
result.put(product.getId(), car.
浏览 3提问于2015-06-12得票数 5
回答已采纳
1回答
我有一个地图列表，List<Map<String,String>>的名称是streams。
看起来是这样的：
{
"key1" : "value1",
"key2" : "value2"
},
{
"key1" : "value1",
"key2" : "value2",
"key3" : "value3"
},
{
"key1" : "va
浏览 1提问于2022-05-15得票数 1
回答已采纳
1回答
有很多java第三方库可以在Java集合中提供高性能的服务。根据这个DZONE ，有一些遵循OSGI模型并在Java中提供高性能的本地库，或者执行其他一些操作。现在，在Java 8中，启动Streams是为了在集合库中提供良好的性能，我们还使用Streams执行一些并行操作。以下是我的问题：
与第三方库(如Trove、Javolution等)相比，Java具有更好的性能。
是否可以将Java 8 Streams与其他集合库一起使用？
浏览 0提问于2014-05-08得票数 4
我试图使用kafka流来执行加窗口的聚合，并且只有在某个会话窗口关闭后才会发出结果。为了实现这一点，我使用了抑制函数。
问题是，我找不到一种方法来使这个简单的测试工作，因为当它试图持久化状态时，我会得到一个类强制转换异常，因为它试图将窗口转换为String。我试图向聚合函数提供一个Materialized<Windowed<String>,Long,StateStore<>>，但它没有输入check，因为它期望第一个类型只是字符串。
我在这里错过了什么？
kafka版本2.1.1
package test;
import org.apache.kafka.
浏览 0提问于2019-03-15得票数 1
回答已采纳
6回答
我正在学习Java8，有没有办法把下面的方法变成Java8Streams、filter和forEach。如果是，是如何实现的？ String[] couponList = coupons.split(",");
for(String coupon:couponList) {
singleCouponUsageCount = getSingleCouponUsageCount(coupon);
if(singleCouponUsageCount >= totalUsageCount)
return 0;
}
return 1;
//
for(Stri
浏览 36提问于2019-12-20得票数 2
回答已采纳
3回答
考虑一下这个二维数组
String[][] names = { {"Sam", "Smith"},
{"Robert", "Delgro"},
{"James", "Gosling"},
};
使用经典的方法，如果我们想要访问一个二维数组的每个元素，那么我们需要使用二维for循环来迭代二维数组。
for (String[] a : names) {
for (String
浏览 2提问于2015-05-06得票数 13
回答已采纳
2回答
我的意见如下：
List<Map<String, String>> = [{1=a, 2=b, 3=c},
{1=d, 2=e, 3=f}]
List<String> = [x, y, z]
预期产出如下：
[
{1=a, 2=b, 3=c, 4=x},
{1=a, 2=b, 3=c, 4=y},
{1=a, 2=b, 3=c, 4=z},
{1=d, 2=e, 3=f, 4=x},
{1=d, 2=e, 3=f, 4=y},
{1=d, 2=e, 3=f, 4=z}
]
我的守则：
import j
浏览 8提问于2022-04-07得票数 2
回答已采纳
我想使用Java8中的函数映射将一个Map<String, Integer>转换为另一个Map<String, Long>，通过两个映射中的键将数据与函数进行匹配。您可以假设这两个映射具有相同的键。
我尝试了以下方法：
Map<String, Integer> inputData = new HashMap<>();
inputData.put("A",8);
inputData.put("B",7);
inputData.put("C",6);
Map<String, Function&l
浏览 23提问于2016-01-13得票数 16
回答已采纳
有没有人能告诉我为什么这个案例会有例外？
IntStream i = IntStream.of(6,5,7,1, 2, 3, 3);
IntStream d = i.map(n -> n+1 );
d.forEach(System.out::print);
System.out.println();
System.out.println("Origional Streams" );
i.forEach(System.out::print);
下面是输出。
7682344
Origional Streams
Exception in
浏览 0提问于2018-02-09得票数 0
我有以下代码：
List<SoldProduct> soldProducts = new ArrayList<>();
for (Product product : products) {
for (ProductCartDTO productCartDTO : dto.getProducts()) {
if(product.getId().equals(productCartDTO.getIdProduct())){
soldProducts.add(new SoldProduct(prod
浏览 0提问于2017-12-29得票数 1
回答已采纳
我有一个Thing对象的列表：
class Thing {
public String id;
public String name;
}
List<Thing> lst包含以下内容：
[{'1', 'AB'},{'2', 'CD'},{'1', 'AB'},{'1','AB'},{'2','CD'},{'3','EF'}]
现在我想使用Java streams或任何util函
浏览 2提问于2018-12-09得票数 9
2回答
我正在尝试将基于Stream的映射转换为二维数组。我已经知道如何将其存储在一维数组中。下面是可用的代码片段：
Float[] floatArray = map.entrySet()
.stream()
.map(key -> key.getKey().getPrice())
.toArray(size -> new Float[size]);
当我执行上面的代码时，我按照预期填充了我的Float数组。现在我需要将其扩展到一个二维数组，其中我
浏览 0提问于2017-11-21得票数 9
回答已采纳
我正在尝试窗口一个数据流，对于每个窗口，我需要该窗口中的值列表，并为此创建了一个自定义的avro，其中包含一个字段records，它是一个Input列表。聚合函数有Materialized部分，因为我有问题。
KStream<String, Input> windowedStream = timestampFilteredStream
.groupByKey()
.windowedBy(TimeWindows.of(Duration.ofSeconds(10)).grace(Duration.ofSeconds(5)))
浏览 0提问于2019-04-16得票数 0
回答已采纳
1回答
我正在学习如何使用Java 8 streams。如何使用streams而不是for循环来完成以下操作：
public static void clump(ArrayList strList)
{
for(int i = 0; i < strList.size() - 1; i++)
{
String newStr = "(" + strList.get(i) + " "
+ strList.get(i + 1) + ")";
strList.set(i, ne
浏览 0提问于2017-02-18得票数 3
1回答
我正在尝试将下面的嵌套循环转换为streams Java 8。
newself2中的每个元素都是一个字符串列表--“12”、"3 4“需要更改为"1”、"2“、"3”、"4“。
for (List<String> list : newself2) {
// cartesian = [["1 2","3 4"],["4 5","6 8"]...] list = ["1 2","3 4"]...
List<String> c
浏览 0提问于2018-04-10得票数 3
回答已采纳
此问题与相关
但是，在Java8/ 9中如何使用streams复制数组呢？
这是我想出来的：
static int[][] cloneArray(int[][] array) {
return IntStream.range(0, array.length).collect(
() -> new int[array.length][],
(ints, i) -> ints[i] = array[i].clone(),
(ints, i) -> {});
}
有没有使用streams复制2D数组的更
浏览 14提问于2018-01-03得票数 1
回答已采纳
1回答
我有一个收集的溪流，我试图把ZIP合并成一个流。我正在使用番石榴Streams.zip方法来压缩流。当集合中的流数低于8000时，它工作得很好，超过8000时，它开始抛出堆栈溢出异常。在本地调试时，我发现堆栈溢出发生在zip方法中。它成功地压缩到8000流，然后开始抛出异常。我无法找到解决这个问题的办法，也无法解释为什么会发生这种情况。在这附近需要帮助才能找到。番石榴邮政编码在这里
我尝试了本地调试。将我所有的lambda调用转换为vanllafor循环，所以为了确认我们没有调用任何由zip函数引起的recursively.Finally引脚。
源代码：
合并方法，它使用zip。
privat
浏览 4提问于2022-11-10得票数 0
回答已采纳
1回答
我有一个带构造函数的班级人员 Person(Fruit... favoriteFruits) {} 3个对象(比方说) Person A = new Person(Apple);
Person B = new Person(Banana, Papaya);
Person C = new Person(Pineapple, Orange); 以及Person Fruit[] getFavouriteFruits(){}类中的方法 使用streams，我尝试将其转换为Map 预期输出: Map of ((Apple，A)，(Banana，B)，(Papaya，B)，(Pineapple，C)，(
浏览 12提问于2020-01-22得票数 2
我正在实现一种机制，通过在本地存储或请求远程Kafka实例来提供一些元数据信息。
我正在使用Scala和kafka-streams-scala库的2.4.1版本
我试着给你们简单的例子来说明我在做什么
，我正在运行Kafka集群，它创建了一个带有两个分区的测试主题。也运行了一个Kafka流实例，正如我前面提到的，它实现了从存储中请求本地或远程元数据的机制，它保存所有分区信息，直到没有任何其他实例连接到同一个组为止。将一些记录推入测试主题中。
kafkaProducer.send(new ProducerRecord<>("test-topic", 0, "1
浏览 2提问于2020-08-03得票数 0
回答已采纳
我正在创建一个Kafka Streams应用程序，我的主题数据来自Protobuf。我们可以为此创建Java代码绑定。但是，我正在努力使用正确的serde来使用topic中的数据。有没有人能分享一下我做错了什么。 下面是我使用的属性定义： Properties properties = new Properties();
properties.put(StreamsConfig.APPLICATION_ID_CONFIG, "my-app-id-config");
properties.put(StreamsConfig.BOOTSTRAP_SERVERS_C
浏览 37提问于2021-01-08得票数 1
使用Java8Streams，我如何将一个Map<Integer, Map<String, Boolean>>展平为一个List<Boolean>，以便最终的列表将包含所有值的所有布尔值？
以下是数据的示例：
1 -> [{"ABC" -> true}, {"DEF" -> true}]
2 -> [{"DEF" -> false}, {"EFG" -> true}]
3 -> [{"ABC" -> true}, {"DEF
浏览 2提问于2017-12-10得票数 0
我正在尝试学习卡夫卡流的单词计数示例。下面是使用的代码。我已经从项目中创建了一个胖jar，并开始生成主题word-count-input1的消息，并从word-count-output1获取输出。但是当我运行胖罐子时，我看到异常- org.apache.kafka.streams.errors.StreamsException: Failed to deserialize value for record.
Properties properties = new Properties();
properties.put(StreamsConfig.APPLICATION_ID
浏览 6提问于2017-08-23得票数 0
我正在将Spring应用程序升级到Boot2.6.1、Cloud2021.0.0和CloudStream3.2.1。
这个应用程序有一堆KStreams，如：
@Bean
fun processEvent() =
Function<KStream<ID, EventReceived>, KStream<Id, UpdatedInfo?>> { events ->
...
}
现在，应用程序在启动时崩溃：
Caused by: org.springframework.kafka.Ka
浏览 25提问于2021-12-16得票数 2
回答已采纳
我有下面的json对象。如何使用java 8 streams更新因子变量为空？ [{
"name": "sasi",
"surname": "test",
"factor": 3
},
{
"name": "sasi",
"surname": "test",
"factor": null
}] rawResponseMapList.stream().forEach(map ->ma
浏览 2提问于2020-06-10得票数 0
回答已采纳
2回答
我已经从avro模式生成了三个类-
public class User extends SpecificRecordBase implements SpecificRecord {
public UserAttrs userAttrs;
public UserKey userKey;
}
public class UserAttrs extends SpecificRecordBase implements SpecificRecord {
public Long clicks;
public Long purchases;
public Long v
浏览 2提问于2022-06-14得票数 0
回答已采纳
我试图理解新的Java 8 Streams，我花了几天时间在Java 8 Streams中的集合上传输嵌套的foreach循环。
是否可以重构以下嵌套的foreach循环，包括Java-8-Streams中的if条件？
如果是，它看起来是什么样子。
ArrayList<ClassInq> Inq = new ArrayList<>();
TreeMap<String, SalesQuot> Quotations = new TreeMap<>();
ArrayList<ClassInq> tempInqAndQuot = new A
浏览 2提问于2014-08-18得票数 3
回答已采纳
1回答
我有一个Map<String, Set<String>>，假设它是{"a": {"a1", "a2", "a3"}, "b": {"b1", "b2", "b3"}, "c": {"c1", "c2"}, "d": {}} 我有一个映射键集的流，我想将流集的每个元素扁平映射到我的映射中相应值集的元素，例如 输入流： {"a","b"}
{"
浏览 8提问于2019-10-12得票数 1
应用使用kafka版本为2.7.0
在pom.xml中尝试使用kafka stream maven version2.2.1 kafka stream，然后启动stream并获得预期的输出。
但是，当在pom.xml中更新到maven版本2.3.0(或更高版本)时，从日志和流中得到的以下错误不会启动
Exception in thread "Average-3ded0155-d697-492b-897b-4da5bfec5cf1-StreamThread-1" org.apache.kafka.streams.errors.ProcessorStateException: Er
浏览 1提问于2021-02-07得票数 0
如何使用Java8- streams、forEach或其他工具获取MutablePair列表的左侧部分？我想转换成Java 8类型的代码是： for (MutablePair<String, Long> id: list) {
if (null == value) {
value = id.getLeft();
} else {
value += ", " + id.getLeft();
}
} 因此，如果列表为：[(OA,3853), (EE,866), (UN,728), (PP,10)]，则需要尽可能简单的值：OA,
浏览 50提问于2019-10-09得票数 3
回答已采纳
4回答
我使用openjdk:8-高寒来部署Kafka应用程序。我使用的是窗口，它崩溃时有以下错误：
Exception in thread "app-4a382bdc55ae-StreamThread-1" java.lang.UnsatisfiedLinkError: /tmp/librocksdbjni94709417646402513.so: Error loading shared library ld-linux-x86-64.so.2: No such file or directory (needed by /tmp/librocksdbjni9470941764640
浏览 1提问于2019-03-04得票数 11
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
