Theme by the Executable Book Project

Class DistributeAggregateKernel¶

Defined in File BatchAggregationProcessing.h

Inheritance Relationships¶

Base Type¶

public ral::cache::distributing_kernel (Class distributing_kernel)

Class Documentation¶

class ral::batch::DistributeAggregateKernel : public ral::cache::distributing_kernel ¶

Public Functions

DistributeAggregateKernel(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.

Class ComputeWindowKernel Class Filter