|| || || || || || || ||

---

Select.h

Go to the documentation of this file.

#ifndef Impala_Core_Table_Select_h
#define Impala_Core_Table_Select_h

#include "Core/Column/Select.h"
#include "Core/Column/FilterUnique.h"
#include "Core/Table/Filter.h"
#include "Core/Table/SelectOneColumn.h"

namespace Impala
{
namespace Core
{
namespace Table
{

template <class T1, class T2>
inline void
Select(T1* dst, T2* src, bool* filter, bool doClearDst)
{
    int srcSize = src->Size(); // keep orignal size in case dst == src
    if (doClearDst)
        dst->SetSize(0);
    int nr = 0;
    if (filter)
    {
        for (int i=0 ; i<srcSize ; i++)
            if (filter[i])
                nr++;
    }
    else
    {
        nr = srcSize;
    }
    dst->ReserveMin(dst->Size() + nr, true);
    Column::Select(dst->GetColumn1(), src->GetColumn1(), filter, dst->Size(), 0,
                   srcSize);
    Column::Select(dst->GetColumn2(), src->GetColumn2(), filter, dst->Size(), 0,
                   srcSize);
    Column::Select(dst->GetColumn3(), src->GetColumn3(), filter, dst->Size(), 0,
                   srcSize);
    Column::Select(dst->GetColumn4(), src->GetColumn4(), filter, dst->Size(), 0,
                   srcSize);
    Column::Select(dst->GetColumn5(), src->GetColumn5(), filter, dst->Size(), 0,
                   srcSize);
    Column::Select(dst->GetColumn6(), src->GetColumn6(), filter, dst->Size(), 0,
                   srcSize);
    Column::Select(dst->GetColumn7(), src->GetColumn7(), filter, dst->Size(), 0,
                   srcSize);
    Column::Select(dst->GetColumn8(), src->GetColumn8(), filter, dst->Size(), 0,
                   srcSize);
    Column::Select(dst->GetColumn9(), src->GetColumn9(), filter, dst->Size(), 0,
                   srcSize);
    dst->SetSize(dst->Size() + nr);
}

template <class T>
inline void
Select(T* dst, T* src, int from, int to, bool doClearDst)
{
    int size = src->Size();
    bool* filter = new bool[size];
    for(int i=0 ; i<from ; ++i)
        filter[i] = false;
    for(int i=from ; i<to ; ++i)
        filter[i] = true;
    for(int i=to ; i<size ; ++i)
        filter[i] = false;

    Select(dst, src, filter, doClearDst);
}


template <class T1, class T2, class Criterion> 
void
Select(T1* dst, T2* src, Criterion& c, bool doClearDst)
{
    bool* filter = Filter(src, c);
    Select(dst, src, filter, doClearDst);
    delete filter;
}

template <class T, class Criterion> 
T*
Select(T* src, Criterion& c)
{
    bool* filter = Filter(src, c);
    T* dst = new T();
    Select(dst, src, filter, false);
    delete filter;
    return dst;
}

template <class T1, class T2>
inline void
SelectUniqueOnCol(T1* dst, T2* src, int col, bool doClearDst)
{
    if (doClearDst)
        dst->SetSize(0);
    bool* filter = 0;
    switch (col) {
    case 1:
        Column::FilterUnique(filter, dst->GetColumn1(), src->GetColumn1(),
                             dst->Size(), src->Size());
        break;
    case 2:
        Column::FilterUnique(filter, dst->GetColumn2(), src->GetColumn2(),
                             dst->Size(), src->Size());
        break;
    case 3:
        Column::FilterUnique(filter, dst->GetColumn3(), src->GetColumn3(),
                             dst->Size(), src->Size());
        break;
    case 4:
        Column::FilterUnique(filter, dst->GetColumn4(), src->GetColumn4(),
                             dst->Size(), src->Size());
        break;
    case 5:
        Column::FilterUnique(filter, dst->GetColumn5(), src->GetColumn5(),
                             dst->Size(), src->Size());
        break;
    case 6:
        Column::FilterUnique(filter, dst->GetColumn6(), src->GetColumn6(),
                             dst->Size(), src->Size());
        break;
    case 7:
        Column::FilterUnique(filter, dst->GetColumn7(), src->GetColumn7(),
                             dst->Size(), src->Size());
        break;
    case 8:
        Column::FilterUnique(filter, dst->GetColumn8(), src->GetColumn8(),
                             dst->Size(), src->Size());
        break;
    case 9:
        Column::FilterUnique(filter, dst->GetColumn9(), src->GetColumn9(),
                             dst->Size(), src->Size());
        break;
    }

    int nr = 0;
    for (int i=0 ; i<src->Size() ; i++)
        if (filter[i])
            nr++;
    dst->ReserveMin(dst->Size() + nr, true); 

    Column::Select(dst->GetColumn1(), src->GetColumn1(), filter, dst->Size(), 0,
                   src->Size());
    Column::Select(dst->GetColumn2(), src->GetColumn2(), filter, dst->Size(), 0,
                   src->Size());
    Column::Select(dst->GetColumn3(), src->GetColumn3(), filter, dst->Size(), 0,
                   src->Size());
    Column::Select(dst->GetColumn4(), src->GetColumn4(), filter, dst->Size(), 0,
                   src->Size());
    Column::Select(dst->GetColumn5(), src->GetColumn5(), filter, dst->Size(), 0,
                   src->Size());
    Column::Select(dst->GetColumn6(), src->GetColumn6(), filter, dst->Size(), 0,
                   src->Size());
    Column::Select(dst->GetColumn7(), src->GetColumn7(), filter, dst->Size(), 0,
                   src->Size());
    Column::Select(dst->GetColumn8(), src->GetColumn8(), filter, dst->Size(), 0,
                   src->Size());
    Column::Select(dst->GetColumn9(), src->GetColumn9(), filter, dst->Size(), 0,
                   src->Size());
    dst->SetSize(dst->Size() + nr);
    delete filter;
}

} // namespace Table
} // namespace Core
} // namespace Impala

#endif

---