.rst .pdf

Contents

Class PartitionKernel

• Defined in File BatchOrderByProcessing.h

Inheritance Relationships

Base Type

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

Class Documentation

class ral::batch::PartitionKernel : public ral::cache::distributing_kernel

Public Functions

PartitionKernel(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() 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 OverlapGeneratorKernel Class PartitionSingleNodeKernel