1回答
是否可以在akkastreams中提取子流密钥？
scala、akka、akka-stream
我似乎找不到这方面的任何文档，但我知道AkkaStreams存储用于在内存中调用groupBy时将流分组为子流的键。是否有可能从子流中提取这些密钥？假设我从我的主流创建了一组子流，通过一个折叠来计算每个子流中的对象，然后将计数存储在一个类中。我能不能让子流的键也传递给那个类呢？还是有更好的方法来做这件事？我需要计算每个子流中的每个元素，但也需要存储计数属于哪个组。
浏览 0提问于2020-11-16得票数 2
回答已采纳
1回答
从本地计算机读取文件并使用google数据流写入BigQuery或google存储。
google-bigquery、google-cloud-storage、google-cloud-dataflow
是否有方法从本地计算机读取csv文件并使用google数据流将其写入大查询或存储？如果它存在，应该使用哪个跑步者？
所有google数据流示例要么从云中读取，要么写入云存储或大查询。我使用DirectPipelineRunner从本地计算机读取和写入本地计算机。
浏览 3提问于2016-08-04得票数 1
回答已采纳
1回答
如何在Apache正确初始化任务状态？
java、initialization、apache-flink
我需要根据金融交易来计算许多不同的总和。我使用Kafka作为流数据源。例如，在平均事务量计算中，我使用MapState存储每张卡的总事务数和总金额。聚集数据存储在Accumulo中。在计算开始之前，是否有方法将初始数据加载到Flink中？是否可以使用两个连接的流与Accumulo的数据一起使用最新的计算聚合和事务流？事务流是无限的，由聚合流不是。我该往哪条路挖？如果这里没有卡的数据-代码调用存储服务
浏览 5提问于2017-08-18得票数 1
1回答
BigQuery流插入是如何计费的？
google-bigquery
当使用流插入将数据加载到BigQuery时，数据大小是由JSON大小计算还是由BigQuery存储中的数据大小计算？
我这样问是因为JSON可能比里面的实际数据大3倍。
浏览 1提问于2017-12-11得票数 1
回答已采纳
3回答
Java8 8的流到底是什么？
java、java-8、java-stream
我读过Java 8 In Action，因此我知道什么是流以及如何使用它。但从计算机科学的角度来看，所有的数据都需要存储在一种数据结构中。所以,
谢谢!
浏览 2提问于2015-04-08得票数 8
回答已采纳
2回答
Apache本地存储- OrientDB / Neo4J图而不是KV存储
neo4j、apache-kafka、orientdb、stream-processing、apache-samza
Apache使用RocksDB作为本地存储的存储引擎。这允许有状态流处理和。
是否可以使用非KV存储作为Samza的本地存储？有人用OrientDB / Neo4J做过这样的事吗?有人知道
浏览 5提问于2015-08-13得票数 3
回答已采纳
1回答
AVX2流存储不会提高性能
vectorization、avx2
我已经确定，绝大部分执行时间都被内存负载和存储所占用。然而，这一变化对业绩的影响很小，甚至没有积极影响(我预期业绩会有大幅度的提高)。
浏览 1提问于2018-03-05得票数 1
1回答
Kappa体系结构:当插入到批/分析服务层时
apache-spark、architecture、streaming、apache-flink、lambda-architecture
Kappa不需要批处理层，而是速度层必须保证历史数据重计算的计算精度和足够的吞吐量(更多的并行性/资源)。什么时候(由于Kappa架构)我必须插入数据到批处理服务层？如果流层不间断地向批处理和流服务层插入数据，那么延迟数据到达又如何呢？还是流层应该定期备
浏览 7提问于2019-10-15得票数 7
回答已采纳
1回答
使用Akka HTTP实现Scala窗口数据
java、scala、akka、drools、akka-http
我使用Akka HTTP在post请求中发送数据，并将其累积到一个列表中。我需要对这些数据执行一些规则，这些规则将对批处理进行聚合。要创建批处理，我需要在固定的时间内对数据进行窗口化 data = List(
Map("a" -> 1.0, "b" -> 267.0, "c" -> 26.0, "d" -> 2.0,"time" -> 12345678293), Map("a" -> 1.0, "b" ->
浏览 2提问于2018-12-17得票数 0
5回答
Java 8流与集合存储
java、memory、collections、java-8、java-stream
我一直在阅读Java 8流以及数据从数据源中的流方式，而不是从数据源中提取数据的整个集合。
如果我只是用
浏览 10提问于2015-04-22得票数 18
回答已采纳
1回答
数据流作业无法写入不同区域中的BigQuery数据集，即使区域设置为bigquery区域
google-cloud-platform、google-cloud-dataflow、apache-beam
我们正在编写一个数据流作业，将数据从存储桶中的JSON写入到BigQuery数据集。存储桶和BigQuery数据集都位于区域X中。但是，在区域X中无法使用数据流端点。最近的区域是Y。因此，所有的计算实例都是在区域X中旋转的。但是，数据流作业仍然失败，错误如下：
临时位置和临时位置存储桶都被设置为区域x。我们正在创建数据流模板并运行它(DataflowRunner)。模板也位于区域X中。
浏览 4提问于2020-03-05得票数 0
2回答
Mercurial/TortoiseHg返回"abort: destination不支持推送“
mercurial、push、tortoisehg、abort
我希望将存储库从我的计算机推送到远程站点上的存储库，以便同步文件。abort: destination不支持推流“英文是什么意思？什么不支持推流？什么是“目的地”？是存储库中的配置文件中的设置导致目标不支持推送吗？是服务器的设置方式吗？27967022的回应之一是“您的目的地不支持推流，或者推流被禁用了”，那么如何启用推流呢？
浏览 0提问于2015-02-14得票数 0
1回答
在C++中存储数据并在执行后从内存中访问和更新数据
c++、data-persistence
我想将一些计算历史存储在内存中，并在调用程序时使用新的计算更新它。我不能使用静态存储类，因为在执行之后，内存会丢失。
任何指点都会有帮助。流是正确的方法吗？
浏览 2提问于2015-12-15得票数 0
回答已采纳
1回答
在C#中不使用流的StorageFile方法
c#、visual-studio、file、stream、uwp
据我所知，必须打开一个流，以允许您的应用程序与文件系统交互。但是某些类，比如StorageFile，有一些方法不能打开流，同时仍然可以操作存储在计算机上的文件，比如CopyAsync和MoveAsync。这怎麽可能？
浏览 10提问于2017-06-30得票数 0
回答已采纳
1回答
是否有一种有效的解决方案来每小时从DynamoDB访问时间序列数据？
amazon-web-services、aws-lambda、amazon-dynamodb
我将来自不同设备的传感器数据(功率和电压测量)存储在DynamoDB中(分区键: deviceid和排序键:时间戳)。每小时，我都要访问在这个时间框架内存储的数据，用它进行一些计算，并将结果存储在其他地方。我最初的想法是运行由CloudWatch规则触发的Lambda，进行计算并将结果存储在另一个DynamoDB表中。我看到了一个类似的问题，答案建议使用DynamoDB流。但是，不应该在每次更新/删除/插入项目时触发流吗？我知道有条
浏览 10提问于2022-07-21得票数 0
1回答
Windows从睡眠返回后的InstanceOwnerException
windows、workflow-foundation、workflow-foundation-4
我有一个长时间运行的工作流，这是一个长时间运行的应用程序使用的。
我使用SqlWorkflowInstanceStore进行持久化。我设置了DefaultInstanceOwner，以便在另一个应用程序启动时重新加载工作流。
浏览 1提问于2011-12-06得票数 2
回答已采纳
1回答
Apache : SummaryStatistics的值存储在哪里？
java、apache-commons-math
我需要用这门课：然而，我对这种描述感到困惑：
如果这些值没有存储在内存中，那么它们存储在哪里？在磁盘上？如果在磁盘上，那么文件名呢？有人能解释一下这件事吗？
浏览 4提问于2017-12-21得票数 1
回答已采纳
2回答
Prefect:在Prefect中可以使用多台机器访问像NAS这样的存储吗？
deployment、server、orchestration、prefect
port/graphql"
apollo_url = "http://server_ip:port/graphql"
现在，我可以在每台机器上创建一个本地代理，注册流并在各自的机器上运行它们现在我想要一台中央计算机，在那里我可以开发和注册我的流。不幸的是，当我在机器B上运行一个流，并在机器A上注册时，我会得到一条"Module“错误消息。我已经读到，错误来自于只查找本地存储中的流<
浏览 8提问于2022-07-05得票数 0
回答已采纳
1回答
是否有任何数据类型可以在sql server中存储大于2gb的数据？
sql、database、functional-programming
我需要在一列中存储超过2G的数据。我有办法做得到吗？我需要存储的数据在数据库中，而不是在计算机中，这会导致使用文件流的概念。
浏览 6提问于2015-03-16得票数 3
回答已采纳
1回答
Flink SQL中的控件流
apache-flink、flink-streaming、flink-sql
使用stream，我可以编写接受控制流和数据流的RichCoFlatMapFunction，控制流包含开始、停止或更改计算参数的元素，我知道我可以将当前的控件设置存储在状态中，并在处理数据流时检查值。我不能使用连接作为数据流和控制流不能连接在一起。
将控制流广播到映射操作符，并将控制设置存储到其map()方法中的java单例对象
浏览 1提问于2018-03-23得票数 1
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号