nidas::dynld::StatisticsCruncher Class Reference

#include <StatisticsCruncher.h>

Inheritance diagram for nidas::dynld::StatisticsCruncher:

Classes
struct	sampleInfo

Public Types
enum	statsEnumType {   STATS_UNKNOWN, STATS_MINIMUM, STATS_MAXIMUM, STATS_MEAN,   STATS_VAR, STATS_COV, STATS_FLUX, STATS_RFLUX,   STATS_SFLUX, STATS_TRIVAR, STATS_PRUNEDTRIVAR, STATS_WINDDIR,   STATS_SUM }
	Types of statistics I can generate. More...
typedef enum nidas::dynld::StatisticsCruncher::statsEnumType	statisticsType
	Types of statistics I can generate. More...

Public Member Functions
	StatisticsCruncher (StatisticsProcessor *proc, const SampleTag *stag, statisticsType type, std::string countsName, bool higherMoments)
	Constructor. More...
	~StatisticsCruncher ()
SampleSource *	getRawSampleSource ()
	Several objects in NIDAS can be both a SampleSource of raw Samples and processed Samples. More...
SampleSource *	getProcessedSampleSource ()
	Several objects in NIDAS can be both a SampleSource of raw Samples and processed Samples. More...
std::list< const SampleTag * >	getSampleTags () const
	Get the output SampleTags. More...
SampleTagIterator	getSampleTagIterator () const
	Implementation of SampleSource::getSampleTagIterator(). More...
void	addSampleClient (SampleClient *client) throw ()
	Implementation of SampleSource::addSampleClient(). More...
void	removeSampleClient (SampleClient *client) throw ()
	Remove a SampleClient from this SampleSource. More...
void	addSampleClientForTag (SampleClient *client, const SampleTag *) throw ()
	Add a Client for a given SampleTag. More...
void	removeSampleClientForTag (SampleClient *client, const SampleTag *) throw ()
	Remove a SampleClient for a given SampleTag from this SampleSource. More...
int	getClientCount () const throw ()
	How many SampleClients are currently in my list. More...
void	flush () throw ()
	Implementation of Resampler::flush(). More...
const SampleStats &	getSampleStats () const
bool	receive (const Sample *s) throw ()
	Method called to pass a sample to this client. More...
void	connect (SampleSource *source) throw (nidas::util::InvalidParameterException)
	Connect a SamplePipeline to the cruncher. More...
void	disconnect (SampleSource *source) throw ()
void	connect (SampleOutput *output)
	Connect a SamplePipeline to the cruncher. More...
void	disconnect (SampleOutput *output)
void	setStartTime (const nidas::util::UTime &val)
nidas::util::UTime	getStartTime () const
void	setEndTime (const nidas::util::UTime &val)
nidas::util::UTime	getEndTime () const
long long	getPeriodUsecs () const
bool	getFillGaps () const
	Whether to generate output samples over time gaps. More...
void	setFillGaps (bool val)

Static Public Member Functions
static statisticsType	getStatisticsType (const std::string &type) throw (nidas::util::InvalidParameterException)

Protected Member Functions
void	attach (SampleSource *source) throw (nidas::util::InvalidParameterException)
void	splitNames ()
	Split input variable names at periods. More...
std::string	makeName (int i, int j=-1, int k=-1, int l=-1)
	Create a derived variable name from input variables i,j,k,l. More...
std::string	makeUnits (int i, int j=-1, int k=-1, int l=-1)
	Create a derived units field from input variables i,j,k,l. More...
std::string	makeUnits (const std::vector< std::string > &)
void	createCombinations () throw (nidas::util::InvalidParameterException)
void	setupMoments (unsigned int nvars, unsigned int moment)
void	setupMinMax (const std::string &)
void	setupWindDir () throw (nidas::util::InvalidParameterException)
void	setupCovariances ()
void	setupTrivariances ()
void	setupPrunedTrivariances ()
void	setupFluxes ()
void	setupReducedFluxes ()
void	setupReducedScalarFluxes ()
void	initStats ()
void	zeroStats ()
void	computeStats ()
void	addVariable (const std::string &name, const std::string &longname, const std::string &units)

