MCPcopy Create free account
hub / github.com/apache/datafusion / set_stream

Method set_stream

datafusion/datasource/src/file_stream/mod.rs:1660–1663  ·  view source on GitHub ↗

Records that this partition's stream has been built.

(&mut self, stream: FileStream)

Source from the content-addressed store, hash-verified

1658
1659 /// Records that this partition's stream has been built.
1660 fn set_stream(&mut self, stream: FileStream) {
1661 self.stream = Some(stream);
1662 self.built = true;
1663 }
1664
1665 /// Records one formatted output line for this partition.
1666 fn push_output(&mut self, line: String) {

Callers 1

runMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected