stream 相关问题

流是一系列可以以串行方式访问的数据元素。对于Java 8的新Stream API，请改用java-stream标签。

如何通过使用StreamBuilder访问开始集合内部的集合

我想知道如何访问开始集合内的集合的字段？（参见下图）这是我用来访问start（first）的streamBuilder ...

flutter google-cloud-firestore stream

回答 1 投票 0

如何了解Modelica模型中的Instream运算符？

我正在学习如何在Modelica模型中使用流内运算符，但是我对以下示例感到困惑，为什么我需要两个方程式来描述能量平衡？这是否意味着...

stream modelica

回答 1 投票 0

如何在Apache Flink的StreamTableEnvironment中实现timeWindow（）？]

每个人，我都想在StreamTableEnvironment中使用flink时间窗口。我以前曾将timeWindow（Time.seconds（））函数与来自kafka主题的dataStream一起使用。对于外部...

apache-spark apache-kafka stream apache-flink

回答 1 投票 0

使用Java8将两个映射合并到对象列表

给出2个Map和一个对象Map >水果=新的HashMap <>（）; fruit.put（1，Arrays.asList（“ apple”，“ banana”））; fruit.put（2，Arrays.asList（“ orange”，“ kiwi”）））;地图＆...

java java-8 stream

回答 2 投票 0

是否指定了Kafka Streams拓扑的处理顺序？

我想知道是否指定了流拓扑处理消息的顺序。示例：//读取输入消息KStream inputMessages = builder ....

apache-kafka stream apache-kafka-streams

回答 1 投票 0

Java 8遍历列表，根据字段进行过滤并求和

我想遍历列表，根据特定字段进行过滤，并获得总和类Transaction {private String heading;私人LocalDate日期；私人BigDecimal金额； } ...

java arraylist java-8 stream

回答 1 投票 -1

s3-streams env AWS_REGION缺失

s3-streams引发了以下错误，但没有明确的详细信息。错误[ERR_UNHANDLED_ERROR]：未处理的错误。（[object Object]）在S3ReadStream.emit（events.js）在S3ReadStream.EventEmitter.emit ...

node.js amazon-s3 stream sdk aws-sdk

回答 1 投票 0

[发生错误时如何重试kafka消息-春季云流

我对Kafka还是很陌生。我正在使用春季云流Kafka来产生和使用@StreamListener（Sink.INPUT）公共无效流程（订单顺序）{试试{//让我的消息处理...

spring apache-kafka stream

回答 1 投票 0

如何通过neo4j-stream向kafka发送节点集合

我们想使用Neo4J构建（产品）类别的层次结构（树结构）。我们的数据从Kafka（接收器连接器）输入。我们计划使用Neo4J Streams Source在我们的...

neo4j apache-kafka stream cypher

回答 1 投票 1

如何使用流代替for循环

我想使用Stream编写下面的代码，而不是使用for循环私有Car getCar（String CarRef，List cars）{for（Car car：cars）{if（carRef.equals（car ... 。

java-8 functional-programming stream java-stream

回答 2 投票 0

在可迭代对象上使用数组方法

[我想知道是否存在一种/简单的方法来使用全局JavaScript Array对象的方法，例如Iterables上的Array.prototype.map，Array.prototype.reduce甚至Array.prototype.filter ...

javascript arrays stream iterable

回答 1 投票 0

按数组索引过滤Java流

我有一个这样的行：成人识字率，15岁以上人口，女性（％），坦桑尼亚联合共和国，2015,76.08978成人识字率，15岁以上人口，女性（％），津巴布韦， ...

java stream

回答 2 投票 0

[用于简单转发程序的Kafka流传递语义

我有一个无状态的Kafka Stream，它从一个主题中消费并发布到forEach中的另一个队列（Cloud PubSub）中。拓扑并没有终止于产生新的Kafka主题。我如何...

apache-kafka stream streaming apache-kafka-streams confluent

回答 1 投票 1

操作列表以返回地图

目标：列表对于每个我仅想返回ID和名称的用户dto，格式应类似于：[{“ id”：1，“ name”：“ ruben”}，{“ id”：2，2，“ name “：null}]我的尝试：List＆...

java-8 stream

回答 1 投票 0

比较流

我需要检查给定的流是否为终端流。例如，我使用* standard-output *做（等于（同义词流符号-standard-output *）* terminal-io *），但是它返回nil。这很奇怪...

stream lisp common-lisp

回答 1 投票 0

是否可以在FFMPEG中使用CSA解密？

首先，很抱歉，我问错了问题。我目前正在使用vlc（libdvbcsa）加密和解密实时流，仅通过在服务器上提供csa-ck = {key}即可将其保存到ts文件中...

encryption ffmpeg stream cryptography vlc

回答 1 投票 0

Java流，根据对象中的条件进行过滤，将值设置为字符串和数组

我是Java流的新手。尝试根据Java流中的条件设置2个值。我尝试使用平面图。可能做错了。我想转换为工作流的工作代码...

java filter stream mapping

回答 2 投票 0

每当流获得新值时如何显示对话框？

我有以下块提供程序类CloudMessagingBloc {StreamController _streamController = StreamController （）;流 ]

flutter dart stream

回答 1 投票 0

从套接字和inputStream读取缓慢

我使用java.net.Socket在我的应用程序中接收消息。接收速度很慢。接收250 kB持续7秒以上。我可以做些什么来加快这一步。 7秒太多了... InputStream是= ...

java performance sockets stream inputstream

回答 3 投票 3

如果使用Java Stream API，如何在调用reduce之后打印出列表列表？

所以，到目前为止，我试图将字符串读入流，然后最终使用输出。到目前为止，唯一的目标就是简单地将其打印出来而没有错误，但是到目前为止，我还没有运气。 ...

java exception arraylist stream mapreduce

回答 2 投票 -1

stream 相关问题

最新问题