ParquetChunkedReader (cudfjni 25.04.0 API)

java.lang.Object
- ai.rapids.cudf.ParquetChunkedReader

所有已实现的接口

AutoCloseable
```
public class ParquetChunkedReader
extends Object
implements AutoCloseable
```
提供一种迭代读取 Parquet 文件的接口。

构造器摘要

构造器
构造器及说明
`ParquetChunkedReader(long chunkSizeByteLimit, File filePath)` 从读取限制和文件路径构造读取器实例。
`ParquetChunkedReader(long chunkSizeByteLimit, long passReadLimit, ParquetOptions opts, File filePath)` 从读取限制、ParquetOptions 对象和文件路径构造读取器实例。
`ParquetChunkedReader(long chunkSizeByteLimit, long passReadLimit, ParquetOptions opts, HostMemoryBuffer... buffers)` 从读取限制和主机内存缓冲区中的数据构造读取器实例。
`ParquetChunkedReader(long chunkSizeByteLimit, long passReadLimit, ParquetOptions opts, HostMemoryBuffer buffer, long offset, long len)` 从读取限制和已读入内存缓冲区的文件构造读取器实例。
`ParquetChunkedReader(long chunkSizeByteLimit, ParquetOptions opts, DataSource ds)` 从 DataSource 构造读取器实例
`ParquetChunkedReader(long chunkSizeByteLimit, ParquetOptions opts, File filePath)` 从读取限制、ParquetOptions 对象和文件路径构造读取器实例。
`ParquetChunkedReader(long chunkSizeByteLimit, ParquetOptions opts, HostMemoryBuffer buffer, long offset, long len)` 从读取限制和已读入内存缓冲区的文件构造读取器实例。

方法摘要

所有方法实例方法具体方法
修饰符及类型	方法及说明
`void`	`close()`
`boolean`	`hasNext()` 检查给定文件是否还有剩余内容可读。
`Table`	`readChunk()` 读取给定 Parquet 文件中的一批行，使得返回数据的总大小不超过给定的读取限制。

从类 java.lang.Object 继承的方法
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 构造器详细信息
  - ParquetChunkedReader
```
public ParquetChunkedReader(long chunkSizeByteLimit,
                            File filePath)
```
    从读取限制和文件路径构造读取器实例。
    
    参数
    
    chunkSizeByteLimit - 每次读取返回的总字节数的限制，如果无限制则为 0。
    
    filePath - 要读取的输入 Parquet 文件的完整路径。
  - ParquetChunkedReader
```
public ParquetChunkedReader(long chunkSizeByteLimit,
                            ParquetOptions opts,
                            File filePath)
```
    从读取限制、ParquetOptions 对象和文件路径构造读取器实例。
    
    参数
    
    chunkSizeByteLimit - 每次读取返回的总字节数的限制，如果无限制则为 0。
    
    opts - Parquet 读取选项。
    
    filePath - 要读取的输入 Parquet 文件的完整路径。
  - ParquetChunkedReader
```
public ParquetChunkedReader(long chunkSizeByteLimit,
                            long passReadLimit,
                            ParquetOptions opts,
                            File filePath)
```
    从读取限制、ParquetOptions 对象和文件路径构造读取器实例。
    
    参数
    
    chunkSizeByteLimit - 每次读取返回的总字节数的限制，如果无限制则为 0。
    
    passReadLimit - 用于读取和解压数据的内存量限制，如果无限制则为 0
    
    opts - Parquet 读取选项。
    
    filePath - 要读取的输入 Parquet 文件的完整路径。
  - ParquetChunkedReader
```
public ParquetChunkedReader(long chunkSizeByteLimit,
                            ParquetOptions opts,
                            HostMemoryBuffer buffer,
                            long offset,
                            long len)
```
    从读取限制和已读入内存缓冲区的文件构造读取器实例。
    
    参数
    
    chunkSizeByteLimit - 每次读取返回的总字节数的限制，如果无限制则为 0。
    
    opts - Parquet 读取选项。
    
    buffer - 原始 Parquet 文件内容。
    
    offset - 缓冲区中的起始偏移量。
    
    len - 要解析给定缓冲区的字节数。
  - ParquetChunkedReader
```
public ParquetChunkedReader(long chunkSizeByteLimit,
                            long passReadLimit,
                            ParquetOptions opts,
                            HostMemoryBuffer buffer,
                            long offset,
                            long len)
```
    从读取限制和已读入内存缓冲区的文件构造读取器实例。
    
    参数
    
    chunkSizeByteLimit - 每次读取返回的总字节数的限制，如果无限制则为 0。
    
    passReadLimit - 用于读取和解压数据的内存量限制，如果无限制则为 0
    
    opts - Parquet 读取选项。
    
    buffer - 原始 Parquet 文件内容。
    
    offset - 缓冲区中的起始偏移量。
    
    len - 要解析给定缓冲区的字节数。
  - ParquetChunkedReader
```
public ParquetChunkedReader(long chunkSizeByteLimit,
                            long passReadLimit,
                            ParquetOptions opts,
                            HostMemoryBuffer... buffers)
```
    从读取限制和主机内存缓冲区中的数据构造读取器实例。
    
    参数
    
    chunkSizeByteLimit - 每次读取返回的总字节数的限制，如果无限制则为 0。
    
    passReadLimit - 用于读取和解压数据的内存量限制，如果无限制则为 0
    
    opts - Parquet 读取选项。
    
    buffers - 包含文件数据的缓冲区数组。这些缓冲区逻辑上连接起来构成要读取的文件。
  - ParquetChunkedReader
```
public ParquetChunkedReader(long chunkSizeByteLimit,
                            ParquetOptions opts,
                            DataSource ds)
```
    从 DataSource 构造读取器实例
    
    参数
    
    chunkSizeByteLimit - 每次读取返回的总字节数的限制，如果无限制则为 0。
    
    opts - Parquet 读取选项。
    
    ds - 要从中读取的数据源
- 方法详细信息
  - hasNext
```
public boolean hasNext()
```
    检查给定文件是否还有剩余内容可读。
    
    返回
    
    一个布尔值，指示文件是否还有更多数据可读。
  - readChunk
```
public Table readChunk()
```
    读取给定 Parquet 文件中的一批行，使得返回数据的总大小不超过给定的读取限制。如果给定文件没有数据，或者所有数据之前已被此函数的先前调用读取，则将返回 null Table。
    
    返回
    
    从给定文件读取的新行的表。
  - close
```
public void close()
```
    指定者：
    
    close 在接口 AutoCloseable 中

类 ParquetChunkedReader

构造器摘要

方法摘要

从类 java.lang.Object 继承的方法

构造器详细信息

ParquetChunkedReader

ParquetChunkedReader

ParquetChunkedReader

ParquetChunkedReader

ParquetChunkedReader

ParquetChunkedReader

ParquetChunkedReader

方法详细信息

hasNext

readChunk

close