Notă
Accesul la această pagină necesită autorizare. Puteți încerca să vă conectați sau să modificați directoarele.
Accesul la această pagină necesită autorizare. Puteți încerca să modificați directoarele.
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()