| Package | Description |
|---|---|
| ai.rapids.cudf | |
| ai.rapids.cudf.ast |
| Modifier and Type | Method and Description |
|---|---|
Table |
Table.GroupByOperation.aggregate(GroupByAggregationOnColumn... aggregates)
Aggregates the group of columns represented by indices
Usage:
aggregate(count(), max(2),...);
example:
input : 1, 1, 1
1, 2, 1
2, 4, 5
table.groupBy(0, 2).count()
col0, col1
output: 1, 1
1, 2
2, 1 ==> aggregated count
|
Table |
Table.GroupByOperation.aggregateWindows(AggregationOverWindow... windowAggregates)
Computes row-based window aggregation functions on the Table/projection,
based on windows specified in the argument.
|
Table |
Table.GroupByOperation.aggregateWindowsOverRanges(AggregationOverWindow... windowAggregates)
Computes range-based window aggregation functions on the Table/projection,
based on windows specified in the argument.
|
Table |
Table.TestBuilder.build() |
static Table |
Aggregation128Utils.combineInt64SumChunks(Table chunks,
DType type)
Reassemble a column of 128-bit values from a table of four 64-bit integer columns and check
for overflow.
|
static Table |
Table.concatenate(Table... tables)
Concatenate multiple tables together to form a single table.
|
Table |
Table.crossJoin(Table right)
Joins two tables all of the left against all of the right.
|
Table |
Table.dropDuplicates(int[] keyColumns,
Table.DuplicateKeepOption keep,
boolean nullsEqual)
Copy rows of the current table to an output table such that duplicate rows in the key columns
are ignored (i.e., only one row from the duplicate ones will be copied).
|
Table |
Table.explode(int index)
Explodes a list column's elements.
|
Table |
Table.explodeOuter(int index)
Explodes a list column's elements.
|
Table |
Table.explodeOuterPosition(int index)
Explodes a list column's elements retaining any null entries or empty lists and includes a
position column.
|
Table |
Table.explodePosition(int index)
Explodes a list column's elements and includes a position column.
|
Table |
ColumnView.extractRe(RegexProgram regexProg)
For each captured group specified in the given regex program
return a column in the table.
|
Table |
ColumnView.extractRe(String pattern)
Deprecated.
|
Table |
Table.filter(ColumnView mask)
Filters this table using a column of boolean values as a mask, returning a new one.
|
static Table |
Table.fromPackedTable(ByteBuffer metadata,
DeviceMemoryBuffer data)
Construct a table from a packed representation.
|
Table |
Table.gather(ColumnView gatherMap)
Gathers the rows of this table according to `gatherMap` such that row "i"
in the resulting table's columns will contain row "gatherMap[i]" from this table.
|
Table |
Table.gather(ColumnView gatherMap,
OutOfBoundsPolicy outOfBoundsPolicy)
Gathers the rows of this table according to `gatherMap` such that row "i"
in the resulting table's columns will contain row "gatherMap[i]" from this table.
|
Table |
StreamedTableReader.getNextIfAvailable()
Get the next table if available.
|
Table |
StreamedTableReader.getNextIfAvailable(int rowTarget)
Get the next table if available.
|
Table |
PartitionedTable.getTable() |
Table |
ContiguousTable.getTable()
Get the table instance, reconstructing it from the metadata if necessary.
|
Table |
JCudfSerialization.TableAndRowCountPair.getTable()
Get the Table that was deserialized or null if there was no data
(e.g.: rows without columns).
|
Table |
ContigSplitGroupByResult.getUniqKeyTable()
Get the key table, each row in the key table is corresponding to a group.
|
static Table |
Table.merge(List<Table> tables,
OrderByArg... args)
Merge multiple already sorted tables keeping the sort order the same.
|
static Table |
Table.merge(Table[] tables,
OrderByArg... args)
Merge multiple already sorted tables keeping the sort order the same.
|
Table |
Table.orderBy(OrderByArg... args)
Orders the table using the sortkeys returning a new allocated table.
|
static Table |
JCudfSerialization.readAndConcat(JCudfSerialization.SerializedTableHeader[] headers,
HostMemoryBuffer[] dataBuffers) |
static Table |
Table.readAvro(AvroOptions opts,
byte[] buffer)
Read Avro formatted data.
|
static Table |
Table.readAvro(AvroOptions opts,
byte[] buffer,
long offset,
long len) |
static Table |
Table.readAvro(AvroOptions opts,
byte[] buffer,
long offset,
long len,
HostMemoryAllocator hostMemoryAllocator)
Read Avro formatted data.
|
static Table |
Table.readAvro(AvroOptions opts,
DataSource ds) |
static Table |
Table.readAvro(AvroOptions opts,
File path)
Read an Avro file.
|
static Table |
Table.readAvro(AvroOptions opts,
HostMemoryBuffer buffer,
long offset,
long len)
Read Avro formatted data.
|
static Table |
Table.readAvro(byte[] buffer)
Read Avro formatted data.
|
static Table |
Table.readAvro(File path)
Read an Avro file using the default AvroOptions.
|
Table |
ORCChunkedReader.readChunk()
Read a chunk of rows in the given ORC file such that the returning data has total size
does not exceed the given read limit.
|
Table |
ParquetChunkedReader.readChunk()
Read a chunk of rows in the given Parquet file such that the returning data has total size
does not exceed the given read limit.
|
static Table |
Table.readCSV(Schema schema,
byte[] buffer)
Read CSV formatted data using the default CSVOptions.
|
static Table |
Table.readCSV(Schema schema,
CSVOptions opts,
byte[] buffer)
Read CSV formatted data.
|
static Table |
Table.readCSV(Schema schema,
CSVOptions opts,
byte[] buffer,
long offset,
long len) |
static Table |
Table.readCSV(Schema schema,
CSVOptions opts,
byte[] buffer,
long offset,
long len,
HostMemoryAllocator hostMemoryAllocator)
Read CSV formatted data.
|
static Table |
Table.readCSV(Schema schema,
CSVOptions opts,
DataSource ds) |
static Table |
Table.readCSV(Schema schema,
CSVOptions opts,
File path)
Read a CSV file.
|
static Table |
Table.readCSV(Schema schema,
CSVOptions opts,
HostMemoryBuffer buffer,
long offset,
long len)
Read CSV formatted data.
|
static Table |
Table.readCSV(Schema schema,
File path)
Read a CSV file using the default CSVOptions.
|
static Table |
Table.readJSON(Schema schema,
byte[] buffer)
Read JSON formatted data using the default JSONOptions.
|
static Table |
Table.readJSON(Schema schema,
File path)
Read a JSON file using the default JSONOptions.
|
static Table |
Table.readJSON(Schema schema,
JSONOptions opts,
byte[] buffer)
Read JSON formatted data.
|
static Table |
Table.readJSON(Schema schema,
JSONOptions opts,
byte[] buffer,
long offset,
long len) |
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.readJSON(Schema schema,
JSONOptions opts,
byte[] buffer,
long offset,
long len,
int emptyRowCount) |
static Table |
Table.readJSON(Schema schema,
JSONOptions opts,
DataSource ds)
Read JSON formatted data.
|
static Table |
Table.readJSON(Schema schema,
JSONOptions opts,
DataSource ds,
int emptyRowCount)
Deprecated.
This method is deprecated since emptyRowCount is not used. Use the method without
emptyRowCount instead.
|
static Table |
Table.readJSON(Schema schema,
JSONOptions opts,
File path)
Read a JSON file.
|
static Table |
Table.readJSON(Schema schema,
JSONOptions opts,
HostMemoryBuffer buffer,
long offset,
long len)
Read JSON formatted data.
|
static Table |
Table.readJSON(Schema schema,
JSONOptions opts,
HostMemoryBuffer buffer,
long offset,
long len,
int emptyRowCount)
Deprecated.
This method is deprecated since emptyRowCount is not used. Use the method without
emptyRowCount instead.
|
static Table |
Table.readORC(byte[] buffer)
Read ORC formatted data.
|
static Table |
Table.readORC(File path)
Read a ORC file using the default ORCOptions.
|
static Table |
Table.readORC(ORCOptions opts,
byte[] buffer)
Read ORC formatted data.
|
static Table |
Table.readORC(ORCOptions opts,
byte[] buffer,
long offset,
long len) |
static Table |
Table.readORC(ORCOptions opts,
byte[] buffer,
long offset,
long len,
HostMemoryAllocator hostMemoryAllocator)
Read ORC formatted data.
|
static Table |
Table.readORC(ORCOptions opts,
DataSource ds) |
static Table |
Table.readORC(ORCOptions opts,
File path)
Read a ORC file.
|
static Table |
Table.readORC(ORCOptions opts,
HostMemoryBuffer buffer,
long offset,
long len)
Read ORC formatted data.
|
static Table |
Table.readParquet(byte[] buffer)
Read parquet formatted data.
|
static Table |
Table.readParquet(File path)
Read a Parquet file using the default ParquetOptions.
|
static Table |
Table.readParquet(ParquetOptions opts,
byte[] buffer)
Read parquet formatted data.
|
static Table |
Table.readParquet(ParquetOptions opts,
byte[] buffer,
long offset,
long len) |
static Table |
Table.readParquet(ParquetOptions opts,
byte[] buffer,
long offset,
long len,
HostMemoryAllocator hostMemoryAllocator)
Read parquet formatted data.
|
static Table |
Table.readParquet(ParquetOptions opts,
DataSource ds) |
static Table |
Table.readParquet(ParquetOptions opts,
File path)
Read a Parquet file.
|
static Table |
Table.readParquet(ParquetOptions opts,
HostMemoryBuffer buffer,
long offset,
long len)
Read parquet formatted data.
|
Table |
TableWithMeta.releaseTable()
Get the table out of this metadata.
|
Table |
Table.repeat(ColumnView counts)
Create a new table by repeating each row of this table.
|
Table |
Table.repeat(int count)
Repeat each row of this table count times.
|
Table |
Table.GroupByOperation.replaceNulls(ReplacePolicyWithColumn... replacements) |
Table |
Table.sample(long n,
boolean replacement,
long seed)
Gather `n` samples from table randomly
Note: does not preserve the ordering
Example:
input: {col1: {1, 2, 3, 4, 5}, col2: {6, 7, 8, 9, 10}}
n: 3
replacement: false
output: {col1: {3, 1, 4}, col2: {8, 6, 9}}
replacement: true
output: {col1: {3, 1, 1}, col2: {8, 6, 6}}
throws "logic_error" if `n` > table rows and `replacement` == FALSE.
|
Table |
Table.GroupByOperation.scan(GroupByScanAggregationOnColumn... aggregates) |
Table |
Table.scatter(ColumnView scatterMap,
Table target)
Scatters values from the source table into the target table out-of-place, returning a new
result table.
|
static Table |
Table.scatter(Scalar[] source,
ColumnView scatterMap,
Table target)
Scatters values from the source rows into the target table out-of-place, returning a new result
table.
|
Table |
ColumnView.stringSplit(RegexProgram regexProg)
Returns a list of columns by splitting each string using the specified regex program pattern.
|
Table |
ColumnView.stringSplit(RegexProgram regexProg,
int limit)
Returns a list of columns by splitting each string using the specified regex program pattern.
|
Table |
ColumnView.stringSplit(String delimiter)
Returns a list of columns by splitting each string using the specified string literal
delimiter.
|
Table |
ColumnView.stringSplit(String pattern,
boolean splitByRegex)
Deprecated.
|
Table |
ColumnView.stringSplit(String delimiter,
int limit)
Returns a list of columns by splitting each string using the specified string literal
delimiter.
|
Table |
ColumnView.stringSplit(String pattern,
int limit,
boolean splitByRegex)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static Table |
Aggregation128Utils.combineInt64SumChunks(Table chunks,
DType type)
Reassemble a column of 128-bit values from a table of four 64-bit integer columns and check
for overflow.
|
static Table |
Table.concatenate(Table... tables)
Concatenate multiple tables together to form a single table.
|
GatherMap[] |
Table.conditionalFullJoinGatherMaps(Table rightTable,
CompiledExpression condition)
Computes the gather maps that can be used to manifest the result of a full join between
two tables when a conditional expression is true.
|
GatherMap[] |
Table.conditionalInnerJoinGatherMaps(Table rightTable,
CompiledExpression condition)
Computes the gather maps that can be used to manifest the result of an inner join between
two tables when a conditional expression is true.
|
GatherMap[] |
Table.conditionalInnerJoinGatherMaps(Table rightTable,
CompiledExpression condition,
long outputRowCount)
Computes the gather maps that can be used to manifest the result of an inner join between
two tables when a conditional expression is true.
|
long |
Table.conditionalInnerJoinRowCount(Table rightTable,
CompiledExpression condition)
Computes the number of rows from the result of an inner join between two tables when a
conditional expression is true.
|
GatherMap |
Table.conditionalLeftAntiJoinGatherMap(Table rightTable,
CompiledExpression condition)
Computes the gather map that can be used to manifest the result of a left anti join between
two tables when a conditional expression is true.
|
GatherMap |
Table.conditionalLeftAntiJoinGatherMap(Table rightTable,
CompiledExpression condition,
long outputRowCount)
Computes the gather map that can be used to manifest the result of a left anti join between
two tables when a conditional expression is true.
|
long |
Table.conditionalLeftAntiJoinRowCount(Table rightTable,
CompiledExpression condition)
Computes the number of rows from the result of a left anti join between two tables when a
conditional expression is true.
|
GatherMap[] |
Table.conditionalLeftJoinGatherMaps(Table rightTable,
CompiledExpression condition)
Computes the gather maps that can be used to manifest the result of a left join between
two tables when a conditional expression is true.
|
GatherMap[] |
Table.conditionalLeftJoinGatherMaps(Table rightTable,
CompiledExpression condition,
long outputRowCount)
Computes the gather maps that can be used to manifest the result of a left join between
two tables when a conditional expression is true.
|
long |
Table.conditionalLeftJoinRowCount(Table rightTable,
CompiledExpression condition)
Computes the number of rows from the result of a left join between two tables when a
conditional expression is true.
|
GatherMap |
Table.conditionalLeftSemiJoinGatherMap(Table rightTable,
CompiledExpression condition)
Computes the gather map that can be used to manifest the result of a left semi join between
two tables when a conditional expression is true.
|
GatherMap |
Table.conditionalLeftSemiJoinGatherMap(Table rightTable,
CompiledExpression condition,
long outputRowCount)
Computes the gather map that can be used to manifest the result of a left semi join between
two tables when a conditional expression is true.
|
long |
Table.conditionalLeftSemiJoinRowCount(Table rightTable,
CompiledExpression condition)
Computes the number of rows from the result of a left semi join between two tables when a
conditional expression is true.
|
Table |
Table.crossJoin(Table right)
Joins two tables all of the left against all of the right.
|
void |
TableDebug.debug(String name,
Table table)
Print the contents of a table.
|
void |
ArrowIPCWriterOptions.DoneOnGpu.doneWithTheGpu(Table table)
A callback to indicate that the table is off of the GPU
and may be closed, even if all of the data is not yet written.
|
GatherMap[] |
Table.fullJoinGatherMaps(Table rightKeys,
boolean compareNullsEqual)
Computes the gather maps that can be used to manifest the result of an full equi-join between
two tables.
|
GatherMap[] |
Table.innerDistinctJoinGatherMaps(Table rightKeys,
boolean compareNullsEqual)
Computes the gather maps that can be used to manifest the result of an inner equi-join between
two tables where the right table is guaranteed to not contain any duplicated join keys.
|
GatherMap[] |
Table.innerJoinGatherMaps(Table rightKeys,
boolean compareNullsEqual)
Computes the gather maps that can be used to manifest the result of an inner equi-join between
two tables.
|
GatherMap |
Table.leftAntiJoinGatherMap(Table rightKeys,
boolean compareNullsEqual)
Computes the gather map that can be used to manifest the result of a left anti-join between
two tables.
|
GatherMap |
Table.leftDistinctJoinGatherMap(Table rightKeys,
boolean compareNullsEqual)
Computes a gather map that can be used to manifest the result of a left equi-join between
two tables where the right table is guaranteed to not contain any duplicated join keys.
|
GatherMap[] |
Table.leftJoinGatherMaps(Table rightKeys,
boolean compareNullsEqual)
Computes the gather maps that can be used to manifest the result of a left equi-join between
two tables.
|
GatherMap |
Table.leftSemiJoinGatherMap(Table rightKeys,
boolean compareNullsEqual)
Computes the gather map that can be used to manifest the result of a left semi-join between
two tables.
|
ColumnVector |
Table.lowerBound(boolean[] areNullsSmallest,
Table valueTable,
boolean[] descFlags)
Find smallest indices in a sorted table where values should be inserted to maintain order.
|
ColumnVector |
Table.lowerBound(Table valueTable,
OrderByArg... args)
Find smallest indices in a sorted table where values should be inserted to maintain order.
|
static Table |
Table.merge(Table[] tables,
OrderByArg... args)
Merge multiple already sorted tables keeping the sort order the same.
|
static GatherMap[] |
Table.mixedFullJoinGatherMaps(Table leftKeys,
Table rightKeys,
Table leftConditional,
Table rightConditional,
CompiledExpression condition,
NullEquality nullEquality)
Computes the gather maps that can be used to manifest the result of a full join between
two tables using a mix of equality and inequality conditions.
|
static GatherMap[] |
Table.mixedInnerJoinGatherMaps(Table leftKeys,
Table rightKeys,
Table leftConditional,
Table rightConditional,
CompiledExpression condition,
NullEquality nullEquality)
Computes the gather maps that can be used to manifest the result of an inner join between
two tables using a mix of equality and inequality conditions.
|
static GatherMap[] |
Table.mixedInnerJoinGatherMaps(Table leftKeys,
Table rightKeys,
Table leftConditional,
Table rightConditional,
CompiledExpression condition,
NullEquality nullEquality,
MixedJoinSize joinSize)
Computes the gather maps that can be used to manifest the result of an inner join between
two tables using a mix of equality and inequality conditions.
|
static MixedJoinSize |
Table.mixedInnerJoinSize(Table leftKeys,
Table rightKeys,
Table leftConditional,
Table rightConditional,
CompiledExpression condition,
NullEquality nullEquality)
Computes output size information for an inner join between two tables using a mix of equality
and inequality conditions.
|
static GatherMap |
Table.mixedLeftAntiJoinGatherMap(Table leftKeys,
Table rightKeys,
Table leftConditional,
Table rightConditional,
CompiledExpression condition,
NullEquality nullEquality)
Computes the gather map that can be used to manifest the result of a left anti join between
two tables using a mix of equality and inequality conditions.
|
static GatherMap[] |
Table.mixedLeftJoinGatherMaps(Table leftKeys,
Table rightKeys,
Table leftConditional,
Table rightConditional,
CompiledExpression condition,
NullEquality nullEquality)
Computes the gather maps that can be used to manifest the result of a left join between
two tables using a mix of equality and inequality conditions.
|
static GatherMap[] |
Table.mixedLeftJoinGatherMaps(Table leftKeys,
Table rightKeys,
Table leftConditional,
Table rightConditional,
CompiledExpression condition,
NullEquality nullEquality,
MixedJoinSize joinSize)
Computes the gather maps that can be used to manifest the result of a left join between
two tables using a mix of equality and inequality conditions.
|
static MixedJoinSize |
Table.mixedLeftJoinSize(Table leftKeys,
Table rightKeys,
Table leftConditional,
Table rightConditional,
CompiledExpression condition,
NullEquality nullEquality)
Computes output size information for a left join between two tables using a mix of equality
and inequality conditions.
|
static GatherMap |
Table.mixedLeftSemiJoinGatherMap(Table leftKeys,
Table rightKeys,
Table leftConditional,
Table rightConditional,
CompiledExpression condition,
NullEquality nullEquality)
Computes the gather map that can be used to manifest the result of a left semi join between
two tables using a mix of equality and inequality conditions.
|
Table |
Table.scatter(ColumnView scatterMap,
Table target)
Scatters values from the source table into the target table out-of-place, returning a new
result table.
|
static Table |
Table.scatter(Scalar[] source,
ColumnView scatterMap,
Table target)
Scatters values from the source rows into the target table out-of-place, returning a new result
table.
|
ColumnVector |
Table.upperBound(boolean[] areNullsSmallest,
Table valueTable,
boolean[] descFlags)
Find largest indices in a sorted table where values should be inserted to maintain order.
|
ColumnVector |
Table.upperBound(Table valueTable,
OrderByArg... args)
Find largest indices in a sorted table where values should be inserted to maintain order.
|
abstract void |
TableWriter.write(Table table)
Write out a table.
|
static void |
JCudfSerialization.writeToStream(Table t,
OutputStream out,
long rowOffset,
long numRows)
Write all or part of a table out in an internal format.
|
| Modifier and Type | Method and Description |
|---|---|
static Table |
Table.merge(List<Table> tables,
OrderByArg... args)
Merge multiple already sorted tables keeping the sort order the same.
|
| Constructor and Description |
|---|
HashJoin(Table buildKeys,
boolean compareNulls)
Construct a hash table for a join from a table representing the join key columns from the
right-side table in the join.
|
| Modifier and Type | Method and Description |
|---|---|
ColumnVector |
CompiledExpression.computeColumn(Table table)
Compute a new column by applying this AST expression to the specified table.
|
Copyright © 2024. All rights reserved.