org.bytedeco.gandiva

Class Projector

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.gandiva.Projector

All Implemented Interfaces:

AutoCloseable

@Namespace(value="gandiva")
 @NoOffset
 @Properties(inherit=gandiva.class)
public class Projector
extends Pointer

\brief projection using expressions. A projector is built for a specific schema and vector of expressions. Once the projector is built, it can be used to evaluate many row batches.

Nested Class Summary

Nested classes/interfaces inherited from class org.bytedeco.javacpp.Pointer

Pointer.CustomDeallocator, Pointer.Deallocator, Pointer.NativeDeallocator, Pointer.ReferenceCounter

Field Summary

Fields inherited from class org.bytedeco.javacpp.Pointer

address, capacity, limit, position

Constructor Summary

Constructors

Constructor and Description
Projector(Pointer p) Pointer cast constructor.

Method Summary

Modifier and Type	Method and Description
String	DumpIR()
Status	Evaluate(RecordBatch batch, ArrayDataVector output) Evaluate the specified record batch, and populate the output arrays.
Status	Evaluate(RecordBatch batch, MemoryPool pool, ArrayVector output) Evaluate the specified record batch, and return the allocated and populated output arrays.
Status	Evaluate(RecordBatch batch, SelectionVector selection_vector, ArrayDataVector output) Evaluate the specified record batch, and populate the output arrays at the filtered positions.
Status	Evaluate(RecordBatch batch, SelectionVector selection_vector, MemoryPool pool, ArrayVector output) Evaluate the specified record batch, and return the allocated and populated output arrays.
static Status	Make(Schema schema, Expression exprs, Configuration configuration, Projector projector) Build a projector for the given schema to evaluate the vector of expressions.
static Status	Make(Schema schema, Expression exprs, int selection_vector_mode, Configuration configuration, Projector projector)
static Status	Make(Schema schema, Expression exprs, Projector projector) Build a default projector for the given schema to evaluate the vector of expressions.
static Status	Make(Schema schema, Expression exprs, SelectionVector.Mode selection_vector_mode, Configuration configuration, Projector projector) Build a projector for the given schema to evaluate the vector of expressions.

Methods inherited from class org.bytedeco.javacpp.Pointer

address, asBuffer, asByteBuffer, availablePhysicalBytes, calloc, capacity, capacity, close, deallocate, deallocate, deallocateReferences, deallocator, deallocator, equals, fill, formatBytes, free, getDirectBufferAddress, getPointer, getPointer, getPointer, getPointer, hashCode, interruptDeallocatorThread, isNull, isNull, limit, limit, malloc, maxBytes, maxPhysicalBytes, memchr, memcmp, memcpy, memmove, memset, offsetAddress, offsetof, offsetof, parseBytes, physicalBytes, physicalBytesInaccurate, position, position, put, realloc, referenceCount, releaseReference, retainReference, setNull, sizeof, sizeof, toString, totalBytes, totalCount, totalPhysicalBytes, withDeallocator, zero

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Projector

public Projector(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

Method Detail

Make

@ByVal
public static Status Make(@SharedPtr @ByVal
                                  Schema schema,
                                  @SharedPtr
                                  Expression exprs,
                                  @SharedPtr
                                  Projector projector)

Build a default projector for the given schema to evaluate the vector of expressions.

Parameters:

schema - [in] schema for the record batches, and the expressions.

exprs - [in] vector of expressions.

projector - [out] the returned projector object

Make

@ByVal
public static Status Make(@SharedPtr @ByVal
                                  Schema schema,
                                  @SharedPtr
                                  Expression exprs,
                                  @SharedPtr
                                  Configuration configuration,
                                  @SharedPtr
                                  Projector projector)

Build a projector for the given schema to evaluate the vector of expressions. Customize the projector with runtime configuration.

Parameters:

schema - [in] schema for the record batches, and the expressions.

exprs - [in] vector of expressions.

configuration - [in] run time configuration.

projector - [out] the returned projector object

Make

@ByVal
public static Status Make(@SharedPtr @ByVal
                                  Schema schema,
                                  @SharedPtr
                                  Expression exprs,
                                  SelectionVector.Mode selection_vector_mode,
                                  @SharedPtr
                                  Configuration configuration,
                                  @SharedPtr
                                  Projector projector)

Build a projector for the given schema to evaluate the vector of expressions. Customize the projector with runtime configuration.

Parameters:

schema - [in] schema for the record batches, and the expressions.

exprs - [in] vector of expressions.

selection_vector_mode - [in] mode of selection vector

configuration - [in] run time configuration.

projector - [out] the returned projector object

Make

@ByVal
public static Status Make(@SharedPtr @ByVal
                                  Schema schema,
                                  @SharedPtr
                                  Expression exprs,
                                  @Cast(value="gandiva::SelectionVector::Mode")
                                  int selection_vector_mode,
                                  @SharedPtr
                                  Configuration configuration,
                                  @SharedPtr
                                  Projector projector)

Evaluate

@ByVal
public Status Evaluate(@Const @ByRef
                               RecordBatch batch,
                               MemoryPool pool,
                               ArrayVector output)

Evaluate the specified record batch, and return the allocated and populated output arrays. The output arrays will be allocated from the memory pool 'pool', and added to the vector 'output'.

Parameters:

batch - [in] the record batch. schema should be the same as the one in 'Make'

pool - [in] memory pool used to allocate output arrays (if required).

output - [out] the vector of allocated/populated arrays.

Evaluate

@ByVal
public Status Evaluate(@Const @ByRef
                               RecordBatch batch,
                               @Const @ByRef
                               ArrayDataVector output)

Evaluate the specified record batch, and populate the output arrays. The output arrays of sufficient capacity must be allocated by the caller.

Parameters:

batch - [in] the record batch. schema should be the same as the one in 'Make'

output - [in,out] vector of arrays, the arrays are allocated by the caller and populated by Evaluate.

Evaluate

@ByVal
public Status Evaluate(@Const @ByRef
                               RecordBatch batch,
                               @Const
                               SelectionVector selection_vector,
                               MemoryPool pool,
                               ArrayVector output)

Evaluate the specified record batch, and return the allocated and populated output arrays. The output arrays will be allocated from the memory pool 'pool', and added to the vector 'output'.

Parameters:

batch - [in] the record batch. schema should be the same as the one in 'Make'

selection_vector - [in] selection vector which has filtered row positions.

pool - [in] memory pool used to allocate output arrays (if required).

output - [out] the vector of allocated/populated arrays.

Evaluate

@ByVal
public Status Evaluate(@Const @ByRef
                               RecordBatch batch,
                               @Const
                               SelectionVector selection_vector,
                               @Const @ByRef
                               ArrayDataVector output)

Evaluate the specified record batch, and populate the output arrays at the filtered positions. The output arrays of sufficient capacity must be allocated by the caller.

Parameters:

batch - [in] the record batch. schema should be the same as the one in 'Make'

selection_vector - [in] selection vector which has the filtered row positions

output - [in,out] vector of arrays, the arrays are allocated by the caller and populated by Evaluate.

DumpIR

@StdString
public String DumpIR()