回答情况：
提问时间：
问题标签：
Redis团队为Redis5.0引入了新的数据类型。由于流看起来像卡夫卡主题，从第一视图，似乎很难找到现实世界的例子使用它。
使用AOF复制将所有数据
浏览 1修改于2021-05-09得票数 21
Hi试图找出如何映射到EnumMap，但没有成功。目前，我正在用两个步骤完成它，我创建了地图，然后我将它变成了一个EnumMap。问题是。
Map<CarModel，CarBrand>输入。Map<CarBrand，CarsSellers> ret = input.values() .stream().filter(品牌-> !brand.equals(CarBrand.BMW)) .collect(Function.ide
浏览 2修改于2016-05-17得票数 10
回答已采纳
我正在尝试缩短流，但它似乎比我预期的更难。这是我的尝试：const Twitter = require('twitter')
// init Twitter Streaming API for OAuth consumer_key
浏览 15修改于2016-12-28得票数 2
在Akka Streams中推荐使用GraphStage，但我找不到任何关于在Java语言中使用getStageActor()方法的文档(我找到的所有文档都使用Scala)。
浏览 28修改于2018-02-10得票数 1
回答已采纳
1回答
此函数的返回值必须是流。在非监视模式下，这很简单；只需返回rebundle，browserify流被转换，诸如此类。然而，在监视模式下，rebundle会在每次更新时运行，并且每次都会创建一个新流。我需要一种方法来合并所有这些流，因为它们被创建为一个我可以返回的无穷无尽的流，实际上可以一直消费下去。使用组合流，似乎一旦数据被读取，流就不再是可写的，所以这是不可能的。任何帮助都将不胜感激！
浏览 0提问于2014-07-18得票数 1
当我使用streams时，我得到了NoSuchElement异常。foreach()替代方案(评论)运行良好。我想知道为什么它会抛出异常，如果使用流实现的话。
浏览 3修改于2021-01-16得票数 0
3回答
我很好奇，有没有关于在D中包含streams的讨论？过去，C++流对我有很大的帮助，它们看起来比使用printf/writefln之类的函数要干净得多。
浏览 1修改于2011-04-06得票数 10
回答已采纳
我正在尝试理解redis streams如何进行分区，如果可以将特定的消息发送到特定的分区(类似于使用Kafka的方式)。
浏览 41提问于2021-10-07得票数 1
回答已采纳
我目前正在设计一个带有flutter的聊天应用程序，我正在使用Firestore来做这个。我想知道这些流是如何工作的，因为我想知道读取的次数，这样我就可以预测限制。假设目前有315条消息，并且所有消息都在聊天屏幕中。如果一个人输入了一条新消息，这将是第316条消息，因此flutter stream将读取所有316条消息，或者只是获取新添加的消息并将其附加到315个成员的列表中。 我看到很多视频阅读博客，他们就是忽略了这一点。我想清楚地理解这一点。 return StreamBuilder<QuerySnapshot>(
stream: _firestoreDataba
浏览 23修改于2020-06-25得票数 0
回答已采纳
我对Redis streams非常感兴趣。(看起来有可能构建由append-log驱动的小型系统，如Kafka，但没有Kafka的所有开销。)Kafka Streams、Flink、Spark等提供了这样做的方法。在Redis宇宙中有没有等价物？如果其他人有使用Redis Streams进行此操作的经验，请分享您的提示或警告。
浏览 12提问于2019-03-23得票数 6
我在项目中使用的org.apache.kafka/kafka-streams scala版本应该与org.apache.kafka/kafka-stream版本相同吗？或者，例如，我可以将kafka-streams-scala版本2.2.0与kafka-streams-scala版本2.0.1一起使用吗？
浏览 15修改于2019-04-22得票数 0
你好，我是一个非常新手的流等，只是为了培训的目的，我试图建立简单的api与mapstruct。我的问题是，我真的不知道如何返回转换的父值与转换的字段在这个实体中。public class RecipeDTO {
浏览 56修改于2018-10-02得票数 0
回答已采纳
我想从连接池项目转换一段代码，我一直在使用流for (Map.Entry<JdbConnection,Instant> entry : borrowed.entrySet()) { JdbConnection jdbConnection = entry.getKey(); if (timeElapsed.toMillis() > lease
浏览 0修改于2015-12-18得票数 6
回答已采纳
如果我有一个包含整数的列表，并且只需要一个方法来打印该列表中的某些数字。我该怎么做呢？我到目前为止的尝试是：System.out.print("odd: "); printSelected(MyIntegers, odd);
public static void pri
浏览 15修改于2017-02-13得票数 0
回答已采纳
我写了一个kafka streams代码，使用kafka 2.4 kafka客户端版本和kafka 2.2服务器版本。我有50个分区在我的主题和内部主题。getId())
.to("bulk_consumer"); 和 props.put(StreamsConfig.STATE_DIR_CONFIG, /tmp/kafka-streams
浏览 49修改于2020-01-08得票数 1
别管那些“为什么？”、“没用了？”和“别费心了”的评论。我想用clang在另一个程序中编译一个程序。我可以创建NSTask并设置参数，如果文件存在，它将工作，(即.没有流)，并写入物理文件。我还没能得到我真正想要的东西，那就是同时使用流作为输入和输出。我知道如果您使用-xc和-选项，clang和gcc都允许编译标准输入，但无法使用管道实现该功能。我也不确定如何将clang的输出重定向到文件句柄或流。task = [[NSTask alloc] init];
NSPipe* outputPipe = [[NSPipe alloc] init
浏览 9提问于2012-06-06得票数 1
回答已采纳
我正在尝试实现来自AWS的Dynamodb Streams Java示例。我得到以下两个错误重复了几次，然后程序按预期完成。你知道原因是什么吗？
浏览 0修改于2015-09-30得票数 4
(RocksDBTimestampedStore.java:87) at org.apache.kafka.streams.state.internals.WrappedStateStore.init(WrappedStateStore.java:54)
at org.apache.kafka.streams.state.internals.WrappedS
浏览 1修改于2021-02-07得票数 0
我有一个关于nodejs中的管道的问题。我有一些代码，应该显示当前目录中的文件列表，但它出乎意料地工作。const config = {distPath: '.',scanPath: '.'};
fs.readdir(
浏览 7提问于2017-11-27得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号