Reduce an iterable collection using a given operator. More...

#include <Dataflow/Core/Functionals/ReduceNode.hpp>

Inheritance diagram for Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >:

Collaboration diagram for Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >:

Public Types
using	ReduceOperator = std::function<v_t( const v_t&, const v_t& )>

Public Types inherited from Ra::Dataflow::Core::Node
using	PortIndex = Ra::Core::Utils::Index

template<typename Port >
using	PortCollection = std::vector<Port>

template<typename Port >
using	PortPtr = std::shared_ptr<Port>

template<typename Port >
using	PortRawPtr = Port*

template<typename Type >
using	PortInPtr = PortPtr<PortIn<Type>>

template<typename Type >
using	PortInRawPtr = PortIn<Type>*

template<typename Type >
using	PortOutPtr = PortPtr<PortOut<Type>>

template<typename Type >
using	PortOutRawPtr = PortOut<Type>*

using	PortBasePtr = PortPtr<PortBase>

using	PortBaseRawPtr = PortRawPtr<PortBase>

using	PortBaseCollection = PortCollection<PortBasePtr>

using	PortBaseInPtr = PortPtr<PortBaseIn>

using	PortBaseInRawPtr = PortRawPtr<PortBaseIn>

using	PortBaseInCollection = PortCollection<PortBaseInPtr>

using	PortBaseOutPtr = PortPtr<PortBaseOut>

using	PortBaseOutRawPtr = PortRawPtr<PortBaseOut>

using	PortBaseOutCollection = PortCollection<PortBaseOutPtr>

template<typename Port >
using	IndexAndPort = std::pair<PortIndex, Port>

template<typename T >
using	ParamHandle = Ra::Core::VariableSet::VariableHandle<T>

Public Member Functions
	ReduceNode (const std::string &instanceName)
	Construct an identity transformer.

	ReduceNode (const std::string &instanceName, ReduceOperator op, v_t initialValue=v_t {})
	Construct a transformer with the given operator.

void	init () override
	Initializes the node content.

bool	execute () override
	Executes the node.

void	set_operator (ReduceOperator op, v_t initialValue=v_t {})
	Sets the operator on the node.

Public Member Functions inherited from Ra::Dataflow::Core::Node
virtual	~Node ()=default
	make Node a base abstract class

bool	operator== (const Node &node)
	Two nodes are considered equal if there model and instance names are the same.

void	add_metadata (const nlohmann::json &data)
	Add a metadata to the node to store application specific information.

const nlohmann::json &	metadata ()
	Give access to extra json data stored on the node.

bool	is_initialized () const

Ra::Core::VariableSet &	parameters ()
	Return node's parameters.

Ra::Core::VariableSet &	input_variables ()
	Return a variable set of input ports default value reference, if any.

bool	is_output ()
	Node is output if none of the output ports is linked.

bool	is_input ()
	Node is input if all input ports have default values and not linked.

	Node (const Node &)=delete

Node &	operator= (const Node &)=delete

virtual bool	compile ()
	Compile the node to check its validity.

virtual void	destroy ()
	Delete the node's content.

auto	port_by_name (const std::string &type, const std::string &name) const -> IndexAndPort< PortBaseRawPtr >
	Get a port by its name.

auto	input_by_name (const std::string &name) const -> IndexAndPort< PortBaseInRawPtr >
	Convenience alias to port_by_name("in", name)

auto	output_by_name (const std::string &name) const -> IndexAndPort< PortBaseOutRawPtr >
	Convenience alias to port_by_name("out", name)

PortBaseRawPtr	port_by_index (const std::string &type, PortIndex index) const
	Get a port by its index.

auto	input_by_index (PortIndex index) const
	Convenience alias to port_by_index("in", index)

auto	output_by_index (PortIndex index) const
	Convenience alias to port_by_index("out", index)

template<typename T >
auto	input_by_index (PortIndex index) const
	Convenience alias with typed port.

template<typename T >
auto	output_by_index (PortIndex index) const
	Convenience alias with typed port.

const PortBaseInCollection &	inputs () const
	Gets the in ports of the node.

const PortBaseOutCollection &	outputs () const
	Gets the out ports of the node.

const std::string &	model_name () const
	Gets the model (type/class) name of the node.

const std::string &	display_name () const
	Gets the display name of the node (e.g. for gui), no need to be unique in a graph.

