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	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 89 of file JoinColumnIterator.h.

89 : chunk_data(nullptr) {}

JoinColumnIterator::chunk_data

const int8_t * chunk_data

Definition: JoinColumnIterator.h:24

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

inline

Definition at line 91 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.

31 { return chunk_data; }

JoinColumnIterator::chunk_data

const int8_t * chunk_data

Definition: JoinColumnIterator.h:24

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 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(), and OverlapsKeyHandler::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++(), and ptr().

size_t JoinColumnIterator::index

Definition at line 27 of file JoinColumnIterator.h.

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

size_t JoinColumnIterator::index_inside_chunk

Definition at line 26 of file JoinColumnIterator.h.

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

size_t JoinColumnIterator::index_of_chunk

Definition at line 25 of file JoinColumnIterator.h.

Referenced by operator++().

struct JoinChunk* JoinColumnIterator::join_chunk_array

Definition at line 23 of file JoinColumnIterator.h.

Referenced by 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 JoinColumnIterator().

size_t JoinColumnIterator::step

Definition at line 29 of file JoinColumnIterator.h.

Referenced by JoinColumnIterator(), 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

Classes

Public Member Functions

Public Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation