* @brief Returns the kernel type identifier. * * @return kernel_type The kernel type identifier. */

Feeds an input cache with time delays

Just creates a Context

Creates a ProjectKernel using a valid `project_plan`

* Get a message_ptr if it exists in the WaitingQueue else wait. * This function allows kernels to pull from the cache before a cache has * CacheData

Creates two CacheMachines and register them with the `project_kernel`

Calcite by default returns units in milliseconds, as we are getting a TIMESTAMP_NANOSECONDS from BLZ_TO_TIMESTAMP, we want to convert these to nanosec

input: LogicalProject(sum_max_prices=[$0], o_orderkey=[$1], o_min_prices=[$2]]) output: sum_max_prices=[$0], o_orderkey=[$1], o_min_prices=[$2]]

* Gets the type of CacheData that was used to construct this CacheData * @return The CacheDataType that is used to store the dataframe representation

Creates a OverlapAccumulatorKernel using a valid `project_plan`

* Mark a function for special use by Sizzle * @param {Function} fn The function to mark

This function will take a join_statement and if it contains anything that is not an equijoin, it will try to break it up into an equijoin (new_join_st

input: AND(=($0, $3), IS_NOT_DISTINCT_FROM($1, $3)) output: ["=($0, $3)" , "OR(AND(IS NULL($1), IS NULL($3)), IS TRUE(=($1 , $3)))"]

Creates two CacheMachines and register them with the `project_kernel`

arrow::Status S3ReadableFile::Read(int64_t nbytes, int64_t * bytesRead, void * buffer) {

simple_log: true (no timestamp or log level)

* Checks if the WaitingQueue is empty. * @return A bool indicating if the WaitingQueue is empty. */

* Get the cudf::data_type of each column. * @return a vector of the cudf::data_type of each column. */