Contents

Class PartwiseJoin

Inheritance Relationships

Base Type

Class Documentation

class ral::batch::PartwiseJoin : public ral::cache::kernel

Public Functions

PartwiseJoin(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()
std::unique_ptr<ral::frame::BlazingTable> join_set(const ral::frame::BlazingTableView &table_left, const ral::frame::BlazingTableView &table_right)
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.

std::string get_join_type()
Class PartitionSingleNodeKernel Class Print