Private Member Functions
void	addSampleTag (const SampleTag *tag) throw ()
	Add a SampleTag to this SampleSource. More...
void	removeSampleTag (const SampleTag *tag) throw ()
	StatisticsCruncher (const StatisticsCruncher &)
	No copy. More...
StatisticsCruncher &	operator= (const StatisticsCruncher &)
	No assignment. More...

Private Attributes
StatisticsProcessor *	_proc
SampleSourceSupport	_source
SampleTag	_reqTag
std::vector< const Variable * >	_reqVariables
unsigned int	_ninvars
	Number of input variables. More...
std::string	_countsName
	Name of counts variable. More...
bool	_numpoints
	Does the user want number-of-points output? More...
dsm_time_t	_periodUsecs
bool	_crossTerms
	Does this cruncher compute cross-terms? More...
NearestResampler *	_resampler
statisticsType	_statsType
	Types of statistics I can generate. More...
std::vector< std::vector < std::string > >	_splitVarNames
	Input variable names, split at dots. More...
std::string	_leadCommon
	Portion after the first dot-separated word that is common to all variable names. More...
std::string	_commonSuffix
	Trailing portion that is common to all variable names. More...
SampleTag	_outSample
unsigned int	_nOutVar
unsigned int	_outlen
dsm_time_t	_tout
std::map< dsm_sample_id_t, sampleInfo >	_sampleMap
float *	_xMin
float *	_xMax
double *	_xSum
double **	_xySum
double *	_xyzSum
double *	_x4Sum
unsigned int *	_nSamples
unsigned int **	_triComb
unsigned int	_nsum
	Number of simple sums to maintain. More...
unsigned int	_ncov
	Number of covariances to compute. More...
unsigned int	_ntri
	Number of trivariances to compute. More...
unsigned int	_n1mom
	Number of 1st,2nd,3rd,4th moments to compute. More...
unsigned int	_n2mom
unsigned int	_n3mom
unsigned int	_n4mom
unsigned int	_ntot
	Total number of products to compute. More...
bool	_higherMoments
const Site *	_site
int	_station
nidas::util::UTime	_startTime
nidas::util::UTime	_endTime
bool	_fillGaps

Member Typedef Documentation

typedef enum nidas::dynld::StatisticsCruncher::statsEnumType nidas::dynld::StatisticsCruncher::statisticsType

Types of statistics I can generate.

Member Enumeration Documentation

enum nidas::dynld::StatisticsCruncher::statsEnumType

Types of statistics I can generate.

Enumerator
STATS_UNKNOWN
STATS_MINIMUM
STATS_MAXIMUM
STATS_MEAN
STATS_VAR
STATS_COV
STATS_FLUX
STATS_RFLUX
STATS_SFLUX
STATS_TRIVAR
STATS_PRUNEDTRIVAR
STATS_WINDDIR
STATS_SUM

Constructor & Destructor Documentation

StatisticsCruncher::StatisticsCruncher	(	StatisticsProcessor *	proc,
		const SampleTag *	stag,
		statisticsType	type,
		std::string	countsName,
		bool	higherMoments
	)

Constructor.

References _crossTerms, _ninvars, _numpoints, _outSample, _periodUsecs, _reqTag, _reqVariables, _site, _statsType, addSampleTag(), nidas::core::SampleTag::getDSMId(), nidas::core::SampleTag::getRate(), nidas::core::SampleTag::getSpSId(), MSECS_PER_SEC, nidas::core::SampleTag::setDSMId(), nidas::core::SampleTag::setRate(), nidas::core::SampleTag::setSampleId(), STATS_COV, STATS_FLUX, STATS_MAXIMUM, STATS_MEAN, STATS_MINIMUM, STATS_PRUNEDTRIVAR, STATS_RFLUX, STATS_SFLUX, STATS_SUM, STATS_TRIVAR, STATS_UNKNOWN, STATS_VAR, STATS_WINDDIR, and USECS_PER_MSEC.

StatisticsCruncher::~StatisticsCruncher

(

)

References _nSamples, _ntri, _resampler, _sampleMap, _triComb, _x4Sum, _xMax, _xMin, _xSum, _xySum, _xyzSum, and nidas::dynld::StatisticsCruncher::sampleInfo::varIndices.

