Theme by the Executable Book Project

Class SortAndSampleKernel¶

Defined in File BatchOrderByProcessing.h

Inheritance Relationships¶

Base Type¶

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

Class Documentation¶

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

Public Functions

SortAndSampleKernel(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()¶

bool all_node_samples_are_available()¶

void make_partition_plan_task()¶

void compute_partition_plan(std::vector<std::unique_ptr<ral::frame::BlazingTable>> inputSamples)¶

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() override¶

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 Projection Class TableScan