我正在编写一个从像Kafka这样的无限源读取数据的波束数据管道。我没有执行任何分析函数。我想转换元素并写入接收器，假设在PCollection的记录计数达到某个阈值之后。这是为了限制发送到接收器的数据。 查看了现有的触发器，但无法确定它们是否适合
浏览 15提问于2019-02-12得票数 0
我有两个无界(KafkaIO) PCollections，对其应用基于标签的CoGroupByKey，具有1分钟的固定窗口，然而，在加入大多数时间时，对于具有相同关键字的一些测试数据，集合似乎遗漏了其中一个标记数据KafkaIO.Read<Integer, String> event1 = ... ;
PCollection<KV<String,String>>int
浏览 2提问于2017-10-07得票数 0
2回答
我正在尝试实现从java到python的slowly updating global window side inputs示例，并且我还停留在python中AfterProcessingTime.pastFirstElementInPane()等效的内容上。为了方便起见，我从下面的文档中粘贴了java示例： // This pipeline uses View.asSingleton，我已经在这个问题上花了好几天<em
浏览 3提问于2020-09-09得票数 1
1回答
我正在尝试理解apache是如何工作的，我不太确定我是否这样做了。所以，我希望有人告诉我我的理解是否正确：
Beam是大数据框架的抽象层，如spark、hadoop、google等。现在几乎所有的功能都是这样的，但几乎就是Beam以两种形式处理数据的情况--有界和无界。像.csv一样有界，像卡夫卡的订阅一样无界。不同的i/o读取方法是不同的。对于无界数据，我们需要实现窗口(将时间戳附加到每个数据点)和<em
浏览 5提问于2020-04-12得票数 2
我最近读了很多文章，包括官方文档，试图了解全球窗口是如何在Apache中工作的。我在这里读过类似的问题，但我无法理解。文档建议在进行聚合时使用非默认触发器，因为默认触发器是在窗口关闭时触发窗格：
设置非默认触发器。这允许全局窗口在其他条件下发出结果，因为默认的窗口行为(等待所有数据到达)永远不会发生。这里的逻辑是，全局窗口无法将事件触发到管道的下一步，因为它永远不会结束，因此默认的</em
浏览 5提问于2021-05-14得票数 3
我需要将来自Corda的一些信息(如LinearId、Transaction等)存储在一个非分类帐数据库(，而不是节点数据库中的一个额外表)中，以便随后的外部处理和下游操作。关键是代码必须在特定的流(而不是所有流)完成后运行，并且只在事务的一端/节点上运行。节点触发器可以直接写入外部数据库，或者触发器可以将数据写入JMS队列以供外部引擎获取和处理
如何在
浏览 3提问于2021-03-01得票数 1
我在sql server上工作，我想在其中插入特定表中的记录，例如(a)，此表包含两个列id (标识字段)和名称(nvarchar(Max)现在在表(A)中插入记录后，触发器将触发并在表b中插入标识字段值...为此，我使用了after insert触发器，但我不知道如何在触发器中获取标识字段值……应将其插入到表b中。这就是我正在使用的</
浏览 0提问于2011-01-28得票数 5
回答已采纳
},
{ "trigger_identity": "*******",
这是我的集合中的一个文档，其中我为每个具有唯一ID的用户提供了一个文档，现在我要做的是计算使用特定触发器的用户数量，用户可能多次使用相同的
浏览 1提问于2018-04-10得票数 1
回答已采纳
| Int | | Name | NVARCHAR(50)|更新Table1集ID1 = ID1 + 1
如何在更新时创建触发器，使更新后的行计数超过1？
浏览 0提问于2012-07-01得票数 -4
我有一个大容量触发器，它使用映射，以避免遇到SOQL调控器限制。此触发器还使用静态类变量进行递归和限制查询。我要做的是，当对对象启动大量操作(如insert或update )时，本例中的Contact对象，则触发器将在第一个触发器上构建相关帐户的映射，并将这些映射用于触发器的其余部分。下面是一个运行良好的操作示例，但仅适用于更新后和插入触发器操作
浏览 0提问于2011-11-03得票数 0
回答已采纳
我想为创建主键创建我的自定义计数器。我在PL/SQL中确实做到了这一点。select 'CM' || lpad(company_seg.nextval,5,0) from dual;这段代码创建了一个触发器，该触发器为company_table创建自定义主键。company_seg是我的定制柜台。每当我插入一行时，它都会创建一个主键，如: it 00001，如何
浏览 1提问于2017-11-29得票数 0
回答已采纳
我不得不重新安装我的超级reinstall服务器，所以我对我的PostgreSQL数据库进行了模式备份。上面的函数应该更新修改过的列的时间戳，但是没有发生任何事情。我的两个触发器函数都用来在旧的虚拟机上工作。postgres用户对所讨论的表拥有所有权限
浏览 0提问于2015-11-16得票数 1
回答已采纳
我正在使用struts2，我希望我的应用程序在MSSQL2008 r2 database.Can中的特定表的值发生变化时得到通知，有人解释吗？
浏览 0提问于2014-09-22得票数 0
1回答
我需要一个计数器变量，该变量在每次调用C# web服务函数时都需要增加。我不能使用会话，因为我还不知道是否所有的请求每次都来自相同的源。计数器将在x次后重置，它从源接收的详细信息与详细信息一起存储在数据库中。计数器的想法是让记录被“反”处理器拾取。我唯一能想到的另一种方法是让一个windows服务来分配请求，但又想减少需要处理的应用程序和代码的数量。或者，sql server触发器
浏览 0提问于2012-12-13得票数 0
1回答
我正在编写一个Dataflow (BeamSDK2.0.0)，它从Pub/Sub读取，对窗口中的元素进行计数，然后将计数存储在BigTable中作为一个timeseries。窗户固定在1分钟的时间内。但这似乎行不通。所以基本上只有我的最后一个值是正确的，其余的都是零。Pipeline pipeline = P
浏览 4提问于2017-06-15得票数 1
回答已采纳
阅读此帖子后：SELECT T.created_at, ORDER BY T.id_str;
老问题解决了，新问题解决了:如何编写触发器我的桌子是这样的。其中id_str是特定</
浏览 0提问于2017-09-06得票数 0
3回答
我认为这是SSDT的一个bug，也是一个很老的错误。我尝试过几个版本的SSDT二进制文件，但问题仍然存在。SQLPackage.exe并不正确地排除触发器，特别是如果它是加密的。情况：
浏览 4提问于2017-11-24得票数 2
我正在检查如何将分区添加到表中，该表当时用于插入。
现在，我关心的是如何在记录插入发生时向父分区添加新分区。
我更新了触发器</
浏览 1提问于2014-07-03得票数 0
回答已采纳
如果我在DockerHub上设置了自动构建，例如，基于ubuntu:yy_mm映像，在它的Dockerfile中，我通过apt-get安装了一些包foo-bar-ng，当Ubuntu存储库中的软件包更新时，如何设置要自动重建的映像？。
浏览 6提问于2016-07-02得票数 0
我使用TextIO从云存储中读取数据。由于我想让工作连续运行，所以我使用watchForNewFiles。PCollection是无界的，包含这些文件中的文本行。在改组中的一步，即GroupByKey。lines = lines.apply(Window.configure()
.10秒后释放一个窗口。.withAllowedLateness(Duration.standardSeco
浏览 0提问于2018-11-12得票数 6
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
