wso2 - WSO2DAS 中的分析

Question

在 wso2das 的 spark 控制台上运行选择查询时出现 Table Not Found 错误。安装后我保持所有默认配置不变。即使它显示在数据资源管理器的表格下拉列表下，我也无法从事件流中获取数据。

Answer 1

最初，当数据移入 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 中的数据。

学习愉快！！:)