Нотатка
Доступ до цієї сторінки потребує авторизації. Можна спробувати ввійти або змінити каталоги.
Доступ до цієї сторінки потребує авторизації. Можна спробувати змінити каталоги.
Loads an ORC file stream and returns the result as a DataFrame.
Syntax
orc(path, **options)
Parameters
| Parameter | Type | Description |
|---|---|---|
path |
str | Path to the ORC dataset. |
Returns
DataFrame
Examples
Load a stream from a temporary ORC file:
import tempfile
import time
with tempfile.TemporaryDirectory(prefix="orc") as d:
spark.range(10).write.mode("overwrite").format("orc").save(d)
q = spark.readStream.schema("id LONG").orc(d).writeStream.format("console").start()
time.sleep(3)
q.stop()