nidas::dynld::StatisticsCruncher::StatisticsCruncher ( const StatisticsCruncher &  )

private

No copy.

Member Function Documentation

void nidas::dynld::StatisticsCruncher::addSampleClient ( SampleClient *  client ) throw ( )

inlinevirtual

Implementation of SampleSource::addSampleClient().

Implements nidas::core::SampleSource.

Referenced by nidas::dynld::StatisticsProcessor::connect().

void nidas::dynld::StatisticsCruncher::addSampleClientForTag ( SampleClient *  client, const SampleTag *    ) throw ( )

inlinevirtual

Add a Client for a given SampleTag.

Implementation of SampleSource::addSampleClient().

Implements nidas::core::SampleSource.

void nidas::dynld::StatisticsCruncher::addSampleTag ( const SampleTag *  tag ) throw ( )

inlineprivatevirtual

Add a SampleTag to this SampleSource.

This SampleSource does not own the SampleTag.

Implements nidas::core::SampleSource.

Referenced by StatisticsCruncher().

void StatisticsCruncher::addVariable ( const std::string &  name, const std::string &  longname, const std::string &  units  )

protected

References _nOutVar, _outSample, nidas::core::SampleTag::addVariable(), nidas::core::SampleTag::getVariable(), nidas::core::SampleTag::getVariables(), nidas::core::Variable::setLongName(), nidas::core::Variable::setName(), and nidas::core::Variable::setUnits().

Referenced by setupMoments().

void StatisticsCruncher::attach ( SampleSource *  source ) throw ( nidas::util::InvalidParameterException )

protected

References GET_DSM_ID, GET_SPS_ID, nidas::core::SampleTag::getDataIndex(), nidas::core::SampleTag::getDSMId(), nidas::core::SampleTag::getId(), nidas::core::Variable::getLongName(), nidas::core::Variable::getName(), nidas::core::Variable::getSampleTag(), nidas::core::SampleTag::getSpSId(), nidas::core::Variable::getStation(), nidas::core::Variable::getType(), nidas::core::Variable::getUnits(), nidas::core::SampleTag::getVariableIterator(), nidas::core::VariableIterator::hasNext(), ILOG, nidas::core::VariableIterator::next(), nidas::dynld::StatisticsCruncher::sampleInfo::varIndices, nidas::core::Variable::WEIGHT, nidas::dynld::StatisticsCruncher::sampleInfo::weightsIndex, and WLOG.

void StatisticsCruncher::computeStats ( )

protected

References _higherMoments, _n1mom, _n3mom, _n4mom, _ninvars, _nSamples, _ntot, _ntri, _numpoints, _outlen, _outSample, _periodUsecs, _source, _statsType, _tout, _triComb, _x4Sum, _xMax, _xMin, _xSum, _xySum, _xyzSum, nidas::util::LogContext::active(), nidas::util::dirFromUV(), nidas::core::SampleSourceSupport::distribute(), nidas::core::floatNAN, nidas::util::UTime::format(), nidas::core::SampleT< DataT >::getDataPtr(), nidas::core::SampleTag::getId(), LOG_VERBOSE, nidas::core::Sample::setId(), nidas::core::Sample::setTimeTag(), STATS_FLUX, STATS_MAXIMUM, STATS_MEAN, STATS_MINIMUM, STATS_PRUNEDTRIVAR, STATS_RFLUX, STATS_SFLUX, STATS_SUM, STATS_TRIVAR, STATS_VAR, STATS_WINDDIR, and zeroStats().

Referenced by flush().

void StatisticsCruncher::connect ( SampleSource *  source ) throw ( nidas::util::InvalidParameterException )

virtual

Connect a SamplePipeline to the cruncher.

Implements nidas::core::Resampler.

References DLOG, nidas::core::SampleTag::getId(), nidas::core::Site::getName(), nidas::core::Variable::getName(), nidas::core::Variable::getSite(), nidas::core::Variable::getStation(), nidas::core::SampleTag::getVariableIterator(), nidas::core::SampleTagIterator::hasNext(), nidas::core::VariableIterator::hasNext(), nidas::core::SampleTagIterator::next(), nidas::core::VariableIterator::next(), and WLOG.

