quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType > Class Template Reference

#include <quantile.h>

Collaboration diagram for quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >:

Classes
struct	Data

Public Member Functions
DEVICE bool	index (Centroids< RealType, IndexType > *centroid) const
DEVICE bool	isDifferentMean (Centroids< RealType, IndexType > *next_centroid) const
DEVICE void	merged (Centroids< RealType, IndexType > *next_centroid)
DEVICE	operator bool () const
DEVICE void	shiftCentroidsAndSetNext ()
DEVICE void	skipFirst (Centroids< RealType, IndexType > *next_centroid)
DEVICE void	skipSubsequent (Centroids< RealType, IndexType > *next_centroid)

Static Private Member Functions
static DEVICE void	shiftCentroids (Data &data)
template<typename T >
static DEVICE void	shiftRange (T *const begin, IndexType skipped, IndexType const merged, int const inc)

Private Attributes
struct quantile::detail::anonymous_namespace{quantile.h}::Skipped::Data	data_ [2]
Centroid< RealType, IndexType >	mean_

Detailed Description

template<typename RealType, typename IndexType>
class quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >

Definition at line 475 of file quantile.h.

Member Function Documentation

template<typename RealType , typename IndexType >

DEVICE bool quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::index ( Centroids< RealType, IndexType > *  centroid ) const

inline

Definition at line 518 of file quantile.h.

                                                                    {
    return data_[0].centroid_ != centroid;
  }

template<typename RealType , typename IndexType >

DEVICE bool quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::isDifferentMean ( Centroids< RealType, IndexType > *  next_centroid ) const

inline

Definition at line 521 of file quantile.h.

References quantile::detail::Centroids< RealType, IndexType >::nextCount(), and quantile::detail::Centroids< RealType, IndexType >::nextSum().

                                                                                   {
    return mean_.sum_ * next_centroid->nextCount() !=
           next_centroid->nextSum() * mean_.count_;
  }

Here is the call graph for this function:

template<typename RealType , typename IndexType >

DEVICE void quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::merged ( Centroids< RealType, IndexType > *  next_centroid )

inline

Definition at line 525 of file quantile.h.

                                                                    {
    IndexType const idx = index(next_centroid);
    if (data_[idx].count_skipped_) {
      ++data_[idx].count_merged_;
    }
  }

template<typename RealType , typename IndexType >

DEVICE quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::operator bool ( ) const

inline

Definition at line 531 of file quantile.h.

                               {
    return data_[0].centroid_;
  }

template<typename RealType , typename IndexType >

static DEVICE void quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::shiftCentroids ( Data &  data )

inlinestaticprivate

Definition at line 484 of file quantile.h.

References quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::Data::centroid_, quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::Data::count_merged_, quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::Data::count_skipped_, and quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::Data::start_.

                                                {
    if (data.count_merged_) {
      shiftRange(data.centroid_->sums_.begin() + data.start_,
                 data.count_skipped_,
                 data.count_merged_,
                 data.centroid_->inc_);
      shiftRange(data.centroid_->counts_.begin() + data.start_,
                 data.count_skipped_,
                 data.count_merged_,
                 data.centroid_->inc_);
      data.start_ += data.centroid_->inc_ * data.count_merged_;
    }
  }

template<typename RealType , typename IndexType >

DEVICE void quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::shiftCentroidsAndSetNext ( )

inline

Definition at line 535 of file quantile.h.

                                         {
    shiftCentroids(data_[0]);
    data_[0].centroid_->next_idx_ = data_[0].start_;
    if (data_[1].centroid_) {
      shiftCentroids(data_[1]);
      data_[1].centroid_->next_idx_ = data_[1].start_;
    }
  }

template<typename RealType , typename IndexType >

template<typename T >

static DEVICE void quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::shiftRange ( T *const  begin, IndexType  skipped, IndexType const  merged, int const  inc  )

inlinestaticprivate

Definition at line 498 of file quantile.h.

References gpu_enabled::copy(), and heavydb.dtypes::T.

                                               {
#ifdef __CUDACC__
    T* src = begin + inc * (skipped - 1);
    T* dst = src + inc * merged;
    for (; skipped; --skipped, src -= inc, dst -= inc) {
      *dst = *src;
    }
#else
    if (inc == 1) {
      std::copy_backward(begin, begin + skipped, begin + skipped + merged);
    } else {
      std::copy(begin + 1 - skipped, begin + 1, begin + 1 - skipped - merged);
    }
#endif
  }

Here is the call graph for this function:

template<typename RealType , typename IndexType >

DEVICE void quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::skipFirst ( Centroids< RealType, IndexType > *  next_centroid )

inline

Definition at line 543 of file quantile.h.

References quantile::detail::Centroids< RealType, IndexType >::inc_, quantile::detail::Centroids< RealType, IndexType >::next_idx_, quantile::detail::Centroids< RealType, IndexType >::nextCount(), and quantile::detail::Centroids< RealType, IndexType >::nextSum().

                                                                       {
    mean_ = Centroid<RealType, IndexType>{next_centroid->nextSum(),
                                          next_centroid->nextCount()};
    data_[0] = {next_centroid, next_centroid->next_idx_, 0, 1};
    next_centroid->next_idx_ += next_centroid->inc_;
  }

Here is the call graph for this function:

template<typename RealType , typename IndexType >

DEVICE void quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::skipSubsequent ( Centroids< RealType, IndexType > *  next_centroid )

inline

Definition at line 549 of file quantile.h.

References quantile::detail::Centroids< RealType, IndexType >::inc_, and quantile::detail::Centroids< RealType, IndexType >::next_idx_.

                                                                            {
    IndexType const idx = index(next_centroid);
    if (idx == 1 && data_[1].centroid_ == nullptr) {
      data_[1] = {next_centroid, next_centroid->next_idx_, 0, 1};
    } else {
      if (data_[idx].count_merged_) {
        shiftCentroids(data_[idx]);
        data_[idx].count_merged_ = 0;
      }
      ++data_[idx].count_skipped_;
    }
    next_centroid->next_idx_ += next_centroid->inc_;
  }

Member Data Documentation

template<typename RealType , typename IndexType >

struct quantile::detail::anonymous_namespace{quantile.h}::Skipped::Data quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::data_[2]

private

template<typename RealType , typename IndexType >

Centroid<RealType, IndexType> quantile::detail::anonymous_namespace{quantile.h}::Skipped< RealType, IndexType >::mean_

private

Definition at line 482 of file quantile.h.

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/Shared/quantile.h