Package | Description |
---|---|
ai.rapids.cudf | |
ai.rapids.cudf.ast |
Modifier and Type | Field and Description |
---|---|
static DType |
DType.BOOL8 |
DType |
JCudfSerialization.SerializedColumnHeader.dtype |
static DType |
DType.DURATION_DAYS |
static DType |
DType.DURATION_MICROSECONDS |
static DType |
DType.DURATION_MILLISECONDS |
static DType |
DType.DURATION_NANOSECONDS |
static DType |
DType.DURATION_SECONDS |
static DType |
DType.EMPTY |
static DType |
DType.FLOAT32 |
static DType |
DType.FLOAT64 |
static DType |
DType.INT16 |
static DType |
DType.INT32 |
static DType |
DType.INT64 |
static DType |
DType.INT8 |
static DType |
DType.LIST |
static DType |
DType.STRING |
static DType |
DType.STRUCT |
static DType |
DType.TIMESTAMP_DAYS |
static DType |
DType.TIMESTAMP_MICROSECONDS |
static DType |
DType.TIMESTAMP_MILLISECONDS |
static DType |
DType.TIMESTAMP_NANOSECONDS |
static DType |
DType.TIMESTAMP_SECONDS |
protected DType |
ColumnView.type |
protected DType |
HostColumnVectorCore.type |
static DType |
DType.UINT16 |
static DType |
DType.UINT32 |
static DType |
DType.UINT64 |
static DType |
DType.UINT8 |
Modifier and Type | Method and Description |
---|---|
static DType |
DType.create(DType.DTypeEnum dt)
Factory method for non-decimal DType instances.
|
static DType |
DType.create(DType.DTypeEnum dt,
int scale)
Factory method specialized for decimal DType instances.
|
static DType |
DecimalUtils.createDecimalType(int precision,
int scale)
Creates a cuDF decimal type with precision and scale
|
static DType |
DType.fromJavaBigDecimal(BigDecimal dec)
Create decimal-like DType using precision and scale of Java BigDecimal.
|
static DType |
DType.fromNative(int nativeId,
int scale)
Factory method for DType instances
|
DType[] |
Schema.getChildTypes()
Get types of the top level child columns in schema.
|
DType[] |
Schema.getFlattenedTypes()
Get the types of the columns in schema flattened from all levels by depth-first traversal.
|
DType |
JCudfSerialization.SerializedColumnHeader.getType()
Get the data type of the column
|
DType |
Schema.getType() |
DType |
Scalar.getType() |
DType |
BinaryOperable.getType()
Get the type of this data.
|
DType |
ColumnView.getType() |
DType |
HostColumnVectorCore.getType()
Returns the type of this vector.
|
abstract DType |
HostColumnVector.DataType.getType() |
DType |
HostColumnVector.ListType.getType() |
DType |
HostColumnVector.StructType.getType() |
DType |
HostColumnVector.BasicType.getType() |
static DType |
BinaryOperable.implicitConversion(BinaryOp op,
BinaryOperable lhs,
BinaryOperable rhs)
Finds the proper DType for an implicit output.
|
Modifier and Type | Method and Description |
---|---|
default ColumnVector |
BinaryOperable.add(BinaryOperable rhs,
DType outType)
Add one vector to another with the given output type.
|
Schema.Builder |
Schema.Builder.addColumn(DType type,
String name)
Add a new column
|
Scalar |
ColumnView.all(DType outType)
Deprecated.
the only output type supported is BOOL8.
|
default ColumnVector |
BinaryOperable.and(BinaryOperable rhs,
DType outType)
Logical and (&&) with the given output type.
|
Scalar |
ColumnView.any(DType outType)
Returns a scalar is true or 1, depending on the specified type,
if any of the elements in the column are true or non-zero
otherwise false or 0.
|
default ColumnVector |
BinaryOperable.arctan2(BinaryOperable xCoordinate,
DType outType)
The function arctan2(y,x) or atan2(y,x) is defined as the angle in the Euclidean plane, given
in radians, between the positive x axis and the ray to the point (x, y) ≠ (0, 0).
|
ColumnVector |
ColumnView.asTimestamp(DType timestampType,
String format)
Parse a string to a timestamp.
|
ColumnVector |
Scalar.binaryOp(BinaryOp op,
BinaryOperable rhs,
DType outType) |
ColumnVector |
BinaryOperable.binaryOp(BinaryOp op,
BinaryOperable rhs,
DType outType)
Multiple different binary operations.
|
ColumnVector |
ColumnView.binaryOp(BinaryOp op,
BinaryOperable rhs,
DType outType)
Multiple different binary operations.
|
default ColumnVector |
BinaryOperable.bitAnd(BinaryOperable rhs,
DType outType)
Bit wise and (&) with the given output type.
|
ColumnView |
ColumnView.bitCastTo(DType type)
Zero-copy cast between types with the same underlying length.
|
default ColumnVector |
BinaryOperable.bitOr(BinaryOperable rhs,
DType outType)
Bit wise or (|) with the given output type.
|
default ColumnVector |
BinaryOperable.bitXor(BinaryOperable rhs,
DType outType)
Bit wise xor (^) with the given output type.
|
static ColumnVector |
ColumnVector.build(DType type,
int rows,
java.util.function.Consumer<HostColumnVector.Builder> init)
Create a new vector.
|
static HostColumnVector |
HostColumnVector.build(DType type,
int rows,
java.util.function.Consumer<HostColumnVector.Builder> init)
Create a new vector.
|
static HostColumnVector.Builder |
HostColumnVector.builder(DType type,
int rows)
Create a new Builder to hold the specified number of rows.
|
ColumnVector |
ColumnView.castTo(DType type)
Generic method to cast ColumnVector
When casting from a Date, Timestamp, or Boolean to a numerical type the underlying numerical
representation of the data will be used for the cast.
|
ColumnVector |
ColumnVector.castTo(DType type)
Generic method to cast ColumnVector
When casting from a Date, Timestamp, or Boolean to a numerical type the underlying numerical
representation of the data will be used for the cast.
|
Schema.Builder |
Schema.Builder.column(DType type,
String name)
Adds a single column to the current schema.
|
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 ColumnVector |
ColumnVector.decimalFromDoubles(DType type,
RoundingMode mode,
double... values)
Create a new decimal vector from double floats with specific DecimalType and RoundingMode.
|
static HostColumnVector |
HostColumnVector.decimalFromDoubles(DType type,
RoundingMode mode,
double... values)
Create a new decimal vector from double floats with specific DecimalType and RoundingMode.
|
default ColumnVector |
BinaryOperable.div(BinaryOperable rhs,
DType outType)
Divide one vector by another with the given output type.
|
static Scalar |
Scalar.durationFromLong(DType type,
long value)
Returns a duration scalar based on the type parameter.
|
static Scalar |
Scalar.durationFromLong(DType type,
Long value)
Returns a duration scalar based on the type parameter.
|
default ColumnVector |
BinaryOperable.equalTo(BinaryOperable rhs,
DType outType)
this == rhs 1 is true 0 is false with the output cast to the given type.
|
default ColumnVector |
BinaryOperable.equalToNullAware(BinaryOperable rhs,
DType outType)
like equalTo but NULL == NULL is TRUE and NULL == not NULL is FALSE
|
static ColumnVector |
Aggregation128Utils.extractInt32Chunk(ColumnView col,
DType outType,
int chunkIdx)
Extract a 32-bit chunk from a 128-bit value.
|
default ColumnVector |
BinaryOperable.floorDiv(BinaryOperable rhs,
DType outType)
Divide one vector by another and calculate the floor of the result with the given output type.
|
static ColumnVector |
ColumnVector.fromArrow(DType type,
long numRows,
long nullCount,
ByteBuffer data,
ByteBuffer validity,
ByteBuffer offsets)
Create a ColumnVector from the Apache Arrow byte buffers passed in.
|
static Scalar |
Scalar.fromDecimal(BigInteger unscaledValue,
DType dt) |
static ColumnView |
ColumnView.fromDeviceBuffer(BaseDeviceMemoryBuffer buffer,
long startOffset,
DType type,
int rows)
Create a new column view from a raw device buffer.
|
static Scalar |
Scalar.fromNull(DType type) |
default ColumnVector |
BinaryOperable.greaterOrEqualTo(BinaryOperable rhs,
DType outType)
this >= rhs 1 is true 0 is false with the output cast to the given type.
|
default ColumnVector |
BinaryOperable.greaterThan(BinaryOperable rhs,
DType outType)
this > rhs 1 is true 0 is false with the output cast to the given type.
|
ColumnVector |
ColumnView.isFixedPoint(DType decimalType)
Returns a Boolean vector with the same number of rows as this instance, that has
TRUE for any entry that is a fixed-point, and FALSE if its not a fixed-point.
|
ColumnVector |
ColumnView.isInteger(DType intType)
Returns a Boolean vector with the same number of rows as this instance, that has
TRUE for any entry that is an integer, and FALSE if its not an integer.
|
default ColumnVector |
BinaryOperable.lessOrEqualTo(BinaryOperable rhs,
DType outType)
this <= rhs 1 is true 0 is false with the output cast to the given type.
|
default ColumnVector |
BinaryOperable.lessThan(BinaryOperable rhs,
DType outType)
this < rhs 1 is true 0 is false with the output cast to the given type.
|
ColumnVector |
ColumnView.listReduce(SegmentedReductionAggregation aggregation,
DType outType)
Do a reduction on the values in a list.
|
ColumnVector |
ColumnView.listReduce(SegmentedReductionAggregation aggregation,
NullPolicy nullPolicy,
DType outType)
Do a reduction on the values in a list.
|
default ColumnVector |
BinaryOperable.log(BinaryOperable rhs,
DType outType)
Calculate the log with the specified base
|
ColumnView |
ColumnView.logicalCastTo(DType type)
Deprecated.
this has changed to bit_cast in C++ so use that name instead
|
static ColumnVector |
ColumnVector.makeList(long rows,
DType type,
ColumnView... columns)
Create a LIST column from the given columns.
|
Scalar |
ColumnView.max(DType outType)
Deprecated.
the max reduction no longer internally allows for setting the output type, as a
work around this API will cast the input type to the output type for you, but this may not
work in all cases.
|
default ColumnVector |
BinaryOperable.maxNullAware(BinaryOperable rhs,
DType outType)
Returns the max non null value.
|
Scalar |
ColumnView.mean(DType outType)
Returns the arithmetic mean of all values in the column, returning a
scalar of the specified type.
|
Scalar |
ColumnView.min(DType outType)
Deprecated.
the min reduction no longer internally allows for setting the output type, as a
work around this API will cast the input type to the output type for you, but this may not
work in all cases.
|
default ColumnVector |
BinaryOperable.minNullAware(BinaryOperable rhs,
DType outType)
Returns the min non null value.
|
default ColumnVector |
BinaryOperable.mod(BinaryOperable rhs,
DType outType)
Compute the modulus with the given output type.
|
default ColumnVector |
BinaryOperable.mul(BinaryOperable rhs,
DType outType)
Multiply two vectors together with the given output type.
|
default ColumnVector |
BinaryOperable.notEqualTo(BinaryOperable rhs,
DType outType)
this != rhs 1 is true 0 is false with the output cast to the given type.
|
default ColumnVector |
BinaryOperable.notEqualToNullAware(BinaryOperable rhs,
DType outType)
like notEqualTo but NULL != NULL is TRUE and NULL != not NULL is FALSE
|
default ColumnVector |
BinaryOperable.or(BinaryOperable rhs,
DType outType)
Logical or (||) with the given output type.
|
default ColumnVector |
BinaryOperable.pmod(BinaryOperable rhs,
DType outputType)
Returns the positive value of lhs mod rhs.
|
default ColumnVector |
BinaryOperable.pow(BinaryOperable rhs,
DType outType)
Compute the power with the given output type.
|
Scalar |
ColumnView.product(DType outType)
Returns the product of all values in the column, returning a scalar
of the specified type.
|
Scalar |
ColumnView.reduce(ReductionAggregation aggregation,
DType outType)
Computes the reduction of the values in all rows of a column.
|
ColumnVector |
ColumnView.segmentedReduce(ColumnView offsets,
SegmentedReductionAggregation aggregation,
DType outType)
Do a segmented reduce where the offsets column indicates which groups in this to combine.
|
ColumnVector |
ColumnView.segmentedReduce(ColumnView offsets,
SegmentedReductionAggregation aggregation,
NullPolicy nullPolicy,
DType outType)
Do a segmented reduce where the offsets column indicates which groups in this to combine.
|
default ColumnVector |
BinaryOperable.shiftLeft(BinaryOperable shiftBy,
DType outType)
Bitwise left shifts the values of this vector by shiftBy.
|
default ColumnVector |
BinaryOperable.shiftRight(BinaryOperable shiftBy,
DType outType)
Bitwise right shift this vector by the shiftBy.
|
default ColumnVector |
BinaryOperable.shiftRightUnsigned(BinaryOperable shiftBy,
DType outType)
This method bitwise right shifts the values of this vector by the shiftBy.
|
Scalar |
ColumnView.standardDeviation(DType outType)
Returns the sample standard deviation of all values in the column,
returning a scalar of the specified type.
|
default ColumnVector |
BinaryOperable.sub(BinaryOperable rhs,
DType outType)
Subtract one vector from another with the given output type.
|
Scalar |
ColumnView.sum(DType outType)
Computes the sum of all values in the column, returning a scalar
of the specified type.
|
Scalar |
ColumnView.sumOfSquares(DType outType)
Returns the sum of squares of all values in the column, returning a
scalar of the specified type.
|
static Scalar |
Scalar.timestampFromLong(DType type,
long value) |
static Scalar |
Scalar.timestampFromLong(DType type,
Long value) |
default ColumnVector |
BinaryOperable.trueDiv(BinaryOperable rhs,
DType outType)
Divide one vector by another converting to FLOAT64 in between with the given output type.
|
Scalar |
ColumnView.variance(DType outType)
Returns the variance of all values in the column, returning a
scalar of the specified type.
|
ORCOptions.Builder |
ORCOptions.Builder.withTimeUnit(DType unit)
Specify the time unit to use when returning timestamps.
|
ParquetOptions.Builder |
ParquetOptions.Builder.withTimeUnit(DType unit)
Specify the time unit to use when returning timestamps.
|
Constructor and Description |
---|
BasicType(boolean isNullable,
DType type) |
ColumnVector(DType type,
long rows,
Optional<Long> nullCount,
DeviceMemoryBuffer dataBuffer,
DeviceMemoryBuffer validityBuffer,
DeviceMemoryBuffer offsetBuffer)
Create a new column vector based off of data already on the device.
|
ColumnVector(DType type,
long rows,
Optional<Long> nullCount,
DeviceMemoryBuffer dataBuffer,
DeviceMemoryBuffer validityBuffer,
DeviceMemoryBuffer offsetBuffer,
List<DeviceMemoryBuffer> toClose,
long[] childHandles)
Create a new column vector based off of data already on the device with child columns.
|
ColumnView(DType type,
long rows,
Optional<Long> nullCount,
BaseDeviceMemoryBuffer dataBuffer,
BaseDeviceMemoryBuffer validityBuffer)
Create a new column view based off of data already on the device.
|
ColumnView(DType type,
long rows,
Optional<Long> nullCount,
BaseDeviceMemoryBuffer dataBuffer,
BaseDeviceMemoryBuffer validityBuffer,
BaseDeviceMemoryBuffer offsetBuffer)
Create a new column view based off of data already on the device.
|
ColumnView(DType type,
long rows,
Optional<Long> nullCount,
BaseDeviceMemoryBuffer validityBuffer,
BaseDeviceMemoryBuffer offsetBuffer,
ColumnView[] children)
Create a new column view based off of data already on the device.
|
HostColumnVector(DType type,
long rows,
Optional<Long> nullCount,
HostMemoryBuffer hostDataBuffer,
HostMemoryBuffer hostValidityBuffer,
HostMemoryBuffer offsetBuffer,
List<HostColumnVectorCore> nestedHcv)
Create a new column vector with data populated on the host.
|
HostColumnVectorCore(DType type,
long rows,
Optional<Long> nullCount,
HostMemoryBuffer data,
HostMemoryBuffer validity,
HostMemoryBuffer offsets,
List<HostColumnVectorCore> nestedChildren) |
Modifier and Type | Method and Description |
---|---|
static Literal |
Literal.ofDurationFromLong(DType type,
long value)
Construct a long-based duration literal with the specified value.
|
static Literal |
Literal.ofDurationFromLong(DType type,
Long value)
Construct a long-based duration literal with the specified value or null.
|
static Literal |
Literal.ofNull(DType type)
Construct a null literal of the specified type.
|
static Literal |
Literal.ofTimestampFromLong(DType type,
long value)
Construct a long-based timestamp literal with the specified value.
|
static Literal |
Literal.ofTimestampFromLong(DType type,
Long value)
Construct a long-based timestamp literal with the specified value or null.
|
Copyright © 2024. All rights reserved.