在wso2das的spark console上运行select查询时,我得到一个找不到表的错误。安装完成后,我保留了所有的默认配置。我无法从事件流中获取数据,即使它显示在数据资源管理器的表下拉列表中。
发布于 2016-05-19 16:40:25
最初,当数据移动到wso2das中时,它将持久化在您提到的数据存储中。
但是,这些表不是在spark中创建的。您需要编写一个spark查询来在spark中创建一个临时表,该临时表将引用您已持久化的表。
例如,
如果你的流是,
{
"name": "sample",
"version": "1.0.0",
"nickName": "",
"description": "",
"payloadData": [
{
"name": "ID",
"type": "INT"
},
{
"name": "NAME",
"type": "STRING"
}
]
}您需要在spark控制台中编写以下spark查询。
CREATE TEMPORARY TABLE sample_temp USING CarbonAnalytics OPTIONS (tableName "sample", schema "ID INT, NAME STRING");执行上述脚本后,请尝试执行以下操作:
select * from sample_temp;这应该会获取您推送到WSO2DAS中的数据。
祝您学习愉快!!:)
https://stackoverflow.com/questions/35172763
复制相似问题