Referenced by nidas::dynld::StatisticsProcessor::connectSource().

void nidas::dynld::StatisticsCruncher::connect

(

SampleOutput *

output

)

Connect a SamplePipeline to the cruncher.

void StatisticsCruncher::createCombinations ( ) throw ( nidas::util::InvalidParameterException )

protected

References _higherMoments, _n1mom, _n2mom, _n3mom, _n4mom, _ncov, _ninvars, _nOutVar, _ntot, _ntri, _outSample, _station, _statsType, _triComb, nidas::util::LogContext::active(), nidas::core::Variable::getName(), nidas::core::Variable::getStation(), nidas::core::SampleTag::getVariable(), nidas::core::SampleTag::getVariableIterator(), nidas::core::SampleTag::getVariables(), nidas::core::VariableIterator::hasNext(), LOG_VERBOSE, nidas::core::VariableIterator::next(), nidas::core::Variable::setStation(), setupCovariances(), setupFluxes(), setupMinMax(), setupMoments(), setupPrunedTrivariances(), setupReducedFluxes(), setupReducedScalarFluxes(), setupTrivariances(), setupWindDir(), splitNames(), STATS_COV, STATS_FLUX, STATS_MAXIMUM, STATS_MEAN, STATS_MINIMUM, STATS_PRUNEDTRIVAR, STATS_RFLUX, STATS_SFLUX, STATS_SUM, STATS_TRIVAR, STATS_VAR, STATS_WINDDIR, and VLOG.

void StatisticsCruncher::disconnect ( SampleSource *  source ) throw ( )

virtual

Implements nidas::core::Resampler.

Referenced by nidas::dynld::StatisticsProcessor::disconnectSource().

void nidas::dynld::StatisticsCruncher::disconnect

(

SampleOutput *

output

)

void StatisticsCruncher::flush ( ) throw ( )

virtual

Implementation of Resampler::flush().

Implements nidas::core::Resampler.

References _ninvars, _nSamples, _periodUsecs, _tout, and computeStats().

Referenced by nidas::dynld::StatisticsProcessor::disconnectSource(), nidas::dynld::StatisticsProcessor::flush(), and nidas::dynld::StatisticsProcessor::~StatisticsProcessor().

int nidas::dynld::StatisticsCruncher::getClientCount ( ) const throw ( )

inlinevirtual

How many SampleClients are currently in my list.

Implements nidas::core::SampleSource.

nidas::util::UTime nidas::dynld::StatisticsCruncher::getEndTime ( ) const

inline

bool nidas::dynld::StatisticsCruncher::getFillGaps ( ) const

inline

Whether to generate output samples over time gaps.

In some circumstances one might be generating statistics for separate time periods, and one does not want to output samples of missing data for the gaps between the periods.

long long nidas::dynld::StatisticsCruncher::getPeriodUsecs ( ) const

inline

SampleSource* nidas::dynld::StatisticsCruncher::getProcessedSampleSource ( )

inlinevirtual

Several objects in NIDAS can be both a SampleSource of raw Samples and processed Samples.

SampleClients use this method to get a pointer to whatever sample source they are interested in. Derived classes can return NULL if they are not a SampleSource of processed samples.

Implements nidas::core::SampleSource.

SampleSource* nidas::dynld::StatisticsCruncher::getRawSampleSource ( )

inlinevirtual

Several objects in NIDAS can be both a SampleSource of raw Samples and processed Samples.

SampleClients use this method to get a pointer to whatever sample source they are interested in. Derived classes can return NULL if they are not a SampleSource of raw samples.

Implements nidas::core::SampleSource.

const SampleStats& nidas::dynld::StatisticsCruncher::getSampleStats ( ) const

inlinevirtual

Implements nidas::core::SampleSource.

SampleTagIterator nidas::dynld::StatisticsCruncher::getSampleTagIterator ( ) const

inlinevirtual

Implementation of SampleSource::getSampleTagIterator().

Implements nidas::core::SampleSource.

std::list<const SampleTag*> nidas::dynld::StatisticsCruncher::getSampleTags ( ) const

inlinevirtual

Get the output SampleTags.

Implements nidas::core::SampleSource.

