Class ConcatenatingCacheMachine

Inheritance Relationships

Base Type

Class Documentation

class ral::cache::ConcatenatingCacheMachine : public ral::cache::CacheMachine

A class that represents a Cache Machine on a multi-tier cache system. Moreover, it only returns a single BlazingTable by concatenating all batches. This Cache Machine is used in the last Kernel (OutputKernel) in the ExecutionGraph.

This ConcatenatingCacheMachine::pullFromCache method does not guarantee the relative order of the messages to be preserved

Public Functions

ConcatenatingCacheMachine(std::shared_ptr<Context> context, std::string cache_machine_name)
ConcatenatingCacheMachine(std::shared_ptr<Context> context, std::size_t concat_cache_num_bytes, int num_bytes_timeout, bool concat_all, std::string cache_machine_name)
~ConcatenatingCacheMachine() = default
virtual std::unique_ptr<ral::frame::BlazingTable> pullFromCache() override
inline virtual std::unique_ptr<ral::frame::BlazingTable> pullUnorderedFromCache() override
virtual std::unique_ptr<ral::cache::CacheData> pullCacheData() override
inline virtual size_t downgradeCacheData() override