ai.rapids.cudf

类 MultiBufferDataSource

java.lang.Object

ai.rapids.cudf.DataSource

ai.rapids.cudf.MultiBufferDataSource

所有实现的接口:

AutoCloseable

public class MultiBufferDataSource
extends DataSource

这是一个可以接受多个 HostMemoryBuffer 的 DataSource。它们被视为单个文件的一部分，端到端连接。

构造器摘要

构造器

构造器和说明
MultiBufferDataSource(HostMemoryAllocator allocator, HostMemoryBuffer... buffers) 创建一个由多个缓冲区支持的新数据源。
MultiBufferDataSource(HostMemoryBuffer... buffers) 创建一个由多个缓冲区支持的新数据源。

方法摘要

修饰符和类型	方法和说明
void	close()
long	deviceRead(long offset, DeviceMemoryBuffer dest, Cuda.Stream stream) 从源中给定偏移量处读取数据到 dest。
long	getDevReadBytes()
long	getDevReads()
long	getHostReadBytes()
long	getHostReads()
long	hostRead(long offset, HostMemoryBuffer dest) 从源中给定偏移量处读取数据到 dest。
HostMemoryBuffer	hostRead(long offset, long amount) 从源中给定偏移量处读取数据。
long	size() 获取源的大小（字节）。
boolean	supportsDeviceRead() 如果支持直接读取到设备则返回 true，否则返回 false。

从类继承的方法 ai.rapids.cudf.DataSource

getDeviceReadCutoff, onHostBufferDone

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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细信息

MultiBufferDataSource

public MultiBufferDataSource(HostMemoryBuffer... buffers)

创建一个由多个缓冲区支持的新数据源。

参数:

buffers - 将支持数据源的缓冲区。

MultiBufferDataSource

public MultiBufferDataSource(HostMemoryAllocator allocator,
                             HostMemoryBuffer... buffers)

创建一个由多个缓冲区支持的新数据源。

参数:

allocator - 如有需要，用于主机缓冲区的分配器。

buffers - 将支持数据源的缓冲区。

方法详细信息

size

public long size()

从类复制的说明: DataSource

获取源的大小（字节）。

指定者:

size 在类中 DataSource

hostRead

public HostMemoryBuffer hostRead(long offset,
                                 long amount)

从类复制的说明: DataSource

从源中给定偏移量处读取数据。返回一个 HostMemoryBuffer，指向读取的数据。

指定者:

hostRead 在类中 DataSource

参数:

offset - 从哪里开始读取。

amount - 要读取的最大字节数。

返回:

指向数据的缓冲区。

hostRead

public long hostRead(long offset,
                     HostMemoryBuffer dest)

从类复制的说明: DataSource

从源中给定偏移量处读取数据到 dest。请注意，dest 不应被关闭，对其引用不能超出 hostRead 的调用生命周期。要读取的目标量是 dest 的长度。

指定者:

hostRead 在类中 DataSource

参数:

offset - 从源中开始读取的偏移量。

dest - 写入数据的位置。

返回:

实际写入 dest 的字节数。

supportsDeviceRead

public boolean supportsDeviceRead()

从类复制的说明: DataSource

如果支持直接读取到设备则返回 true，否则返回 false。默认是不支持设备读取。这不能动态改变。通常只读取一次。

覆盖:

supportsDeviceRead 在类中 DataSource

deviceRead

public long deviceRead(long offset,
                       DeviceMemoryBuffer dest,
                       Cuda.Stream stream)

从类复制的说明: DataSource

从源中给定偏移量处读取数据到 dest。请注意，dest 不应被关闭，对其引用不能超出 hostRead 的调用生命周期。要读取的目标量是 dest 的长度。

覆盖:

deviceRead 在类中 DataSource

参数:

offset - 开始读取的偏移量

dest - 写入数据的位置。

stream - 执行复制的流。

返回:

实际写入 dest 的字节数。

close

public void close()

指定者:

close 在接口中 AutoCloseable

覆盖:

close 在类中 DataSource

getHostReads

public long getHostReads()

getHostReadBytes

public long getHostReadBytes()

getDevReads

public long getDevReads()

getDevReadBytes

public long getDevReadBytes()