Referenced by nidas::dynld::StatisticsProcessor::connectSource().

nidas::util::UTime nidas::dynld::StatisticsCruncher::getStartTime ( ) const

inline

StatisticsCruncher::statisticsType StatisticsCruncher::getStatisticsType ( const std::string &  type ) throw ( nidas::util::InvalidParameterException )

static

Referenced by nidas::dynld::StatisticsProcessor::addRequestedSampleTag().

void StatisticsCruncher::initStats ( )

protected

References _commonSuffix, _countsName, _leadCommon, _n2mom, _n3mom, _n4mom, _ncov, _ninvars, _nSamples, _nsum, _ntot, _ntri, _numpoints, _outlen, _outSample, _proc, _station, _statsType, _x4Sum, _xMax, _xMin, _xSum, _xySum, _xyzSum, nidas::core::SampleTag::addVariable(), nidas::core::Variable::getName(), nidas::dynld::StatisticsProcessor::getUniqueCountsName(), nidas::core::SampleTag::getVariables(), nidas::core::Variable::setName(), nidas::core::Variable::setStation(), nidas::core::Variable::setType(), nidas::core::Variable::setUnits(), STATS_FLUX, STATS_MAXIMUM, STATS_MINIMUM, STATS_RFLUX, STATS_SFLUX, and nidas::core::Variable::WEIGHT.

string StatisticsCruncher::makeName ( int  i, int  j = -1, int  k = -1, int  l = -1  )

protected

Create a derived variable name from input variables i,j,k,l.

Specify j,k,l for 2nd,3rd,4th order products.

References _commonSuffix, _leadCommon, and _splitVarNames.

Referenced by setupCovariances(), setupFluxes(), setupMoments(), setupPrunedTrivariances(), setupReducedFluxes(), setupReducedScalarFluxes(), and setupTrivariances().

string StatisticsCruncher::makeUnits ( int  i, int  j = -1, int  k = -1, int  l = -1  )

protected

Create a derived units field from input variables i,j,k,l.

Specify j,k,l for 2nd,3rd,4th order products.

References _reqVariables.

Referenced by setupCovariances(), setupFluxes(), setupMinMax(), setupMoments(), setupPrunedTrivariances(), setupReducedFluxes(), setupReducedScalarFluxes(), and setupTrivariances().

std::string StatisticsCruncher::makeUnits ( const std::vector< std::string > &  units )

protected

StatisticsCruncher& nidas::dynld::StatisticsCruncher::operator= ( const StatisticsCruncher &  )

private

No assignment.

bool StatisticsCruncher::receive ( const Sample *  s ) throw ( )

virtual

Method called to pass a sample to this client.

This method is typically called by a SampleSource for each of its SampleClients when it has a sample ready. Returns true: success false: sample rejected. This is meant to signal a warning-type situation - like a socket not being available temporarily. True errors will be thrown as an IOException.

Implements nidas::core::SampleClient.

References nidas::util::LogContext::active(), nidas::core::DOUBLE_ST, nidas::core::FLOAT_ST, nidas::util::UTime::format(), LOG_VERBOSE, nidas::dynld::StatisticsCruncher::sampleInfo::varIndices, nidas::dynld::StatisticsCruncher::sampleInfo::weightsIndex, and WLOG.

void nidas::dynld::StatisticsCruncher::removeSampleClient ( SampleClient *  c ) throw ( )

inlinevirtual

Remove a SampleClient from this SampleSource.

Implements nidas::core::SampleSource.

Referenced by nidas::dynld::StatisticsProcessor::disconnect(), and nidas::dynld::StatisticsProcessor::~StatisticsProcessor().

void nidas::dynld::StatisticsCruncher::removeSampleClientForTag ( SampleClient *  c, const SampleTag *    ) throw ( )

inlinevirtual

Remove a SampleClient for a given SampleTag from this SampleSource.

The pointer to the SampleClient must remain valid, until after it is removed.

Implements nidas::core::SampleSource.

void nidas::dynld::StatisticsCruncher::removeSampleTag ( const SampleTag *  tag ) throw ( )

inlineprivatevirtual

Implements nidas::core::SampleSource.

void nidas::dynld::StatisticsCruncher::setEndTime ( const nidas::util::UTime &  val )

