opomba,
Dostop do te strani zahteva pooblastilo. Poskusite se vpisati alispremeniti imenike.
Dostop do te strani zahteva pooblastilo. Poskusite lahko spremeniti imenike.
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()