0

wso2das の spark コンソールで選択クエリを実行しているときに、Table Not Found エラーが発生します。インストール後、すべてのデフォルト構成をそのまま保持しました。データ エクスプローラーのテーブル ドロップダウンに表示されている場合でも、イベント ストリームからデータを取得できません。

4

1 に答える 1

0

最初にデータがwso2dasに移動されると、言及したデータストアに永続化されます。

ただし、これらは 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 にプッシュしたデータが取得されます。

ハッピーラーニング!! :)

于 2016-05-19T08:40:25.233 に答える