inline

Referenced by nidas::dynld::StatisticsProcessor::connectSource().

void nidas::dynld::StatisticsCruncher::setFillGaps ( bool  val )

inline

Referenced by nidas::dynld::StatisticsProcessor::connectSource().

void StatisticsCruncher::setStartTime

(

const nidas::util::UTime &

val

)

References _periodUsecs, _startTime, _tout, and nidas::util::UTime::toUsecs().

Referenced by nidas::dynld::StatisticsProcessor::connectSource().

void StatisticsCruncher::setupCovariances ( )

protected

References _ncov, _ninvars, _nOutVar, _nsum, _outSample, nidas::core::SampleTag::addVariable(), nidas::core::SampleTag::getVariable(), nidas::core::SampleTag::getVariables(), makeName(), makeUnits(), nidas::core::Variable::setLongName(), nidas::core::Variable::setName(), and nidas::core::Variable::setUnits().

Referenced by createCombinations().

void StatisticsCruncher::setupFluxes ( )

protected

References _ncov, _ninvars, _nOutVar, _nsum, _outSample, nidas::core::SampleTag::addVariable(), nidas::core::SampleTag::getVariable(), nidas::core::SampleTag::getVariables(), makeName(), makeUnits(), nidas::core::Variable::setLongName(), nidas::core::Variable::setName(), and nidas::core::Variable::setUnits().

Referenced by createCombinations().

void StatisticsCruncher::setupMinMax ( const std::string &  )

protected

References _commonSuffix, _leadCommon, _n1mom, _ninvars, _nOutVar, _nsum, _outSample, _splitVarNames, nidas::core::SampleTag::addVariable(), nidas::core::SampleTag::getVariable(), nidas::core::SampleTag::getVariables(), makeUnits(), nidas::core::Variable::setName(), and nidas::core::Variable::setUnits().

Referenced by createCombinations().

void StatisticsCruncher::setupMoments ( unsigned int  nvars, unsigned int  moment  )

protected

References _n1mom, _n2mom, _n3mom, _n4mom, _nsum, _reqVariables, addVariable(), makeName(), and makeUnits().

Referenced by createCombinations(), and setupPrunedTrivariances().

void StatisticsCruncher::setupPrunedTrivariances ( )

protected

References _n3mom, _ninvars, _nOutVar, _nsum, _ntri, _outSample, _triComb, nidas::core::SampleTag::addVariable(), nidas::core::SampleTag::getVariable(), nidas::core::SampleTag::getVariables(), makeName(), makeUnits(), nidas::core::Variable::setLongName(), nidas::core::Variable::setName(), nidas::core::Variable::setUnits(), and setupMoments().

Referenced by createCombinations().

void StatisticsCruncher::setupReducedFluxes ( )

protected

References _ncov, _ninvars, _nOutVar, _nsum, _outSample, nidas::core::SampleTag::addVariable(), nidas::core::SampleTag::getVariable(), nidas::core::SampleTag::getVariables(), makeName(), makeUnits(), nidas::core::Variable::setLongName(), nidas::core::Variable::setName(), and nidas::core::Variable::setUnits().

Referenced by createCombinations().

void StatisticsCruncher::setupReducedScalarFluxes ( )

protected

References _ncov, _ninvars, _nOutVar, _nsum, _outSample, nidas::core::SampleTag::addVariable(), nidas::core::SampleTag::getVariable(), nidas::core::SampleTag::getVariables(), makeName(), makeUnits(), nidas::core::Variable::setLongName(), nidas::core::Variable::setName(), and nidas::core::Variable::setUnits().

Referenced by createCombinations().

void StatisticsCruncher::setupTrivariances ( )

protected

References _ninvars, _nOutVar, _nsum, _ntri, _outSample, nidas::core::SampleTag::addVariable(), nidas::core::SampleTag::getVariable(), nidas::core::SampleTag::getVariables(), makeName(), makeUnits(), nidas::core::Variable::setLongName(), nidas::core::Variable::setName(), and nidas::core::Variable::setUnits().

Referenced by createCombinations().

void StatisticsCruncher::setupWindDir ( ) throw ( nidas::util::InvalidParameterException )

protected

