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

  • 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.

  • 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.


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.


true A new message is ready.


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.


true There is at least one message in the queue.


false Message queue is empty.