プロジェクトパラメータ（スコープ：プロジェクト配下のすべてのワークフロー / タスク）
   ↓
ワークフローパラメータ（スコープ：単一ワークフロー内のすべてのタスク）
   ↓
タスクパラメータ（スコープ：単一タスク）

INSERT OVERWRITE TABLE dw.user_daily PARTITION(dt = '${pt_date}')
SELECT * FROM ods.user_log
WHERE dt = '${pt_date}';

SELECT * FROM demo_bi.user_log
WHERE dt = '${pt_date}';

SELECT * FROM ${pg}.user_log
WHERE dt = '${pt_date}';

pt_date=20260507;qt=100

SELECT * FROM demo_bi.user_log
WHERE dt = '${pt_date}'
  AND user_id = ${qt};

構文クイックリファレンス（3種類の時間パラメータ）：
  ${yyyyMMdd} → インスタンスデータ時間（パーティション値として推奨）
  $(yyyyMMdd) → 計画スケジュール時間（海外タイムゾーンシーンでの使用を推奨）
  $[yyyyMMdd] → インスタンス実行時間（ログ/監査に適用）

オフセットクイックリファレンス：
  ${yyyyMMdd-1d} → 1日前
  ${yyyyMMdd+3M} → 3か月後
  ${yyyyMMdd+2w} → 2週間後
  ${yyyyMMddHHmmss-2H} → 2時間前

特殊オフセットクイックリファレンス：
  ${yyyyMMdd+ME} → 当月月末
  ${yyyyMMdd+MS} → 当月月初
  ${yyyyMMdd+PME} → 前月月末
  ${yyyyMMdd+YE} → 当年年末

タイムゾーンクイックリファレンス：
  ${UTC+0_yyyyMMdd} → UTC+0タイムゾーン
  ${UTC+7_yyyyMMdd} → UTC+7タイムゾーン
  タイムゾーンプレフィックスを付けない場合 → デフォルトはUTC+8です。

コンテキストパラメータ：
  ${projectIdent} → プロジェクト識別子
  ${workflowName} → ワークフロー名
  ${taskName} → タスク名
  ${taskId} → タスクID
  ${taskInCharge} → タスク担当者
  ${taskType} → タスクタイプ

パラメータ構文：
  インスタンスデータ時間：${[UTC+N_]<format>[±N<unit>][+<special>]}
  計画スケジュール時間：$([UTC+N_]<format>[±N<unit>][+<special>])
  インスタンス実行時間：$[[UTC+N_]<format>[±N<unit>][+<special>]]

ここで：
  [UTC+N_] はオプションです。タイムゾーンプレフィックスで、Nは整数です。デフォルトはUTC+8です。
  <format>      yyyy、MM、dd、HH、mm、ssおよびそれらの自由な組み合わせ（区切り文字をサポート）
  [±N<unit>]    オプション、オフセット量
    <unit>      y（年）、M（月）、w（週）、d（日）、H（時間）、m（分）
  [+<special>]  オプション、特殊オフセット識別子
    TE, ME, QE, HYE, YE, TS, MS, HYS, YS, PME, PYE

-- 日次タスクは2026-03-22に実行され、dt='20260321'パーティションに書き込まれます。
INSERT OVERWRITE TABLE dw.user_daily PARTITION(dt = '${yyyyMMdd-1d}')
SELECT * FROM ods.user_log
WHERE dt = '${yyyyMMdd-1d}';

-- 日次タスクは2026-03-22に実行されます。
-- ${yyyy-MM-dd} は '2026-03-22' に解析されます。
SELECT '${yyyy-MM-dd}' AS p_date, user_id, action
FROM ods.user_events
WHERE dt = '${yyyyMMdd}';

-- 毎月1日にタスクを実行し、前月の月間データを集計します。
-- ${yyyyMMdd+PME} → 前月末、${yyyyMMdd+MS} → 当月初
SELECT COUNT(*) AS order_cnt
FROM dw.order_detail
WHERE dt >= '${yyyyMMdd+PME}' AND dt < '${yyyyMMdd+MS}';

-- 海外ビジネスはUTC+0を基準とし、計画スケジュール時間+タイムゾーンプレフィックスを使用します。
SELECT * FROM ods.global_events
WHERE event_date = '$(UTC+0_yyyy-MM-dd)';

SELECT
  '${projectIdent}'  AS project_ident,
  '${workflowName}'  AS workflow_name,
  '${taskName}'      AS task_name,
  '${taskId}'        AS task_id,
  '${taskInCharge}'  AS task_in_charge,
  '${taskType}'      AS task_type,
  user_id
FROM wedata_demo_db.user_info
LIMIT 10;

--name ${projectIdent}-${workflowName}-${taskInCharge}

spark.app.name=${projectIdent}-${workflowName}-${taskInCharge}

INSERT OVERWRITE TABLE dw.user_daily PARTITION(dt = '${pt_date}')
SELECT * FROM ods.user_log
WHERE dt = '${pt_date}'
  AND user_id = ${qt};

#!/bin/bash
# 時間パラメータを使用する
echo "Processing data for date: ${yyyyMMdd}"
hdfs dfs -ls /data/warehouse/dt=${yyyyMMdd-1d}/

# プロジェクト/タスクパラメータを使用する
echo "Business date: ${pt_date}"
echo "Project: ${projectIdent}"

# スケジューリングシステムは実行前にパラメータを実際の値に置換します
pt_date = "${pt_date}"
project = "${projectIdent}"

print(f"Processing data for {project} on {pt_date}")

# ロジックでパラメータを使用する
threshold = ${qt}
if threshold > 50:
    print("High threshold mode")

pt_date = "${yyyyMMdd-1d}"
df = spark.sql(f"SELECT * FROM ods.events WHERE dt = '{pt_date}'")
df.write.mode("overwrite").saveAsTable("dw.events_daily")

project_param = dlcutils.widgets.get("project_param")    # プロジェクトパラメータ
workflow_param = dlcutils.widgets.get("workflow_param")  # ワークフローパラメータ
task_param = dlcutils.widgets.get("task_param")          # タスクパラメータ

pt_date = dlcutils.widgets.get("pt_date")            # "20260506"
project = dlcutils.widgets.get("projectIdent")       # "my_project"
task = dlcutils.widgets.get("taskName")              # "user_sync_task"

# パラメータを使用する
df = spark.sql(f"SELECT * FROM ods.user_log WHERE dt = '{pt_date}'")

# パラメータとデフォルト値を定義します（デバッグ時のみ有効）
dlcutils.widgets.text("pt_date", "20260507", "業務日付")

# パラメータを読み取る
pt_date = dlcutils.widgets.get("pt_date")

create_time >= '${yyyy-MM-dd-1d HH:mm:ss}'
  AND create_time < '${yyyy-MM-dd HH:mm:ss}'

/user/test/data_${yyyyMMdd}.ok

/user/test/${filetrans_di_src}_${yyyyMMdd}.ok

# 数値比較（タスクパラメータqt = 100）
${qt} > 50

# 文字列比較（文字列パラメータは引用符で囲む必要があります）
'${pt_date}' == '20260507'

# 組み合わせ条件
${qt} > 50 and '${pt_date}' >= '20260501'