void	set_display_name (const std::string &name)
	Set the display name.

const std::string &	instance_name () const
	Gets the instance name of the node.

void	set_instance_name (const std::string &name)
	Sets the instance name the node (unused?) instance name must be unique in a graph.

void	toJson (nlohmann::json &data) const
	Serialize the content of the node.

bool	fromJson (const nlohmann::json &data)
	Unserialized the content of the node.

Static Public Member Functions
static const std::string &	node_typename ()

Protected Member Functions
	ReduceNode (const std::string &instanceName, const std::string &typeName, ReduceOperator op, v_t initialValue)

void	toJsonInternal (nlohmann::json &data) const override
	Internal json representation of the Node.

bool	fromJsonInternal (const nlohmann::json &data) override
	Internal json representation of the Node.

Protected Member Functions inherited from Ra::Dataflow::Core::Node
	Node (const std::string &instance, const std::string &typeName)
	Construct the base node given its name and type.

template<typename PortType >
auto	port_by_name (const PortCollection< PortPtr< PortType > > &ports, const std::string &name) const -> IndexAndPort< PortRawPtr< PortType > >
	Gets the Port By Name.

template<typename PortType >
auto	port_base (const PortCollection< PortPtr< PortType > > &ports, PortIndex idx) const -> PortRawPtr< PortType >
	Gets the PortBase In or Out by its index.

template<typename T , typename PortType >
auto	port (const PortCollection< PortPtr< PortType > > &ports, PortIndex index) const
	Gets a port in a collection by its index.

template<typename PortType >
PortIndex	add_port (PortCollection< PortPtr< PortType > > &, PortPtr< PortType > port)
	Adds a port to port collection.

PortIndex	add_input (PortBaseInPtr in)
	Convenience alias to add_port(inputs(), in)

PortIndex	add_output (PortBaseOutPtr out)
	Convenience alias to add_port(outputs(), out)

template<typename T , typename... U>
auto	add_input (U &&... u)
	Adds a typed input port.

template<typename T , typename... U>
auto	add_output (U &&... u)
	Adds a typed output port.

template<typename T >
auto	input_port (PortIndex index)
	Gets a typed (input/output) port.

template<typename T >
auto	output_port (PortIndex index)
	Gets a typed (input/output) port.

void	remove_input (PortIndex index)
	Remove the given port from the managed (input/output) ports.

void	remove_output (PortIndex index)
	Remove the given port from the managed (input/output) ports.

template<typename T >
auto	add_parameter (const std::string &name, const T &value)

template<typename T >
bool	remove_parameter (const std::string &name)

template<typename T >
bool	remove_parameter (ParamHandle< T > &handle)

Additional Inherited Members
Protected Attributes inherited from Ra::Dataflow::Core::Node
bool	m_initialized { false }
	Flag that checks if the node is already initialized.

std::string	m_model_name
	The type name of the node. Initialized once at construction.

std::string	m_instance_name
	The instance name of the node.

std::string	m_display_name { "" }
	Node's name if needed for display.

PortCollection< PortPtr< PortBaseIn > >	m_inputs
	The in ports of the node (own by the node)

PortCollection< PortPtr< PortBaseOut > >	m_outputs
	The out ports of the node (own by the node)

Ra::Core::VariableSet	m_parameters
	The editable parameters of the node.

Ra::Core::VariableSet	m_input_variables

nlohmann::json	m_metadata
	Additional data on the node, added by application or gui or ...

Detailed Description

template<typename coll_t, typename v_t = typename coll_t::value_type>
class Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >

Reduce an iterable collection using a given operator.

Template Parameters

coll_t	the collection to reduce. Must respect the SequenceContainer requirements
v_t	(optional), type of the element in the collection. Default to coll_t::value_type

See also: https://en.cppreference.com/w/cpp/named_req/SequenceContainer

This node has three inputs :

in : port accepting a coll_t data. Linking to this port is mandatory
f : port accepting an operator with profile std::function<v_t( const v_t& )>. Linking to this port is not mandatory, the operator might be set once for the node or is the default value for v_t. If this port is linked, the operator will be taken from the port.
init : port accepting a v_t to serve as initial value. Linking to this port is not mandatory. If this port is linked, the initial value will be taken from the port.

This node has one output :

