Inheritance diagram for JArrowProcessingController:

Collaboration diagram for JArrowProcessingController:

Public Member Functions
	JArrowProcessingController (JArrowTopology *topology)

void	acquire_services (JServiceLocator *) override

void	initialize () override

void	run (size_t nthreads) override

void	scale (size_t nthreads) override

void	request_stop () override

void	wait_until_stopped () override

bool	is_stopped () override

bool	is_finished () override

std::unique_ptr< const JPerfSummary >	measure_performance () override

std::unique_ptr< const JArrowPerfSummary >	measure_internal_performance ()

void	print_report () override

void	print_final_report () override

Public Member Functions inherited from JService
virtual	~JService ()=default
	acquire_services is a callback which allows the user to configure a JService which relies on other JServices. More...

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

Public Member Functions