Aurora DSQL EXPLAIN プランのバッチ処理されたネストループ結合

Aurora DSQL がストレージから効率的にスキャンできる内部入力に対して、クエリが小さな外部入力を結合する場合、Aurora DSQL は Nested Loop (Batched Join) プランを選択できます。この結合タイプは、内部側をプローブする前に複数の外部行をグループ化することで、コンピューティングレイヤーとストレージレイヤー間のラウンドトリップを削減します。

標準のネストループは、外部の行を一度に 1 つずつ処理し、行ごとに内部スキャンを再度実行します。バッチ処理されたネストループ結合は、外部の行をバッチとして収集し、バッチ全体に対して内部スキャン処理を構築してから、返された内部の行を一致する外部の行に結合します。

バッチ処理されたネストループ結合の仕組み

このアプローチは、内部側がパラメータ化された Index Cond を持つインデックススキャンである場合に最も役立ちます。組み合わされたスキャンキーにより、外部バッチ全体に対してターゲットを絞ったストレージアクセスが可能になるためです。

Aurora DSQL がこの結合を使用する場合

Aurora DSQL がバッチ処理されたネストループ結合を検討するのは、結合の内側が物理スキャンノード (Index Scan、Index Only Scan、Full Scan、または Sequential Scan) であり、バッチ処理のコストが、外部行ごとに内部スキャンを実行するよりも低くなると予想される場合です。実際には、通常、外部入力が小さく、外部側でパラメータ化された Index Cond を使用して内部インデックススキャンを実行したときに、最大の利点が得られます。

ハッシュ結合やマージ結合など、別のプラン形状の方がコストが低い場合、Aurora DSQL は代わりにそのプランを選択します。チューニング中にプラン形状を比較するには、現在のセッションでバッチ処理されたネストループ結合を無効にすることができます。

SET dsql.enable_batched_nestloop = off;

バッチ処理されたネストループ結合の出力を読み取る方法

次のクエリでは、Aurora DSQL EXPLAIN プランの読み取り のサンプル transaction テーブルと account テーブルを使用します。

EXPLAIN
SELECT t.account_id, a.balance
FROM transaction t
LEFT JOIN account a
  ON t.account_id = a.customer_id
 AND a.balance > CASE
                    WHEN t.description LIKE 'fee%' THEN 0
                    ELSE 100
                  END
WHERE t.transaction_date >= '2025-01-01'
  AND (a.status = 'active' OR a.customer_id IS NULL)
ORDER BY t.account_id;

EXPLAIN プランには、次のような出力が含まれる場合があります。

Sort
  Sort Key: t.account_id
  -> Nested Loop (Batched Join)
       Filter: (((status)::text = 'active'::text) OR (customer_id IS NULL))
       Join Type: Left
       Recheck Cond: (customer_id = t.account_id)
       Join Filter: (balance > CASE WHEN (t.description ~~ 'fee%'::text) THEN '0'::numeric ELSE '100'::numeric END)
       -> Full Scan (btree-table) on transaction t
            -> Storage Scan on transaction t
                 Filters: (transaction_date >= '2025-01-01 00:00:00'::timestamp without time zone)
                 -> B-Tree Scan on transaction t
       -> Index Only Scan using idx1 on account a
            Index Cond: (customer_id = t.account_id)