Theme by the Executable Book Project

Class ComputeAggregateKernel¶

Defined in File BatchAggregationProcessing.h

Inheritance Relationships¶

Base Type¶

public ral::cache::kernel (Class kernel)

Class Documentation¶

class ral::batch::ComputeAggregateKernel : public ral::cache::kernel ¶

Public Functions

ComputeAggregateKernel(std::size_t kernel_id, const std::string &queryString, std::shared_ptr<Context> context, std::shared_ptr<ral::cache::graph> query_graph)¶

inline virtual std::string kernel_name()¶

ral::execution::task_result do_process(std::vector<std::unique_ptr<ral::frame::BlazingTable>> inputs, std::shared_ptr<ral::cache::CacheMachine> output, cudaStream_t stream, const std::map<std::string, std::string> &args) override¶

virtual kstatus run()¶

Executes the batch processing. Loads the data from their input port, and after processing it, the results are stored in their output port.

Return: kstatus ‘stop’ to halt processing, or ‘proceed’ to continue processing.

virtual std::pair<bool, uint64_t> get_estimated_output_num_rows()¶: Returns the estimated num_rows for the output, the default is that its the same as the input (i.e. project, sort, …).

Class BindableTableScan Class ComputeWindowKernel