JoinColumnIterator Struct Reference

Iterates over the rows of a JoinColumn across multiple fragments/chunks. More...

#include <JoinColumnIterator.h>

Collaboration diagram for JoinColumnIterator:

Classes
struct	IndexedElement

Public Member Functions
DEVICE FORCE_INLINE	operator bool () const
DEVICE FORCE_INLINE const int8_t *	ptr () const
DEVICE FORCE_INLINE int64_t	getElementSwitch () const
DEVICE FORCE_INLINE IndexedElement	operator* () const
DEVICE FORCE_INLINE JoinColumnIterator &	operator++ ()
DEVICE FORCE_INLINE JoinColumnIterator &	operator-- ()
DEVICE	JoinColumnIterator ()
DEVICE	JoinColumnIterator (const JoinColumn *join_column, const JoinColumnTypeInfo *type_info, size_t start, size_t step)

Public Attributes
const JoinColumn *	join_column
const JoinColumnTypeInfo *	type_info
struct JoinChunk *	join_chunk_array
const int8_t *	chunk_data
size_t	index_of_chunk
size_t	index_inside_chunk
size_t	index
size_t	start
size_t	step

Detailed Description

Iterates over the rows of a JoinColumn across multiple fragments/chunks.

Definition at line 20 of file JoinColumnIterator.h.

Constructor & Destructor Documentation

DEVICE JoinColumnIterator::JoinColumnIterator ( )

inline

Definition at line 105 of file JoinColumnIterator.h.

: chunk_data(nullptr) {}

DEVICE JoinColumnIterator::JoinColumnIterator ( const JoinColumn *  join_column, const JoinColumnTypeInfo *  type_info, size_t  start, size_t  step  )

inline

Definition at line 107 of file JoinColumnIterator.h.

References operator++(), start, and step.

      : join_column(join_column)
      , type_info(type_info)
      , join_chunk_array(
            reinterpret_cast<const struct JoinChunk*>(join_column->col_chunks_buff))
      , chunk_data(join_column->num_elems > 0 ? join_chunk_array->col_buff : nullptr)
      , index_of_chunk(0)
      , index_inside_chunk(0)
      , index(0)
      , start(start)
      , step(step) {
    // Stagger the index differently for each thread iterating over the column.
    auto temp = this->step;
    this->step = this->start;
    operator++();
    this->step = temp;
  }

Here is the call graph for this function:

Member Function Documentation

DEVICE FORCE_INLINE int64_t JoinColumnIterator::getElementSwitch ( ) const

inline

Definition at line 37 of file JoinColumnIterator.h.

References CHECK, chunk_data, JoinColumnTypeInfo::column_type, Double, JoinColumnTypeInfo::elem_sz, fixed_width_double_decode_noinline(), fixed_width_int_decode_noinline(), fixed_width_small_date_decode_noinline(), fixed_width_unsigned_decode_noinline(), index_inside_chunk, NULL_INT, NULL_SMALLINT, Signed, SmallDate, SUFFIX, type_info, and Unsigned.

