Platform For AI:SQL スクリプト

パラメーター

変数リファレンス

各入力ポートは固定変数名にマッピングされます。アップストリームコンポーネントから接続を描画してポートを選択し、対応する変数を使用して入力テーブルを参照します。元のテーブル名を使用する必要はありません。

出力テーブルの作成

このコンポーネントは、出力テーブルを作成するための2つのモードを提供します。

シナリオ

以下の表を使用して、ユースケースに一致するシナリオを特定し、対応する例に従ってください。

シナリオ 1: 単一のアップストリームテーブルから読み取る

[システムが CREATE TABLE 文を追加するかどうか] を選択し、スクリプトの末尾に SELECT 文を記述します。 PAI は、pai_temp というプレフィックスが付いた一時テーブルを出力として作成します。

select age,
(case sex when 'male' then 1 else 0 end) as sex,
(case cp when 'angina' then 0  when 'notang' then 1 else 2 end) as cp,
trestbps,
chol,
(case fbs when 'true' then 1 else 0 end) as fbs,
(case restecg when 'norm' then 0  when 'abn' then 1 else 2 end) as restecg,
thalach,
(case exang when 'true' then 1 else 0 end) as exang,
oldpeak,
(case slop when 'up' then 0  when 'flat' then 1 else 2 end) as slop,
ca,
(case thal when 'norm' then 0  when 'fix' then 1 else 2 end) as thal,
(case status  when 'sick' then 1 else 0 end) as ifHealth
from  ${t1};

シナリオ 2: 複数のアップストリームテーブルを結合する

出力テーブルを手動で作成するには、${o1} と ${lifecycle} を使用します。

create table if not exists ${o1} lifecycle ${lifecycle}
as
with
    a as (select * from ${t1}),
    b as (select * from ${t2}),
    c as (select * from ${t3})
select * from a
    UNION all
select * from b
    UNION all
select * from c;

シナリオ 3: 名前付きソーステーブルから直接読み取る

アップストリームコンポーネントがない場合、ソーステーブルを名前で参照します。出力テーブルを手動で作成するには、${o1} と ${lifecycle} を使用します。上部の SET 文は MaxCompute 環境変数を構成します。

set odps.sql.mapper.split.size=128;
set odps.sql.executionengine.batch.rowcount=100;

drop table if exists test_a_5_1;
create table test_a_5_1
as
select * from pai_online_project.wumai_data;

drop table if exists test_a_5_2;
create table test_a_5_2
as
select * from pai_online_project.wumai_data;

create table if not exists ${o1}
LIFECYCLE ${lifecycle}
as
select a.pm2, a.pm10, a.so2, b.co, b.no2
from
test_a_5_1 a join test_a_5_2 b
on a.time = b.time
and a.hour = b.hour;

select * from ${o1};

シナリオ 4: スクリプト内で PAI コマンドを実行する

出力テーブルを手動で作成するには、${o1} と ${lifecycle} を使用します。

drop table if exists ${o1};
PAI -name type_transform_v1 -project algo_public
-Dlifecycle=${lifecycle} -DoutputTable=${o1}
-Dcols_to_double="time,hour,pm2,pm10,so2,co,no2"
-Ddefault_double_value="0.0" -Ddefault_int_value="0"
-DreserveOldFeat="false" -DinputTable="pai_online_project.wumai_data";