Method pullCacheData

engine/src/cache_machine/CacheMachine.cpp:528–556

std::unique_ptr<ral::cache::CacheData> CacheMachine::pullCacheData(std::string message_id) {
    CodeTimer cacheEventTimer;
    cacheEventTimer.start();

	std::unique_ptr<message> message_data = waitingCache->get_or_wait(message_id);
	if (message_data == nullptr) {
		return nullptr;
	}
    size_t num_rows = message_data->get_data().num_rows();
    size_t num_bytes = message_data->get_data().sizeInBytes();
    int dataType = static_cast<int>(message_data->get_data().get_type());
	std::unique_ptr<ral::cache::CacheData> output = message_data->release_data();

    cacheEventTimer.stop();
    if(cache_events_logger) {
        cache_events_logger->info("{ral_id}|{query_id}|{message_id}|{cache_id}|{num_rows}|{num_bytes}|{event_type}|{timestamp_begin}|{timestamp_end}|{description}",
                                  "ral_id"_a=(ctx ? ctx->getNodeIndex(ral::communication::CommunicationData::getInstance().getSelfNode()) : -1),
                                  "query_id"_a=(ctx ? ctx->getContextToken() : -1),
                                  "message_id"_a=message_id,
                                  "cache_id"_a=cache_id,
                                  "num_rows"_a=num_rows,
                                  "num_bytes"_a=num_bytes,
                                  "event_type"_a="PullCacheData",
                                  "timestamp_begin"_a=cacheEventTimer.start_time(),
                                  "timestamp_end"_a=cacheEventTimer.end_time(),
                                  "description"_a="Pull from CacheMachine CacheData object type {}"_format(dataType));
    }
	return output;
}

std::unique_ptr<ral::frame::BlazingTable> CacheMachine::pullUnorderedFromCache() {
    if (is_array_access) {