Referenced by operator*().

                                                       {
    switch (type_info->column_type) {
      case SmallDate:
        return SUFFIX(fixed_width_small_date_decode_noinline)(
            chunk_data,
            type_info->elem_sz,
            type_info->elem_sz == 4 ? NULL_INT : NULL_SMALLINT,
            type_info->elem_sz == 4 ? NULL_INT : NULL_SMALLINT,
            index_inside_chunk);
      case Signed:
        return SUFFIX(fixed_width_int_decode_noinline)(
            chunk_data, type_info->elem_sz, index_inside_chunk);
      case Unsigned:
        return SUFFIX(fixed_width_unsigned_decode_noinline)(
            chunk_data, type_info->elem_sz, index_inside_chunk);
      case Double:
        return SUFFIX(fixed_width_double_decode_noinline)(chunk_data, index_inside_chunk);
      default:
#ifndef __CUDACC__
        CHECK(false);
#else
        assert(0);
#endif
        return 0;
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

DEVICE FORCE_INLINE JoinColumnIterator::operator bool ( ) const

inline

Definition at line 31 of file JoinColumnIterator.h.

References chunk_data.

{ return chunk_data; }

DEVICE FORCE_INLINE IndexedElement JoinColumnIterator::operator* ( ) const

inline

Definition at line 69 of file JoinColumnIterator.h.

References getElementSwitch(), and index.

                                                       {
    return {index, getElementSwitch()};
  }

Here is the call graph for this function:

DEVICE FORCE_INLINE JoinColumnIterator& JoinColumnIterator::operator++ ( void  )

inline

Definition at line 73 of file JoinColumnIterator.h.

References chunk_data, JoinChunk::col_buff, index, index_inside_chunk, index_of_chunk, join_chunk_array, JoinChunk::num_elems, and step.

Referenced by JoinColumnIterator().

                                                       {
    index += step;
    index_inside_chunk += step;
    while (chunk_data &&
           index_inside_chunk >= join_chunk_array[index_of_chunk].num_elems) {
      index_inside_chunk -= join_chunk_array[index_of_chunk].num_elems;
      ++index_of_chunk;
      if (index_of_chunk < join_column->num_chunks) {
        chunk_data = join_chunk_array[index_of_chunk].col_buff;
      } else {
        chunk_data = nullptr;
      }
    }
    return *this;
  }

Here is the caller graph for this function:

DEVICE FORCE_INLINE JoinColumnIterator& JoinColumnIterator::operator-- ( )

inline

Definition at line 89 of file JoinColumnIterator.h.

References chunk_data, JoinChunk::col_buff, index, index_inside_chunk, index_of_chunk, join_chunk_array, JoinChunk::num_elems, and step.

                                                       {
    index -= step;
    index_inside_chunk -= step;
    while (chunk_data &&
           index_inside_chunk <= join_chunk_array[index_of_chunk].num_elems) {
      index_inside_chunk -= join_chunk_array[index_of_chunk].num_elems;
      --index_of_chunk;
      if (index_of_chunk < join_column->num_chunks) {
        chunk_data = join_chunk_array[index_of_chunk].col_buff;
      } else {
        chunk_data = nullptr;
      }
    }
    return *this;
  }

DEVICE FORCE_INLINE const int8_t* JoinColumnIterator::ptr ( ) const

inline

Definition at line 33 of file JoinColumnIterator.h.

References chunk_data, JoinColumn::elem_sz, index_inside_chunk, and join_column.

Referenced by compute_bucket_sizes_impl(), BoundingBoxIntersectKeyHandler::operator()(), and RangeKeyHandler::operator()().

                                                {
    return &chunk_data[index_inside_chunk * join_column->elem_sz];
  }

Here is the caller graph for this function:

Member Data Documentation

const int8_t* JoinColumnIterator::chunk_data

Definition at line 24 of file JoinColumnIterator.h.

Referenced by getElementSwitch(), operator bool(), operator++(), operator--(), and ptr().

size_t JoinColumnIterator::index

Definition at line 27 of file JoinColumnIterator.h.

Referenced by operator*(), operator++(), and operator--().

size_t JoinColumnIterator::index_inside_chunk

Definition at line 26 of file JoinColumnIterator.h.

Referenced by getElementSwitch(), operator++(), operator--(), and ptr().

size_t JoinColumnIterator::index_of_chunk

Definition at line 25 of file JoinColumnIterator.h.

Referenced by operator++(), and operator--().

struct JoinChunk* JoinColumnIterator::join_chunk_array

Definition at line 23 of file JoinColumnIterator.h.

Referenced by operator++(), and operator--().

const JoinColumn* JoinColumnIterator::join_column

Definition at line 21 of file JoinColumnIterator.h.

Referenced by ptr().

size_t JoinColumnIterator::start

Definition at line 28 of file JoinColumnIterator.h.

Referenced by TableFunctionsFactory_parser.Tokenize::add_token(), TableFunctionsFactory_parser.Tokenize::current_token(), JoinColumnIterator(), and TableFunctionsFactory_parser.Tokenize::tokenize().

size_t JoinColumnIterator::step

Definition at line 29 of file JoinColumnIterator.h.

Referenced by JoinColumnIterator(), operator++(), and operator--().

const JoinColumnTypeInfo* JoinColumnIterator::type_info

Definition at line 22 of file JoinColumnIterator.h.

Referenced by getElementSwitch().

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/JoinHashTable/Runtime/JoinColumnIterator.h