MCPcopy Create free account
hub / github.com/apache/arrow / open_input_stream

Method open_input_stream

python/pyarrow/tests/test_fs.py:128–132  ·  view source on GitHub ↗
(self, path)

Source from the content-addressed store, hash-verified

126 assert dest == "copy_file_to"
127
128 def open_input_stream(self, path):
129 if "notfound" in path:
130 raise FileNotFoundError(path)
131 data = f"{path}:input_stream".encode('utf8')
132 return pa.BufferReader(data)
133
134 def open_input_file(self, path):
135 if "notfound" in path:

Callers 11

test_open_input_streamFunction · 0.45
test_open_output_streamFunction · 0.45
test_open_append_streamFunction · 0.45
test_localfs_errorsFunction · 0.45
test_s3_real_awsFunction · 0.45
test_copy_filesFunction · 0.45
check_copied_filesFunction · 0.45

Calls 2

BufferReaderMethod · 0.80
encodeMethod · 0.45

Tested by

no test coverage detected