トップ / フィルタ・サンプリング

limit

先頭から指定した行数だけを取得する。

df.limit(10)

ldf.limit(10)

挙動・設計の違い

SnowparkはSQLのLIMIT句を追加してSnowflake側に行数制限を伝える。Polarsはストリーミング実行時、指定行数を集めた時点で下流のパイプラインを早期終了させる。どちらも「全件処理してから先頭を切り出す」のではなく、早期に打ち切る動き方をする。

移行時の落とし穴

事前にソート（Snowparkのsort／Polarsのsort）をしていないlimitは、両エンジンとも「どの行が返るか」の決定性を保証しない。同じクエリを2回実行しても違う行が返る可能性があるため、再現性が必要な場面では必ずソートと組み合わせる。

フィルタ・サンプリングの他のメソッド

• filter / where ── 条件に合う行だけを残す。whereはfilterの別名で、書き方はどちらも同じ。
• sample ── データの一部をランダムに抽出する。
• distinct / unique ── 重複行を取り除く。メソッド名がSnowparkとPolarsで異なる点に注意。
• drop_duplicates ── 指定した列の値が一致する行を重複とみなして間引く。

出典・検証情報

• Snowpark 公式リファレンス（limit）
• Polars 公式リファレンス（limit）

Polars 1.43.2 で実行確認 / Snowpark Python SDK 1.54.0 で静的検証（2026-08-21）