References _commonSuffix, _leadCommon, _n1mom, _nOutVar, _nsum, _outSample, _splitVarNames, nidas::core::SampleTag::addVariable(), nidas::core::Variable::setLongName(), nidas::core::Variable::setName(), and nidas::core::Variable::setUnits().

Referenced by createCombinations().

void StatisticsCruncher::splitNames ( )

protected

Split input variable names at periods.

References _commonSuffix, _leadCommon, _reqVariables, and _splitVarNames.

Referenced by createCombinations().

void StatisticsCruncher::zeroStats ( )

protected

References _n2mom, _n3mom, _n4mom, _ncov, _ninvars, _nSamples, _nsum, _ntri, _x4Sum, _xMax, _xMin, _xSum, _xySum, and _xyzSum.

Referenced by computeStats().

Member Data Documentation

std::string nidas::dynld::StatisticsCruncher::_commonSuffix

private

Trailing portion that is common to all variable names.

Referenced by initStats(), makeName(), setupMinMax(), setupWindDir(), and splitNames().

std::string nidas::dynld::StatisticsCruncher::_countsName

private

Name of counts variable.

Referenced by initStats().

bool nidas::dynld::StatisticsCruncher::_crossTerms

private

Does this cruncher compute cross-terms?

Referenced by StatisticsCruncher().

nidas::util::UTime nidas::dynld::StatisticsCruncher::_endTime

private

bool nidas::dynld::StatisticsCruncher::_fillGaps

private

bool nidas::dynld::StatisticsCruncher::_higherMoments

private

Referenced by computeStats(), and createCombinations().

std::string nidas::dynld::StatisticsCruncher::_leadCommon

private

Portion after the first dot-separated word that is common to all variable names.

Referenced by initStats(), makeName(), setupMinMax(), setupWindDir(), and splitNames().

unsigned int nidas::dynld::StatisticsCruncher::_n1mom

private

Number of 1st,2nd,3rd,4th moments to compute.

Referenced by computeStats(), createCombinations(), setupMinMax(), setupMoments(), and setupWindDir().

unsigned int nidas::dynld::StatisticsCruncher::_n2mom

private

Referenced by createCombinations(), initStats(), setupMoments(), and zeroStats().

unsigned int nidas::dynld::StatisticsCruncher::_n3mom

private

Referenced by computeStats(), createCombinations(), initStats(), setupMoments(), setupPrunedTrivariances(), and zeroStats().

unsigned int nidas::dynld::StatisticsCruncher::_n4mom

private

Referenced by computeStats(), createCombinations(), initStats(), setupMoments(), and zeroStats().

unsigned int nidas::dynld::StatisticsCruncher::_ncov

private

Number of covariances to compute.

Referenced by createCombinations(), initStats(), setupCovariances(), setupFluxes(), setupReducedFluxes(), setupReducedScalarFluxes(), and zeroStats().

unsigned int nidas::dynld::StatisticsCruncher::_ninvars

private

Number of input variables.

Referenced by computeStats(), createCombinations(), flush(), initStats(), setupCovariances(), setupFluxes(), setupMinMax(), setupPrunedTrivariances(), setupReducedFluxes(), setupReducedScalarFluxes(), setupTrivariances(), StatisticsCruncher(), and zeroStats().

unsigned int nidas::dynld::StatisticsCruncher::_nOutVar

private

Referenced by addVariable(), createCombinations(), setupCovariances(), setupFluxes(), setupMinMax(), setupPrunedTrivariances(), setupReducedFluxes(), setupReducedScalarFluxes(), setupTrivariances(), and setupWindDir().

unsigned int* nidas::dynld::StatisticsCruncher::_nSamples

private

Referenced by computeStats(), flush(), initStats(), zeroStats(), and ~StatisticsCruncher().

unsigned int nidas::dynld::StatisticsCruncher::_nsum

private

Number of simple sums to maintain.

Referenced by initStats(), setupCovariances(), setupFluxes(), setupMinMax(), setupMoments(), setupPrunedTrivariances(), setupReducedFluxes(), setupReducedScalarFluxes(), setupTrivariances(), setupWindDir(), and zeroStats().

unsigned int nidas::dynld::StatisticsCruncher::_ntot

