開始オフセットから使用可能なすべてのデータを読み取り、次の読み取り試行の開始位置のオフセットを返します。
Databricks Runtime 15.3 で追加されました
構文
read(start: dict)
パラメーター
| パラメーター | タイプ | 説明 |
|---|---|---|
start |
辞書 | 読み取り開始オフセット。 |
返品
Tuple[Iterator[Tuple], dict]
反復子とディクテーションのタプル。 反復子には、開始オフセットの後に使用可能なすべてのレコードが含まれます。 dict は、この読み取り試行の終了オフセットと、次の読み取り試行の開始オフセットです。
イテレーターはピクル可能でなければなりません。
iter([...])のようなリストに対してイテレーターを返します。 発電機の返却は TypeError: cannot pickle 'generator' objectで失敗します。