MCPcopy Create free account
hub / github.com/apache/spark-connect-rust / write_stream

Method write_stream

crates/connect/src/dataframe.rs:1399–1401  ·  view source on GitHub ↗

Interface for [DataStreamWriter] to save the content of the streaming DataFrame out into external storage.

(self)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 9

mainFunction · 0.80
test_stream_activeFunction · 0.80
test_stream_statusFunction · 0.80
test_stream_progressFunction · 0.80
test_stream_explainFunction · 0.80
test_stream_manager_activeFunction · 0.80
test_stream_manager_getFunction · 0.80
test_stream_manager_await_termFunction · 0.80
test_stream_manager_await_term_noneFunction · 0.80

Calls

no outgoing calls

Tested by 8

test_stream_activeFunction · 0.64
test_stream_statusFunction · 0.64
test_stream_progressFunction · 0.64
test_stream_explainFunction · 0.64
test_stream_manager_activeFunction · 0.64
test_stream_manager_getFunction · 0.64
test_stream_manager_await_termFunction · 0.64
test_stream_manager_await_term_noneFunction · 0.64