腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(5043)
视频
沙龙
2
回答
Apache
获取kafka数据执行SQL错误:在
没有
模式
时
不能
调用
getSchema
、
、
我将向kafka输入多个表的数据,
beam
将在获得数据后执行SQL,但现在有以下错误:org.
apache
.
beam
.sdk.values.PCollection.
getSchema
(BeamPCollectionTable.java:34) at org.
apache
.
beam
.sdk.extensions.sql.
SqlTransform
.toTableMap(
SqlTransform
.java:141) a
浏览 10
提问于2019-11-22
得票数 0
回答已采纳
3
回答
Apache
Beam
SQLTransform
:
没有
架构
时
无法
调用
getSchema
、
在这里,CustomSource转换在runtime.Hence生成一个Pojo,运行
SQLTransform
的对象的类型在编译
时
是未知的。at org.
apache
.
beam
.sdk.values.PCollection.
getSchema
(PCollection.java:328) atorg.
apache
.
beam
.sdk.extensions.sql.impl.schema.BeamPCollectionTabl
浏览 46
提问于2019-07-04
得票数 0
1
回答
Apache
模式问题
、
、
、
在使用SqlTransforms通过遵循文档执行转换
时
,我遇到了以下问题。你能帮忙吗?java.lang.IllegalStateException: Cannot call
getSchema
when there is no schema at org.
apache
.
beam
浏览 0
提问于2018-10-25
得票数 0
1
回答
Beam
SQL - SqlValidatorException:找不到对象'PCOLLECTION‘
、
我从转换SampleSource中获得一个PCollection<Row>,并将其输出传递给一个
SqlTransform
。String sql1 = "select c1, c2, c3 from PCOLLECTION where c1 > 1";p.run().waitUntilFinish();但是,当我尝试以下几行代码
浏览 7
提问于2019-07-02
得票数 0
1
回答
用Python中的
SqlTransform
本地测试
Apache
。我收到一个错误:“‘[%s]的执行
没有
在runner %s中实现。’”
、
、
、
、
在本地
Apache
实例上使用
SqlTransform
时
,我会收到一个错误。x[3], # float pc |
SqlTransform
(" SELECT * FROM PCOLLECTION WHERE quantity > 1") RuntimeError追尾(最近一次
调用
),在1
浏览 9
提问于2021-01-26
得票数 0
1
回答
如何获取
Apache
Beam
SQL查询的输出模式?
、
、
我一直在使用and DSL,如果不提供一个能够手动识别输出模式的编码器,我就
无法
使用查询的输出。我可以推断输出模式而不是硬编码它吗?Serialization trace:schema (org.
apache
.
beam
.sdk.val
浏览 1
提问于2018-09-05
得票数 1
回答已采纳
1
回答
BigQueryIO.Write系列化withJsonSchema
、
、
我的波束管道中有一个BigQueryIO.Write阶段,它是通过
调用
.withJsonSchema(String)来构造的。(BigQueryHelpers.java:156) org.
apache
.
beam
.sdk.io.gcp.bigquery.DynamicDestinationsHelpers$ConstantSchemaDestinations.
getSchema
$ConstantSchemaDestinations.
getSchema
(DynamicDestinationsH
浏览 7
提问于2017-10-19
得票数 5
回答已采纳
1
回答
数据流/波束累加器编码器
、
、
、
、
我正在开发一个Dataflow管道,它使用
SqlTransform
库以及org.
apache
.
beam
.sdk.extensions.sql.impl.transform.agg.CountIf中定义的束聚集函数这里是一张代码幻灯片:import org.
apache
.
beam
.sdk.extensions.sql.impl.transfo
浏览 7
提问于2021-10-26
得票数 0
回答已采纳
2
回答
FluentNHibernate配置,NotSupportedException at DBConnection.
GetSchema
()
、
、
、
尝试配置BuildSessionFactory().上的SQL Ce数据库,并获得以下异常有什么建议吗?fluentConfiguration.BuildSessionFactory() virtual public DataTable
GetSchema
System.Data.Common.DbConnection.
GetSchema
(String Source=System.Data
浏览 3
提问于2011-12-09
得票数 2
回答已采纳
1
回答
如何将query窗口查询与KafkaIO集成?
、
、
、
;import org.
apache
.
beam
.sdk.io.kafka.KafkaIO;import org.
apache
.
beam
.sdk.options.PipelineOptionsFactory; impor
浏览 23
提问于2020-08-25
得票数 0
2
回答
TextIO.read().watchForNewFiles()防止写入BigQuery
、
())) .to(tableRef)有什么想法吗?
浏览 0
提问于2018-03-19
得票数 1
回答已采纳
1
回答
运行多个连接
时
,
Beam
SQL /
Apache
Beam
速度较慢
、
、
、
当使用
Beam
对两个表进行连接
时
,它正常工作,提供了预期的性能,但是随着我的连接表的增加,性能就变得最差了。 .and(new TupleTag<>("principle"), principle).apply(
SqlTransform
.queryd.corporation1 LEFT JO
浏览 2
提问于2018-08-14
得票数 0
回答已采纳
1
回答
在TableRow
Apache
梁中访问BigQuery列
、
、
4.所有表的
架构
保持不变。但是我
无法
访问JSON消息中的"campaign_id“和"user_id”字段。因此,我的事件
没有
路由到正确的表。;import org.
apache
.
beam
.sdk.io.gcp.bigquery.BigQueryIO; imp
浏览 0
提问于2018-04-17
得票数 0
回答已采纳
2
回答
如何在jspInit()方法中获取模式(http/https)?
、
我在我的应用程序中使用jsp文件,它包含jspInit()方法来初始化一些资源。我尝试在jsp文件的init方法中获取协议( http/https /ftp),以启用具有http/https连接的应用程序url。<%!public void jspInit() { ServletContext servletContext = getServletConfig().getServletContext(); //
浏览 0
提问于2017-09-22
得票数 2
1
回答
在Google App Engine Flex上运行
Apache
Beam
时
,“‘module”对象
没有
属性“WriteToBigQuery”
、
、
、
、
这条管道应该将最终的PCollection写入谷歌BigQuery,但我找不到一种方法来安装正确的
apache
_
beam
.io依赖项。 write_disposition=
beam
.io.BigQueryDisposition.WRITE_APPEND当我在本地运行这段代码
时
,
beam
.io.WriteToBigQuery()被正确
调用
。它是从我的虚拟环境
浏览 6
提问于2018-02-09
得票数 3
1
回答
Apache
:将具有对象列表的对象转换为多个TableRows以写入BigQuery
、
、
、
message.getEventItemMap().get("key2")); } 但是,这也是我
无法
应用message.getEventItemMap().get("key1")); } 现在,当我试图将这个集合写到BigQuery
时
,rows.apply(BigQueryIO.writeTableRows().to(ge
浏览 3
提问于2017-10-26
得票数 3
回答已采纳
1
回答
如何在
调用
某些方法
时
使用getattr或getattribute正确引发ImportError
、
、
、
disable=too-few-public-methods Pipeline = Empty raise ImportError(err_msg) import
apache
_
beam
浏览 5
提问于2020-04-27
得票数 0
2
回答
DataflowRunner不工作
、
、
) at org.
apache
.
beam
.sdk.util.InstanceBuilder.build:162) at org.
浏览 1
提问于2018-01-30
得票数 0
回答已采纳
1
回答
如何在运行时从连接池声明中获取用户名
、
、
我在javax.sql.DataSource类中
没有
看到任何这样的方法。当我试图从连接中获取模式
时
,请使用conn.
getSchema
();java.lang.AbstractMethodError: org.
apache
.tomcat.dbcp.dbcp.PoolingDataSource$PoolGuardConnectionWrapper.
getSchema
()
浏览 2
提问于2015-03-25
得票数 0
回答已采纳
2
回答
不使用Python类方法吗?
、
、
、
查看下面的代码块,我
没有
看到expand方法曾经被下游
调用
过。class ReadWordsFromText(
beam
.PTransform): def __init__(self, file_pattern): words = p | 'read' >> ReadWordsFromText('gs://
apach
浏览 0
提问于2021-02-12
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Java近期新闻: JReleaser 1.2、Spring Batch、PrimeFaces、Quarkus、JobRunr与Apache Beam
Kafka落选!InfoWorld最佳开源数据平台奖公布
想成为大数据开发工程师,你必须掌握的开发流程图是这样的
ChatGPT 的局限性:可信度、时效性、成本和专业性
雪球基于Apache APISIX的双活架构演进
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券