klboke commented on issue #6157:
URL: https://github.com/apache/paimon/issues/6157#issuecomment-3226951563
> read_builder.new_scan().with_shard(0, 3)
@JingsongLi Hi, after testing this feature, it doesn't meet expectations.
The expected input parameters are the start row number and end row number, and
the function should return the rows within that range. For example, you can
refer to the interface definition of mc as follows.
```python
def open_arrow_reader(
self, start, count, compress=False, columns=None,
append_partitions=False
):
"""
Open a reader to read data as Arrow format from the tunnel.
:param int start: start row index
:param int count: number of rows to read
:param bool compress: whether to compress data
:columns: list of column names to read
:append_partitions: whether to append partition values as columns
:return: an Arrow reader
:rtype: :class:`TunnelArrowReader`
"""
return self._open_reader(
start,
count,
compress=compress,
columns=columns,
arrow=True,
append_partitions=append_partitions,
partition_spec=self._partition_spec,
reader_cls=TunnelArrowReader,
)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
