開始オフセットと終了オフセット InputPartition オブジェクトの一覧を返します。
各 InputPartition は、1 つの Spark タスクで処理できるデータ分割を表します。
start == end空のオフセット範囲で呼び出されると、このメソッドは空のシーケンスを返す必要があります。
Databricks Runtime 15.2 で追加されました
構文
partitions(start: dict, end: dict)
パラメーター
| パラメーター | タイプ | 説明 |
|---|---|---|
start |
辞書 | パーティション分割を計画するマイクロバッチの開始オフセット。 |
end |
辞書 | パーティション分割を計画するマイクロバッチの終了オフセット。 |
返品
Sequence[InputPartition]
このデータ ソースのパーティションのシーケンス。 各パーティション値は、 InputPartition のインスタンスまたはサブクラスである必要があります。