CollectDistinctSourceSeries merges lists of SourceSeries.

FilterAndRank filters and ranks ObsTimeSeries in place.

FilterSeries filters a list of source series given the observation properties.

GetBestSeries gets the best series for a collection of series with different facet.

GetStatAll implements API for Mixer.GetStatAll.

GetStatDateWithinPlace implements API for Mixer.GetStatDateWithinPlace.

GetStats implements API for Mixer.GetStats.

GetStatSeries implements API for Mixer.GetStatSeries.

GetValueFromBestSource get the stat value from top ranked source series.

GetValueFromBestSourcePb get the stat value from ObsTimeSeries (protobuf version) When date is given, it get the value from the highest ranked source series that has the date.

IsInferiorFacet checks if a facet is from an inferior source.

IsInferiorFacetPb checks if a facet is from an inferior source.

IsInferiorSourceSeries checks if a facet is from an inferior source.

ReadStatCollection reads and process ObsCollection cache from BigTable in parallel.

ReadStats reads and process BigTable rows in parallel.

ReadStatsPb reads and process BigTable rows in parallel.

TokenFn generates a function that convert row key to token string.