SourceXtractorPlusPlus
0.10
Please provide a description of the project.
|
#include <TableOutput.h>
Public Types | |
using | SourceToRowConverter = std::function< Euclid::Table::Row(const SourceInterface &)> |
using | TableHandler = std::function< void(const Euclid::Table::Table &)> |
Public Member Functions | |
size_t | flush () override |
TableOutput (SourceToRowConverter source_to_row, TableHandler table_handler, size_t flush_size) | |
void | outputSource (const SourceInterface &source) override |
![]() | |
virtual | ~Output ()=default |
virtual void | handleMessage (const std::shared_ptr< SourceInterface > &source) override |
virtual void | handleMessage (const std::shared_ptr< SourceGroupInterface > &source_group) override |
![]() | |
virtual | ~Observer ()=default |
![]() | |
virtual | ~Observer ()=default |
Private Attributes | |
SourceToRowConverter | m_source_to_row |
TableHandler | m_table_handler |
std::vector< Euclid::Table::Row > | m_rows {} |
size_t | m_flush_size |
size_t | m_total_rows_written |
Definition at line 32 of file TableOutput.h.
using SourceXtractor::TableOutput::SourceToRowConverter = std::function<Euclid::Table::Row(const SourceInterface&)> |
Definition at line 36 of file TableOutput.h.
using SourceXtractor::TableOutput::TableHandler = std::function<void(const Euclid::Table::Table&)> |
Definition at line 37 of file TableOutput.h.
|
inline |
Definition at line 49 of file TableOutput.h.
|
inlineoverridevirtual |
Implements SourceXtractor::Output.
Definition at line 39 of file TableOutput.h.
References std::vector< T >::clear(), std::vector< T >::empty(), m_rows, m_table_handler, m_total_rows_written, and std::vector< T >::size().
Referenced by outputSource().
|
inlineoverridevirtual |
Implements SourceXtractor::Output.
Definition at line 54 of file TableOutput.h.
References std::vector< T >::emplace_back(), flush(), m_flush_size, m_rows, m_source_to_row, and std::vector< T >::size().
|
private |
Definition at line 65 of file TableOutput.h.
Referenced by outputSource().
|
private |
Definition at line 64 of file TableOutput.h.
Referenced by flush(), and outputSource().
|
private |
Definition at line 62 of file TableOutput.h.
Referenced by outputSource().
|
private |
Definition at line 63 of file TableOutput.h.
Referenced by flush().
|
private |
Definition at line 66 of file TableOutput.h.
Referenced by flush().