out : port giving a v_t such that out = std::reduce(in, f, init) (std::accumulate if less than C++17)

Definition at line 33 of file ReduceNode.hpp.

Member Typedef Documentation

◆ ReduceOperator

template<typename coll_t , typename v_t = typename coll_t::value_type>

using Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >::ReduceOperator = std::function<v_t( const v_t&, const v_t& )>

Trasformation operator profile

Definition at line 39 of file ReduceNode.hpp.

Constructor & Destructor Documentation

◆ ReduceNode() [1/3]

template<typename coll_t , typename v_t >

Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >::ReduceNode ( const std::string & instanceName )

explicit

Construct an identity transformer.

Parameters

instanceName

Definition at line 86 of file ReduceNode.hpp.

◆ ReduceNode() [2/3]

template<typename coll_t , typename v_t >

Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >::ReduceNode	(	const std::string &	instanceName,
		ReduceOperator	op,
		v_t	initialValue = v_t {} )

Construct a transformer with the given operator.

Parameters

instanceName
op
initialValue

Definition at line 94 of file ReduceNode.hpp.

◆ ReduceNode() [3/3]

template<typename coll_t , typename v_t >

Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >::ReduceNode	(	const std::string &	instanceName,
		const std::string &	typeName,
		ReduceOperator	op,
		v_t	initialValue )

protected

Definition at line 129 of file ReduceNode.hpp.

Member Function Documentation

◆ execute()

template<typename coll_t , typename v_t >

bool Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >::execute ( )

overridevirtual

Executes the node.

Execute the node function on the input ports (to be fetched) and write the results to the output ports.

Returns: the execution status.

Implements Ra::Dataflow::Core::Node.

Definition at line 112 of file ReduceNode.hpp.

Here is the call graph for this function:

◆ fromJsonInternal()

template<typename coll_t , typename v_t = typename coll_t::value_type>

bool Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >::fromJsonInternal ( const nlohmann::json & data )

inlineoverrideprotectedvirtual

Internal json representation of the Node.

Default implementation warn about unsupported deserialization. Effective deserialzation must be implemented by inheriting classes. Be careful with template specialization and function member overriding in derived classes.

Reimplemented from Ra::Dataflow::Core::Node.

Definition at line 68 of file ReduceNode.hpp.

Here is the call graph for this function:

◆ init()

template<typename coll_t , typename v_t >

void Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >::init ( )

overridevirtual

Initializes the node content.

The init() function should be called once at the beginning of the lifetime of the node by the owner of the node (the graph which contains the node). Its goal is to initialize the node's internal data if any. The default do nothing.

Reimplemented from Ra::Dataflow::Core::Node.

Definition at line 106 of file ReduceNode.hpp.

Here is the call graph for this function:

◆ node_typename()

template<typename coll_t , typename v_t >

const std::string & Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >::node_typename ( )

static

Definition at line 122 of file ReduceNode.hpp.

◆ set_operator()

template<typename coll_t , typename v_t >

void Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >::set_operator	(	ReduceOperator	op,
		v_t	initialValue = v_t {} )

Sets the operator on the node.

Definition at line 100 of file ReduceNode.hpp.

◆ toJsonInternal()

template<typename coll_t , typename v_t = typename coll_t::value_type>

void Ra::Dataflow::Core::Functionals::ReduceNode< coll_t, v_t >::toJsonInternal ( nlohmann::json & data ) const

inlineoverrideprotectedvirtual

Internal json representation of the Node.

Default implementation warn about unsupported deserialization. Effective deserialzation must be implemented by inheriting classes. Be careful with template specialization and function member overriding in derived classes.

Reimplemented from Ra::Dataflow::Core::Node.

Definition at line 67 of file ReduceNode.hpp.

Here is the call graph for this function:

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

/home/runner/work/Radium-Engine/Radium-Engine/src/Radium-Engine/src/Dataflow/Core/Functionals/ReduceNode.hpp

Public Types

Public Member Functions

Static Public Member Functions

Protected Member Functions

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ ReduceOperator

Constructor & Destructor Documentation

◆ ReduceNode() [1/3]

◆ ReduceNode() [2/3]

◆ ReduceNode() [3/3]

Member Function Documentation

◆ execute()

◆ fromJsonInternal()

◆ init()

◆ node_typename()

◆ set_operator()

◆ toJsonInternal()