DataPath.h File Reference

#include <NMSTL/callback>
#include <NMSTL/thread>
#include <NMSTL/tqueue>
#include <NMSTL/netioevent>
#include <NMSTL/serial>
#include "runtime/AuroraNode.h"
#include "Exceptions.h"
#include "MTuple.h"
#include "StreamState.h"
#include "DataHandler.h"
#include "Recovery.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>

Go to the source code of this file.Go to the history log for this file.

Classes
class	DataPath
	This class handles all data inputs and outputs. More...
class	DataPath::EnqueueThread
	Accepts new incoming data connections (i.e., new input streams) The EnqueueThread receives input events on each input stream and pushes these events to Aurora.
class	DataPath::DequeueThread
	Grabs events from Aurora and hands them over to the FastDequeueForwarder.
class	DataPath::FastDequeueForwarder
	Forwards tuples from Aurora to destinations.
class	DataPath::FastDequeueForwarder::ForwardHandler
	Handler to attach to event loop. More...
Variables
	BOREALIS_NAMESPACE_BEGIN
	BOREALIS_NAMESPACE_END

---

Variable Documentation

BOREALIS_NAMESPACE_BEGIN

BOREALIS_NAMESPACE_END

---