Parameters:	+ series (pandas.Series or numpy.ndarray) – + mask (pandas.Series or numpy.ndarray, optional) – boolean mask if the object is null (True) or valid (False) + type (pyarrow.DataType) – Explicit type to attempt to coerce to + timestamps_to_ms (bool, optional) – Convert datetime columns to ms resolution. This is needed for +compatibility with other functionality like Parquet I/O which +only supports milliseconds. + memory_pool (MemoryPool, optional) – Specific memory pool to use to allocate the resulting Arrow array. + +

Returns:	pyarrow.array.Array

Parameters:	+ offset (int, default 0) – Offset from start of array to slice + length (int, default None) – Length of slice (default is until end of Array starting from +offset) + +
Returns:	sliced (RecordBatch) +

Parameters:

offset (int, default 0) – Offset from start of array to slice
length (int, default None) – Length of slice (default is until end of Array starting from +offset)

Returns:

sliced (RecordBatch)

Parameters:	+ series (pandas.Series or numpy.ndarray) – + mask (pandas.Series or numpy.ndarray, optional) – boolean mask if the object is null (True) or valid (False) + type (pyarrow.DataType) – Explicit type to attempt to coerce to + timestamps_to_ms (bool, optional) – Convert datetime columns to ms resolution. This is needed for +compatibility with other functionality like Parquet I/O which +only supports milliseconds. + memory_pool (MemoryPool, optional) – Specific memory pool to use to allocate the resulting Arrow array. + +

Returns:	pyarrow.array.Array

Parameters:	+ offset (int, default 0) – Offset from start of array to slice + length (int, default None) – Length of slice (default is until end of Array starting from +offset) + +
Returns:	sliced (RecordBatch) +

Parameters:

offset (int, default 0) – Offset from start of array to slice
length (int, default None) – Length of slice (default is until end of Array starting from +offset)

Returns:

sliced (RecordBatch)

Parameters:	+ series (pandas.Series or numpy.ndarray) – + mask (pandas.Series or numpy.ndarray, optional) – boolean mask if the object is null (True) or valid (False) + type (pyarrow.DataType) – Explicit type to attempt to coerce to + timestamps_to_ms (bool, optional) – Convert datetime columns to ms resolution. This is needed for +compatibility with other functionality like Parquet I/O which +only supports milliseconds. + memory_pool (MemoryPool, optional) – Specific memory pool to use to allocate the resulting Arrow array. + +

Returns:	pyarrow.array.Array

Parameters:	+ offset (int, default 0) – Offset from start of array to slice + length (int, default None) – Length of slice (default is until end of Array starting from +offset) + +
Returns:	sliced (RecordBatch) +

Parameters:

offset (int, default 0) – Offset from start of array to slice
length (int, default None) – Length of slice (default is until end of Array starting from +offset)

Returns:

sliced (RecordBatch)

+ +

pyarrow.Message¶

+class pyarrow.Message¶

Bases: object

Container for an Arrow IPC message with metadata and optional body

+__init__()¶: Initialize self. See help(type(self)) for accurate signature.
+

+ +

Methods

+ ++++ + + + + + + + + +

`equals`(self, Message other)	Returns True if the message contents (metadata and body) are identical
`serialize`(self[, memory_pool])	Write message to Buffer with length-prefixed metadata, then body

Attributes

+ ++++ + + + + + + + + + + + +

`body`
`metadata`
`type`

+body¶

+ +

+equals(self, Message other)¶

Returns True if the message contents (metadata and body) are identical

+ +++ + + + + + +

Parameters:	other (Message) –
Returns:	are_equal (bool)

+ +

+metadata¶

+ +

+serialize(self, memory_pool=None)¶

Write message to Buffer with length-prefixed metadata, then body

+ +++ + + + + + +

Parameters:	memory_pool (MemoryPool, default None) – Uses default memory pool if not specified
Returns:	serialized (Buffer)

+ +

+type¶

+ +

+ + +

pyarrow.MessageReader¶

+class pyarrow.MessageReader¶

Bases: object

Interface for reading Message objects from some source (like an +InputStream)

+__init__()¶: Initialize self. See help(type(self)) for accurate signature.
+

+ +

Methods

+ ++++ + + + + + + + + +

`open_stream`(source)
`read_next_message`(self)	Read next Message from the stream.

+static open_stream(source)¶

+ +

+read_next_message(self)¶: Read next Message from the stream. Raises StopIteration at end of +stream
+

+ +

`equals`(self, Array other)
`from_pandas`(obj[, mask, timestamps_to_ms])	Convert pandas.Series to an Arrow Array.
`isnull`(self)
`slice`(self[, offset, length])	Compute zero-copy slice of this array
`to_pandas`(self)	Convert to an array object suitable for use in pandas
`to_pylist`(self)	Convert to an list of native Python objects.

`equals`(self, Array other)
`from_pandas`(obj[, mask, timestamps_to_ms])	Convert pandas.Series to an Arrow Array.
`isnull`(self)
`slice`(self[, offset, length])	Compute zero-copy slice of this array
`to_pandas`(self)	Convert to an array object suitable for use in pandas
`to_pylist`(self)	Convert to an list of native Python objects.

`equals`(self, Array other)
`from_pandas`(obj[, mask, timestamps_to_ms])	Convert pandas.Series to an Arrow Array.
`isnull`(self)
`slice`(self[, offset, length])	Compute zero-copy slice of this array
`to_pandas`(self)	Convert to an array object suitable for use in pandas
`to_pylist`(self)	Convert to an list of native Python objects.

`close`(self)
`create`(path, size)
`download`(self, stream_or_path[, buffer_size])	Read file completely to local path (rather than reading completely into memory).
`read`(self[, nbytes])
`read_buffer`(self[, nbytes])
`seek`(self, int64_t position)
`size`(self)
`tell`(self)
`upload`(self, stream[, buffer_size])	Pipe file-like object to file
`write`(self, data)	Write byte from any object implementing buffer protocol (bytes,