Inheritance diagram for JEventMapArrow:

Collaboration diagram for JEventMapArrow:

Public Member Functions
	JEventMapArrow (std::string name)

void	add_source (JEventSource *source)

void	add_unfolder (JEventUnfolder *unfolder)

void	add_processor (JEventProcessor *proc)

void	process (std::shared_ptr< JEvent > *event, bool &success, JArrowMetrics::Status &status)

void	initialize () final

void	finalize () final

Public Member Functions inherited from JPipelineArrow< JEventMapArrow >
	JPipelineArrow (std::string name, bool is_parallel, bool is_source, bool is_sink)

void	set_input (JMailbox< MessageT * > *queue)

void	set_input (JEventPool *pool)

void	set_output (JMailbox< MessageT * > *queue)

void	set_output (JEventPool *pool)

void	execute (JArrowMetrics &result, size_t location_id) final

Public Member Functions inherited from JArrow
std::string	get_name ()

JLogger &	get_logger ()

bool	is_parallel ()

bool	is_source ()

bool	is_sink ()

JArrowMetrics &	get_metrics ()

void	set_name (std::string name)

void	set_logger (JLogger logger)

void	set_is_parallel (bool is_parallel)

void	set_is_source (bool is_source)

void	set_is_sink (bool is_sink)

	JArrow (std::string name, bool is_parallel, bool is_source, bool is_sink)

virtual size_t	get_pending ()

void	attach (JArrow *downstream)

void	attach (Place *place)

Additional Inherited Members
Protected Attributes inherited from JArrow
JLogger	m_logger

std::vector< Place * >	m_places

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

Public Member Functions

Additional Inherited Members