WorkerContext.hpp File Reference

#include <Network/NetworkForwardRefs.hpp>
#include <Operators/LogicalOperators/Network/NesPartition.hpp>
#include <Runtime/QueryTerminationType.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>
#include <Runtime/TupleBuffer.hpp>
#include <cstdint>
#include <folly/ThreadLocal.h>
#include <future>
#include <memory>
#include <optional>
#include <queue>
#include <unordered_map>

Include dependency graph for WorkerContext.hpp:

This graph shows which files directly or indirectly include this file:

Classes
class	NES::Runtime::WorkerContext
	A WorkerContext represents the current state of a worker thread Note that it is not thread-safe per se but it is meant to be used in a thread-safe manner by the ThreadPool. More...

Namespaces
	NES
	This exception represents a network error.
	NES::Runtime
	Turn this on to have Thread::current_num_threads_ keep a count of currently-active threads.

Typedefs
using	NES::HashOperatorId = std::pair< OperatorId, DecomposedQueryPlanVersion >
using	NES::Runtime::WorkerContextPtr = std::shared_ptr< WorkerContext >