pyarrow.PythonFile

class pyarrow.PythonFile

Bases: pyarrow.lib.NativeFile

A stream backed by a Python file object.

This class allows using Python file objects with arbitrary Arrow functions, including functions written in another language than Python.

As a downside, there is a non-zero redirection cost in translating Arrow stream calls to Python method calls. Furthermore, Python’s Global Interpreter Lock may limit parallelism in some situations.

__init__()

Initialize self. See help(type(self)) for accurate signature.

Methods

__init__()	Initialize self.
close(self)
download(self, stream_or_path[, buffer_size])	Read file completely to local path (rather than reading completely into memory).
fileno(self)	NOT IMPLEMENTED
flush(self)	Flush the stream, if applicable.
isatty(self)
read(self[, nbytes])	Read indicated number of bytes from file, or read all remaining bytes if no argument passed
read1(self[, nbytes])	Read and return up to n bytes.
read_at(self, nbytes, offset)	Read indicated number of bytes at offset from the file
read_buffer(self[, nbytes])
readable(self)
readall(self)
readinto(self, b)	Read into the supplied buffer
readline(self[, size])
readlines(self[, hint])
seek(self, int64_t position, int whence=0)	Change current file stream position
seekable(self)
size(self)	Return file size
tell(self)	Return current stream position
truncate(self[, pos])
upload(self, stream[, buffer_size])	Pipe file-like object to file
writable(self)
write(self, data)	Write byte from any object implementing buffer protocol (bytes, bytearray, ndarray, pyarrow.Buffer)
writelines(self, lines)

Attributes

closed
mode	The file mode.

close(self)

closed

download(self, stream_or_path, buffer_size=None)

Read file completely to local path (rather than reading completely into memory). First seeks to the beginning of the file.

fileno(self)

NOT IMPLEMENTED

flush(self)

Flush the stream, if applicable.

An error is raised if stream is not writable.

isatty(self)

mode

The file mode. Currently instances of NativeFile may support:

• rb: binary read

• wb: binary write

• rb+: binary read and write

read(self, nbytes=None)

Read indicated number of bytes from file, or read all remaining bytes if no argument passed

Parameters

nbytes (int, default None) –

Returns

data (bytes)

read1(self, nbytes=None)

Read and return up to n bytes.

Alias for read, needed to match the IOBase interface.

read_at(self, nbytes, offset)

Read indicated number of bytes at offset from the file

Parameters

• nbytes (int) –

• offset (int) –

Returns

data (bytes)

read_buffer(self, nbytes=None)

readable(self)

readall(self)

readinto(self, b)

Read into the supplied buffer

Parameters

b (any python object supporting buffer interface) –

Returns

number of bytes written

readline(self, size=None)

readlines(self, hint=None)

seek(self, int64_t position, int whence=0)

Change current file stream position

Parameters

• position (int) – Byte offset, interpreted relative to value of whence argument

• whence (int, default 0) – Point of reference for seek offset

Notes

Values of whence: * 0 – start of stream (the default); offset should be zero or positive * 1 – current stream position; offset may be negative * 2 – end of stream; offset is usually negative

Returns

new_position (the new absolute stream position)

seekable(self)

size(self)

Return file size

tell(self)

Return current stream position

truncate(self, pos=None)

upload(self, stream, buffer_size=None)

Pipe file-like object to file

writable(self)

write(self, data)

Write byte from any object implementing buffer protocol (bytes, bytearray, ndarray, pyarrow.Buffer)

Parameters

data (bytes-like object or exporter of buffer protocol) –

Returns

nbytes (number of bytes written)

writelines(self, lines)

pyarrow.OSFile pyarrow.BufferReader