DataPath Class Reference

#include <DataPath.h>

List of all members.

---

Detailed Description

This class handles all data inputs and outputs.

It listens for incoming streams of tuples and pushes incoming tuples to the processing engine It gets tuples from the engine and forwards them to all subscribed clients

Public Member Functions
	DataPath (AuroraNode &node, InetAddress data_add, bool m_no_dups=false)
	~DataPath ()
void	init ()
void	stop_enqueue ()
vector< pair< ptr< StreamState >, string > >	last_input_tuples ()
vector< pair< ptr< StreamState >, string > >	last_output_tuples ()
vector< StreamEvent >	checkpoint_tuples ()
void	set_recovery_method (RecoveryMethod method)
	Set the recovery method.
RecoveryMethod	get_recovery_method ()
void	set_primary_status (bool status)
	Change the status to primary (if true) or to secondary (if false).
bool	is_primary ()
void	suspend_dequeue ()
	Suspends all dequeueing activity.
void	resume_dequeue ()
	Allow all dequeueing activity again.
void	add_input_path (ptr< StreamState > str)
bool	is_input_path (ptr< StreamState > str)
void	remove_input_path (ptr< StreamState > str)
string	update_input_path (Name stream_name, StreamDef &sd)
	Get a long on all input streams so we can not enqueue anything while swapping the input stream.
void	add_output_path (ptr< StreamState > str)
void	remove_output_path (ptr< StreamState > str)
void	set_data_path (Name stream_name, MedusaID fast_dst, bool with_history, string first_tuple)
void	close_data_path (Name stream_name, MedusaID fast_dst)
Status	send_downstream (vector< StreamEvent > &events_to_send)
	Send downstream a specific set of stream events.
void	update (StreamEvent &stream_event)
	Updates output streams with given stream events.
void	update (StreamID stream_id, string last_tuple)
	Trims output streams up to given event.
void	subscribe_cb (Name stream_name, DataHandler::DHCallback cb)
	Lets a local callback get output tuples.
void	enqueue (ptr< StreamEvent > event)
	Enqueue a stream event originating at this node.
Public Attributes
Mutex	m_aurora_lock

---

Constructor & Destructor Documentation

DataPath::DataPath (  AuroraNode &  node, InetAddress  data_add, bool  m_no_dups = false )

DataPath::~DataPath (   )

---

Member Function Documentation

void DataPath::add_input_path (  ptr< StreamState >  str  )

void DataPath::add_output_path (  ptr< StreamState >  str  )

vector< StreamEvent > DataPath::checkpoint_tuples (   )

Returns: For each output stream, return the StreamEvent that represents all the tuples that need to be checkpointed

void DataPath::close_data_path (  Name  stream_name, MedusaID  fast_dst )

void DataPath::enqueue (  ptr< StreamEvent >  event  )

Enqueue a stream event originating at this node.

RecoveryMethod DataPath::get_recovery_method (   )

Returns: the recovery method

void DataPath::init (   )

bool DataPath::is_input_path (  ptr< StreamState >  str  )

bool DataPath::is_primary (   )

Returns: primary status of this query processor

vector< pair< ptr< StreamState >, string > > DataPath::last_input_tuples (   )

Returns: pairs mapping input streams to the last tuple that was enqueued on that stream

vector< pair< ptr< StreamState >, string > > DataPath::last_output_tuples (   )

Returns: pairs mapping output streams to the last tuple that was enqueued on that stream

void DataPath::remove_input_path (  ptr< StreamState >  str  )

void DataPath::remove_output_path (  ptr< StreamState >  str  )

void DataPath::resume_dequeue (   )

Allow all dequeueing activity again.

Status DataPath::send_downstream (  vector< StreamEvent > &  events_to_send  )

Send downstream a specific set of stream events. These events are typically those that we have checkpointed with our secondary

void DataPath::set_data_path (  Name  stream_name, MedusaID  fast_dst, bool  with_history, string  first_tuple )

void DataPath::set_primary_status (  bool  status  )

Change the status to primary (if true) or to secondary (if false).

void DataPath::set_recovery_method (  RecoveryMethod  method  )

Set the recovery method.

void DataPath::stop_enqueue (   )

void DataPath::subscribe_cb (  Name  stream_name, DataHandler::DHCallback  cb )

Lets a local callback get output tuples.

void DataPath::suspend_dequeue (   )

Suspends all dequeueing activity.

void DataPath::update (  StreamID  stream_id, string  last_tuple )

Trims output streams up to given event.

void DataPath::update (  StreamEvent &  stream_event  )

Updates output streams with given stream events.

string DataPath::update_input_path (  Name  stream_name, StreamDef &  new_sd )

Get a long on all input streams so we can not enqueue anything while swapping the input stream. Replace the definition of the stream and return that last input tuple on the old stream

---

Member Data Documentation

Mutex DataPath::m_aurora_lock

---

The documentation for this class was generated from the following files:

• DataPath.h
• DataPath.cc

---