我正在尝试创建一个SourceOut，Mat from a Future[SourceOut，Mat]，并将内置的source.fromFuture与flatMapConcat结合使用。但是，在使用fromFuture时，源的物化值为NotUsed。当flatMapConcatenating实际的源时，物化的值保持为notUsed。是否可以获取在flatMapConcat中使用的源的物化</
浏览 8提问于2016-07-30得票数 4
回答已采纳
1回答
当我创建一个源时，我试图创建物化值，如下所示：val source: Source[String, Future[Info]] = Source.single如何创建具有物化价值的源？
浏览 0提问于2019-04-13得票数 2
回答已采纳
我正在尝试使用akka-streams和akka-http以及alpakka库下载/上传文件到亚马逊S3。我看到两个可能相关的问题..。
处理请求时出错：“子流源没有在5000毫秒内物化”。完成500内部服务器错误响应。若要更改默认异常处理行为，请提供自定义ExceptionHandler。akka.stream.impl.SubscriptionTimeoutExceptio
浏览 4提问于2017-09-19得票数 2
1回答
保持组合的意义？
、、
我试图在akka中的Keep组合下创建以下示例：import akka.actor.ActorSystemSink[String, Future[IOResult]]，这意味着它接受字符串作为输入，当物化时它将创建Future[IOResult]类型的辅助信息(当链接源上的操作或流辅助信息的类型时--称为“物化值”-is，由最左边的起点给出；因为我们希望保
浏览 0提问于2019-04-12得票数 4
回答已采纳
2回答
我对akka流很陌生，我想了解流中的物化是如何工作的。我想看看Keep.left和Keep.right给出了不同的值，以及我们如何使用Keep.both
浏览 4提问于2020-12-22得票数 2
回答已采纳
假设有一个Source[Int, NotUsed]类型的源。如何将其转换为Source[Int, T]，其中物化值T是根据源的元素计算的？示例:我想对流中的元素求和；如何实现dumbFlow，这样结果应该是6而不是42？ val dumbFlow = ???result = source.toMat(Sink.ignore)(Keep.left).run()
//result: Int = 42 我知道如何使用Sink.fold或
浏览 20提问于2021-09-28得票数 1
回答已采纳
1回答
镜像表与物化视图
、、、、
从这个优秀的视频"“中，我知道有不同的方法可以将数据块分割成单独的数据库用于微服务：
事件源你能解释一下镜像表和物化视图的区别吗？
浏览 10提问于2017-07-10得票数 0
2回答
假设我有repo - ，当我派生它的时候，它有两个分支-- master和release。
假设几天后，有人向上游添加了新的分支feature。如果我想把这个新分支放到我的fork中，我应该使用哪些git命令？
浏览 0提问于2018-09-11得票数 0
我有一个生产Oracle数据库，我想导出表、数据、视图、物化视图、同义词等等，以便导入开发Oracle数据库。我了解TABLE_EXISTS_ACTION和4个选项SKIP | APPEND | TRUNCATE | REPLACE，但如何处理从源数据库导出的表名与目标数据库中的物化视图名称冲突的情况，反之亦然当名称属于一个数据库中的一个表和另一个数据库中的同义词时-- impdp在这种情况下做什么，或者我应该如何处理？实际上，我并不
浏览 0提问于2020-07-29得票数 0
我有一个数据源，它是存储在sharepoint文件夹中的一个.xlsm excel文件，我需要将该文件带入Power (由于设置错误，我无法获得数据> Sharepoint文件夹)。另一个是保存在sharepoint中的.csv文件，我已经把它带来了。.csv文件的power查询m代码中的源函数是：我需要为.xlsm文
浏览 3提问于2022-07-21得票数 0
回答已采纳
我在我自己的模式中有物化视图，物化视图源是另一个模式表，但是，这个主表有900行，我在这个主表上做了一些dml操作，之后我将刷新这个物化视图，正如你所知道的，我做了一些研究“如何刷新我自己的物化视图”，它说“你可以进行完全刷新或快速刷新”，但我不理解这些解决方案，所以我的问题很简单；
MV中的完全刷新和快速刷新有什么区别？P.S:If我的主表有100万行或更多行，我应该选择哪一个？
浏览 1提问于2017-01-04得票数 4
回答已采纳
2回答
我试图用akka-streams的Tcp客户端向数据库发送一个查询，但我不明白我缺少了什么。
因此，我有两种类型的Query和Response，它们完全可以与akka的ByteString进行转换。因此，假设源是我对查询的请求，我无法找到向查询源提供这个流的最佳方法，而是像Source(Future.successful(query))一样构造它，并将它连接到流source.via(flow)，这给了我另一个在这里，我无法理解如何获得
浏览 2提问于2015-09-16得票数 1
回答已采纳
2回答
如何使用事件源对购物场景建模
、、、、
我正在尝试使用事件源编写一个简单的购物场景：| OrderService |处理器:生成当前状态视图的CQRS处理器。将数据库中的物化视图视为系统对股票的推力源是一种良好的实践吗？
浏览 0提问于2017-07-11得票数 2
回答已采纳
1回答
在使用Selecwith匿名函数或运行时计算的其他值时，我注意到的是，每次访问输出IEnumerable对象时，投影都会重新计算值。IEnumerable<B> listOfBs = someListOfA.Select( x => new B() Id = rand.Next(),});
浏览 0提问于2018-02-22得票数 3
回答已采纳
我正在开发下面的流处理系统，以便从一个源、进程和发送到另一个源获取帧。我正在通过scapa使用akka-streams和akka-http的组合。管道非常短，但我似乎无法定位系统在精确地向端点发出100个请求之后决定停止的位置。}}
在参考之前，我使用的是akka-streams版本2.5.19和akka-http版本10.1.7。没有抛出错误，在来自于帧的源服务器上没有错误代码，程序以错误代码0退出。我<
浏览 0提问于2019-01-08得票数 3
回答已采纳
2回答
假设我有两个用于某个实体的数据源。用户。LDAP和自定义Sql数据库。现在，在我的应用程序中，我必须显示基于某些“Where”条件从两个数据库中筛选出的用户的页面。：PageSize = 10；rowsDataSource1= 100；rowsDataSource2=100；显示第10页，共20页，其中User.birthdate > 2001
假设我不需要中间的缓存层编辑:当然，我们需要一个中间的层，但不一定是缓存层。
浏览 1提问于2014-02-26得票数 0
2回答
我们正在讨论数据安全，出现了一个我需要确认的问题。这是一种情况：简单地说..。这包括三个部分: 1)源服务器上的数据；2)数据在网络上的传输；3)客户端服务器上的数据。
有人能解释聚合发生在哪里吗？传送<
浏览 1提问于2017-10-11得票数 0
回答已采纳
我是ClickHouse的新手，对MV有问题。我有一个记录表，它是数据源。我在这里插入所有的数据。然后使用adv_general_report物化视图创建另一个名为mv_adv_general_report的表。记录表数据。奇怪的是，在将数据插入记录表之后，印象之和将完美地添加到adv_general_report和mv_adv_general_report物化视图中，但是视图和单击总是显示为零。显示大量的视图
SE
浏览 0提问于2021-08-30得票数 -1
回答已采纳
2回答
我正在使用水晶报表2008，我想在一个报表中使用多个数据源。一个是连接informix，另一个是连接redbrick数据源。两者都是独立的数据源，没有任何共同的价值来联合-relate它们。我们能有这样的选择吗？请给我一个建议？
浏览 1提问于2009-09-22得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
