腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(531)
视频
沙龙
1
回答
有没有
可能在
不
中断
的
情况下
使用
pub
/
sub
输入
修改
apache
波束
流
?
、
、
1)我写了一个管道,它有一个作为
输入
的
发布/订阅
流
。我想用--update或--jobName选项
修改
它。发布/订阅和整个管道中
的
数据发生了什么?
有没有
可能以某种简单
的
方式将此数据重放到重新启动
的
管道中,以便在
流
模式中像以前一样处理所有内容。我听说你可以重放7天
的
pub
/
sub
。
浏览 7
提问于2019-06-20
得票数 0
回答已采纳
1
回答
Apache
beam将数据
流
pub
/
sub
解析为字典
、
、
、
我正在运行一个
使用
波束
/数据
流
的
流管道。我正在读取来自
pub
/
sub
的
输入
,将其转换为字典,如下所示: | 'ReadPubsubLoads' >> ReadFromPubSub(with_output_types(bytes) | 'JSONParse' >> beam.Map(lambda x
浏览 17
提问于2019-07-14
得票数 0
1
回答
新
的
PTransform是否需要实现或指定TransformTranslator?
、
、
我尝试编写一个封装在PTransform中
的
自定义
波束
源。(PTransformTranslation.java:191) at org.
apache
.beam.runners.direct.RootProviderRegistry.getInitialInputs我看到了这个异常
的
几个答案,表明maven shading存在问题。然而,我不
使用
也
不
希望构建一个超/胖jar,在构建我
的
数据
流
模板时,我可以获取依赖项。
有没有
人
浏览 14
提问于2020-11-30
得票数 0
1
回答
从Google PubSub主题
流
数据到Google BigQuery
、
、
、
我想读取Google PubSub主题上
的
传入数据,处理数据并将其转换为统一
的
数据结构,然后将其插入到Google BigQuery中
的
数据集中。据我所知,可以
使用
某种
流
数据
的
管道。然而,我很难找到任何好
的
和简洁
的
例子来实现这一点。谢谢!
浏览 2
提问于2018-05-03
得票数 0
回答已采纳
2
回答
谷歌云公开订阅真的可以自动删除吗?
从医生那里: 需要建议。
浏览 1
提问于2017-07-04
得票数 3
回答已采纳
1
回答
Apache
不能写入AWS S3
、
、
、
我们目前正在开发
Apache
管道,用于从GCP
Pub
/
Sub
读取数据,并将接收到
的
数据写入AWS S3中
的
存储桶中。(管道接收来自
Pub
/
Sub
的
数据并将其写入S3。options.setStagingLocation(".s3://my-s3-bucket/temp") options.setOu
浏览 6
提问于2020-02-28
得票数 1
2
回答
Tensorflow:如何应用一维卷积功能/通道老虎钳?
、
、
我想处理具有时间点形状
的
多变量时间序列,#特征
有没有
可能在
不
拆分# feature those中
的
输入
并对这些
输入
应用卷积
的
情
浏览 40
提问于2020-11-16
得票数 1
回答已采纳
2
回答
WriteToText只写临时文件
、
、
我是
Apache
的
新手,我试图用Python编写我
的
第一个管道,以便将Google
Pub
/
Sub
订阅中
的
数据输出到平面文件,以便以后
使用
;理想
情况下
,我希望每隔半小时将这些数据分批到一个文件中。,该进程将无限期地运行,并成功地从订阅中读取消息;然而,它只将它们写入
波束
临时文件。更新:class AddKeyToDict(beam.DoFn):
浏览 0
提问于2019-07-09
得票数 1
回答已采纳
1
回答
默认(未指定
的
)触发器如何确定结构化
流
中微批
的
大小?
、
当Spark结构化
流
中
的
查询执行
不
设置触发器时, 比方说。
输入
源是卡夫卡。由于一些故障,这项工作
中断<
浏览 0
提问于2019-08-22
得票数 3
回答已采纳
4
回答
Google :
使用
DirectPipelineRunner (本地作业)在管道中访问Google /
Sub
?
、
我已经用编写了一个流管道,但是我想在本地测试我
的
管道。我
的
管道从Google /
Sub
获取
输入
数据。是否可以
使用
pubsubIO(本地执行,而不是Google )运行访问
Pub
/
Sub
(pubsubIO)
的
作业? 作为普通用户帐户登录时,我会遇到权限问题。我是项目的所有者,我试图访问
的
是酒吧/子主题。
浏览 6
提问于2015-04-07
得票数 3
回答已采纳
2
回答
如何在YouTube上检索活动事件
的
开始时间?
、
我试图回到过去,用真实世界
的
时间戳同步已完成或正在进行
的
实时事件(例如,twitter逐个播放)。我
不
拥有现场直播节目。显然,这仅适用于可以重绕或重播
的
事件(例如许多与游戏有关
的
广播)。我试过以下几种方法: 如果当前播放
的
视频是一个活动事件,则getDuration()函数将返回自实时视频
流
开始以来经过
的
时间。具体而言,这是视频在没有被重置或
中断
的
<
浏览 3
提问于2013-08-05
得票数 3
1
回答
需要帮助设置彗星代码
、
、
、
、
Nginx http推模块配置 default_type应用程序/八进制
流
;发送文件on;keepalive_timeout 65;push_authorized_channels_only off
的
任何调用,并且它将返回发送到/port/
pub
的
任何响应。我
的
想法是让/broadcast/
pub
__.广播公司( node.js )我认为这将使我可以在不
中断
连接
的
情况下
将从服务器
浏览 2
提问于2010-04-03
得票数 3
回答已采纳
1
回答
Rails 4应用程序中
的
Sendgrid和用户订阅逻辑
、
我遇到了这个,我似乎可以避免
使用
延迟作业创业板,这将是首选
的
。 当属性(或属性)发生
中断
时,将创建票证。我目前有大约15个测试用户,每次
修改
票证时,似乎都会发送15个单独
的
请求:这在浏览器中非常慢(也就是说,票证修饰符
可能在
单击create/update/close按钮后等待10+秒),但是是可以承受
的
。随着越来越多
的
用户订阅,这种缓慢将是不可容忍
的
浏览 2
提问于2016-04-01
得票数 0
回答已采纳
1
回答
_GNU_、_attribute_、语用扩展和指令
的
含义是什么?
以下代码
的
含义是什么?_((_naked_)) #pragma shadow_registers = full这部分代码放在
中断
处理程序之前
浏览 4
提问于2014-08-30
得票数 1
回答已采纳
1
回答
Apache
/Google to BigQuery管道:处理插入错误和意外重试行为
、
、
、
我从上取下了
的
一份副本。我正在
使用
在本地机器上运行它。 我
的
印象是,默认
情况下</em
浏览 0
提问于2018-08-27
得票数 5
回答已采纳
1
回答
Grails:添加编译
的
构建任务
、
、
、
我
使用
的
是grails 2.4.4。我
的
一些类有注解,APT (注解处理工具)必须在编译期间处理这些注解,以生成一些源代码。通过运行grails generate-pom,我能够
使用
创建maven pom.xml
的
变通方法完成所有工作,并从那里添加特定
的
插件并配置它们。
有没有
可能在
不
绕过maven pom.xml
的
情况下
,
使用
内置
的
grails编译器配置Build
浏览 1
提问于2015-05-14
得票数 0
2
回答
Flink从GenericRecord
流
生成动态
流
、
、
、
、
现在,我已经编写了一个
使用
者来阅读该主题并构建一个GenericRecord数据
流
。现在,我不能将此
流
汇到parquet格式
的
hdfs/s3中,因为此
流
包含不同类型
的
模式记录。因此,我通过应用过滤器并创建不同
的
流
,然后分别下沉每个
流
,为每种类型过滤不同
的
记录。下面是我
使用
的
代码- import io.confluent.kafka.schemaregistry.clie
浏览 69
提问于2020-02-21
得票数 1
回答已采纳
1
回答
Excel VBA排序范围,范围底部为空白和空值
、
、
我在Excel中对一个非常大
的
范围进行排序,它由多个列组成,并不是所有列都被填充。在某些列中,有时
输入
空格,有时单元格为Empty。我想要做
的
是将空白和空单元格都移到范围
的
底部。我写了一个,但对于给定
的
范围(将近4000行,需要2+分钟才能完成)来说,它
的
运行速度非常慢。此外,我还发布了我正在
使用
的
排序
sub
。 我已经研究了自定义顺序,但看起来它需要您指定您计划
使用
的
所有值。
有没有
浏览 7
提问于2016-08-13
得票数 2
回答已采纳
6
回答
eclipse要求我在finally块中
使用
try/catch --可以禁用它吗?
、
在我
的
一段Java应用程序代码中,我有一个try-catch-finally块,其中
的
try块创建了一些
输入
流和输出
流
,如果出现错误,我将关闭finally中以前打开
的
所有
流
。= null)} 但是Eclipse中
的
<stream>.close()行在代码中显示了错误"Unhandled exception IOException“,并表明解决方案是在finally块中包含另一个try&
浏览 0
提问于2011-08-03
得票数 4
回答已采纳
3
回答
scanf(),std::cin是如何在多线程环境中运行
的
?
、
、
我想用一个例子来说明我
的
问题。在控制台上操作
的
终端用户看到/体验了什么? 编辑:还有一件事我想补充。下面的代码是否足够安全,足以放弃仅在一个线程(可能是主线程)中
使用
std:cin
的
想法?
浏览 2
提问于2013-09-17
得票数 7
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
C#中的委托和事件-Part.2
Analytics Zoo Cluster Serving自动扩展分布式推理
Alluxio跨集群同步机制的设计与实现
不惧流量持续上涨,BIGO 借助 Flink 与 Pulsar 打造实时消息系统
如何在Python中实现异步执行?
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券