Notiz
Zougrëff op dës Säit erfuerdert Autorisatioun. Dir kënnt probéieren, Iech unzemellen oder Verzeechnesser ze änneren.
Zougrëff op dës Säit erfuerdert Autorisatioun. Dir kënnt probéieren, Verzeechnesser ze änneren.
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()