Contents

Class BatchSequence

Class Documentation

class ral::batch::BatchSequence

This is the standard data sequencer that just pulls data from an input cache one batch at a time.

Public Functions

BatchSequence(std::shared_ptr<ral::cache::CacheMachine> cache = nullptr, const ral::cache::kernel *kernel = nullptr, bool ordered = true)

Constructor for the BatchSequence

Parameters

  • cache: The input cache from where the data will be pulled.

  • kernel: The kernel that will actually receive the pulled data.

  • ordered: Indicates whether the order should be kept at data pulling.

void set_source(std::shared_ptr<ral::cache::CacheMachine> cache)

Updates the input cache machine.

Parameters

  • cache: The pointer to the new input cache.

std::unique_ptr<ral::frame::BlazingTable> next()

Get the next message as a unique pointer to a BlazingTable. If there are no more messages on the queue we get a nullptr.

Return

Unique pointer to a BlazingTable containing the next decached message.

bool wait_for_next()

Blocks executing thread until a new message is ready or when the message queue is empty.

Return

true A new message is ready.

Return

false There are no more messages on the cache.

bool has_next_now()

Indicates if the message queue is not empty at this point on time.

Return

true There is at least one message in the queue.

Return

false Message queue is empty.

Class internal_blazing_host_memory_resource Class BatchSequenceBypass