Lưu ý
Cần có ủy quyền mới truy nhập được vào trang này. Bạn có thể thử đăng nhập hoặc thay đổi thư mục.
Cần có ủy quyền mới truy nhập được vào trang này. Bạn có thể thử thay đổi thư mục.
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()