private

Total number of products to compute.

Referenced by computeStats(), createCombinations(), and initStats().

unsigned int nidas::dynld::StatisticsCruncher::_ntri

private

Number of trivariances to compute.

Referenced by computeStats(), createCombinations(), initStats(), setupPrunedTrivariances(), setupTrivariances(), zeroStats(), and ~StatisticsCruncher().

bool nidas::dynld::StatisticsCruncher::_numpoints

private

Does the user want number-of-points output?

Referenced by computeStats(), initStats(), and StatisticsCruncher().

unsigned int nidas::dynld::StatisticsCruncher::_outlen

private

Referenced by computeStats(), and initStats().

SampleTag nidas::dynld::StatisticsCruncher::_outSample

private

Referenced by addVariable(), computeStats(), createCombinations(), initStats(), setupCovariances(), setupFluxes(), setupMinMax(), setupPrunedTrivariances(), setupReducedFluxes(), setupReducedScalarFluxes(), setupTrivariances(), setupWindDir(), and StatisticsCruncher().

dsm_time_t nidas::dynld::StatisticsCruncher::_periodUsecs

private

Referenced by computeStats(), flush(), setStartTime(), and StatisticsCruncher().

StatisticsProcessor* nidas::dynld::StatisticsCruncher::_proc

private

Referenced by initStats().

SampleTag nidas::dynld::StatisticsCruncher::_reqTag

private

Referenced by StatisticsCruncher().

std::vector<const Variable*> nidas::dynld::StatisticsCruncher::_reqVariables

private

Referenced by makeUnits(), setupMoments(), splitNames(), and StatisticsCruncher().

NearestResampler* nidas::dynld::StatisticsCruncher::_resampler

private

Referenced by ~StatisticsCruncher().

std::map<dsm_sample_id_t,sampleInfo > nidas::dynld::StatisticsCruncher::_sampleMap

private

Referenced by ~StatisticsCruncher().

const Site* nidas::dynld::StatisticsCruncher::_site

private

Referenced by StatisticsCruncher().

SampleSourceSupport nidas::dynld::StatisticsCruncher::_source

private

Referenced by computeStats().

std::vector<std::vector<std::string> > nidas::dynld::StatisticsCruncher::_splitVarNames

private

Input variable names, split at dots.

Referenced by makeName(), setupMinMax(), setupWindDir(), and splitNames().

nidas::util::UTime nidas::dynld::StatisticsCruncher::_startTime

private

Referenced by setStartTime().

int nidas::dynld::StatisticsCruncher::_station

private

Referenced by createCombinations(), and initStats().

statisticsType nidas::dynld::StatisticsCruncher::_statsType

private

Types of statistics I can generate.

Referenced by computeStats(), createCombinations(), initStats(), and StatisticsCruncher().

dsm_time_t nidas::dynld::StatisticsCruncher::_tout

private

Referenced by computeStats(), flush(), and setStartTime().

unsigned int** nidas::dynld::StatisticsCruncher::_triComb

private

Referenced by computeStats(), createCombinations(), setupPrunedTrivariances(), and ~StatisticsCruncher().

double* nidas::dynld::StatisticsCruncher::_x4Sum

private

Referenced by computeStats(), initStats(), zeroStats(), and ~StatisticsCruncher().

float* nidas::dynld::StatisticsCruncher::_xMax

private

Referenced by computeStats(), initStats(), zeroStats(), and ~StatisticsCruncher().

float* nidas::dynld::StatisticsCruncher::_xMin

private

Referenced by computeStats(), initStats(), zeroStats(), and ~StatisticsCruncher().

double* nidas::dynld::StatisticsCruncher::_xSum

private

Referenced by computeStats(), initStats(), zeroStats(), and ~StatisticsCruncher().

double** nidas::dynld::StatisticsCruncher::_xySum

private

Referenced by computeStats(), initStats(), zeroStats(), and ~StatisticsCruncher().

double* nidas::dynld::StatisticsCruncher::_xyzSum

private

Referenced by computeStats(), initStats(), zeroStats(), and ~StatisticsCruncher().

---

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

• nidas/dynld/StatisticsCruncher.h
• nidas/dynld/StatisticsCruncher.cc