#include <API/Schema.hpp>
#include <Configurations/Worker/PhysicalSourceTypes/PhysicalSourceType.hpp>
#include <Identifiers/Identifiers.hpp>
#include <Reconfiguration/ReconfigurationMarker.hpp>
#include <Runtime/Execution/DataEmitter.hpp>
#include <Runtime/QueryTerminationType.hpp>
#include <Runtime/Reconfigurable.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>
#include <Util/GatheringMode.hpp>
#include <atomic>
#include <chrono>
#include <future>
#include <mutex>
#include <optional>
#include <thread>

Include dependency graph for DataSource.hpp:

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

Classes
class	NES::DataSource
	Base class for all data sources in NES we allow only three cases: 1.) If the user specifies a numBuffersToProcess: 1.1) if the source e.g. file is large enough we will read in numBuffersToProcess and then terminate 1.2) if the file is not large enough, we will start at the beginning until we produced numBuffersToProcess 2.) If the user set numBuffersToProcess to 0, we read the source until it ends, e.g, until the file ends 3.) If the user just set numBuffersToProcess to n but does not say how many tuples he wants per buffer, we loop over the source until the buffer is full. 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.

	NES::Runtime::MemoryLayouts

Classes

Namespaces