首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >WSO2DAS中的分析

WSO2DAS中的分析
EN

Stack Overflow用户
提问于 2016-02-03 17:14:35
回答 1查看 153关注 0票数 0

在wso2das的spark console上运行select查询时,我得到一个找不到表的错误。安装完成后,我保留了所有的默认配置。我无法从事件流中获取数据,即使它显示在数据资源管理器的表下拉列表中。

EN

回答 1

Stack Overflow用户

发布于 2016-05-19 16:40:25

最初,当数据移动到wso2das中时,它将持久化在您提到的数据存储中。

但是,这些表不是在spark中创建的。您需要编写一个spark查询来在spark中创建一个临时表,该临时表将引用您已持久化的表。

例如,

如果你的流是,

代码语言:javascript
复制
{
  "name": "sample",
  "version": "1.0.0",
  "nickName": "",
  "description": "",
  "payloadData": [
    {
      "name": "ID",
      "type": "INT"
    },
    {
      "name": "NAME",
      "type": "STRING"
    }
  ]
}

您需要在spark控制台中编写以下spark查询。

代码语言:javascript
复制
CREATE TEMPORARY TABLE sample_temp USING CarbonAnalytics OPTIONS (tableName "sample", schema "ID INT, NAME STRING");

执行上述脚本后,请尝试执行以下操作:

代码语言:javascript
复制
select * from sample_temp;

这应该会获取您推送到WSO2DAS中的数据。

祝您学习愉快!!:)

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/35172763

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档