Package | Description |
---|---|
ai.rapids.cudf |
Modifier and Type | Class and Description |
---|---|
class |
DefaultHostMemoryAllocator |
Modifier and Type | Method and Description |
---|---|
static HostMemoryAllocator |
DefaultHostMemoryAllocator.get()
Retrieve current host memory allocator used by default if not passed directly to API
|
Modifier and Type | Method and Description |
---|---|
static HostMemoryBuffer |
PinnedMemoryPool.allocate(long bytes,
HostMemoryAllocator hostMemoryAllocator)
Factory method to create a host buffer but preferably pointing to pinned memory.
|
static JCudfSerialization.HostConcatResult |
JCudfSerialization.concatToHostBuffer(JCudfSerialization.SerializedTableHeader[] headers,
HostMemoryBuffer[] dataBuffers,
HostMemoryAllocator hostMemoryAllocator)
Concatenate multiple tables in host memory into a single host table buffer.
|
HostColumnVector |
ColumnView.copyToHost(HostMemoryAllocator hostMemoryAllocator)
Copy the data to the host synchronously.
|
HostColumnVector |
ColumnView.copyToHostAsync(Cuda.Stream stream,
HostMemoryAllocator hostMemoryAllocator)
Copy the data to the host asynchronously.
|
static TableWriter |
Table.getCSVBufferWriter(CSVWriterOptions options,
HostBufferConsumer bufferConsumer,
HostMemoryAllocator hostMemoryAllocator) |
static StreamedTableReader |
Table.readArrowIPCChunked(ArrowIPCOptions options,
HostBufferProvider provider,
HostMemoryAllocator hostMemoryAllocator)
Get a reader that will return tables.
|
static Table |
Table.readAvro(AvroOptions opts,
byte[] buffer,
long offset,
long len,
HostMemoryAllocator hostMemoryAllocator)
Read Avro formatted data.
|
static Table |
Table.readCSV(Schema schema,
CSVOptions opts,
byte[] buffer,
long offset,
long len,
HostMemoryAllocator hostMemoryAllocator)
Read CSV formatted data.
|
static Table |
Table.readJSON(Schema schema,
JSONOptions opts,
byte[] buffer,
long offset,
long len,
HostMemoryAllocator hostMemoryAllocator)
Read JSON formatted data.
|
static Table |
Table.readJSON(Schema schema,
JSONOptions opts,
byte[] buffer,
long offset,
long len,
HostMemoryAllocator hostMemoryAllocator,
int emptyRowCount)
Deprecated.
This method is deprecated since emptyRowCount is not used. Use the method without
emptyRowCount instead.
|
static Table |
Table.readORC(ORCOptions opts,
byte[] buffer,
long offset,
long len,
HostMemoryAllocator hostMemoryAllocator)
Read ORC formatted data.
|
static Table |
Table.readParquet(ParquetOptions opts,
byte[] buffer,
long offset,
long len,
HostMemoryAllocator hostMemoryAllocator)
Read parquet formatted data.
|
static JCudfSerialization.TableAndRowCountPair |
JCudfSerialization.readTableFrom(InputStream in,
HostMemoryAllocator hostMemoryAllocator)
Read a serialize table from the given InputStream.
|
static void |
DefaultHostMemoryAllocator.set(HostMemoryAllocator hostMemoryAllocator)
Sets a new default host memory allocator implementation by default.
|
static TableWriter |
Table.writeArrowIPCChunked(ArrowIPCWriterOptions options,
HostBufferConsumer consumer,
HostMemoryAllocator hostMemoryAllocator)
Get a table writer to write arrow IPC data and handle each chunk with a callback.
|
static void |
Table.writeColumnViewsToParquet(ParquetWriterOptions options,
HostBufferConsumer consumer,
HostMemoryAllocator hostMemoryAllocator,
ColumnView... columnViews)
This is an evolving API and most likely be removed in future releases.
|
static TableWriter |
Table.writeORCChunked(ORCWriterOptions options,
HostBufferConsumer consumer,
HostMemoryAllocator hostMemoryAllocator)
Get a table writer to write ORC data and handle each chunk with a callback.
|
static TableWriter |
Table.writeParquetChunked(ParquetWriterOptions options,
HostBufferConsumer consumer,
HostMemoryAllocator hostMemoryAllocator)
Get a table writer to write parquet data and handle each chunk with a callback.
|
Constructor and Description |
---|
MultiBufferDataSource(HostMemoryAllocator allocator,
HostMemoryBuffer... buffers)
Create a new data source backed by multiple buffers.
|
Copyright © 2024. All rights reserved.