LbmSortedAggExecStream.cpp

Go to the documentation of this file.

/*
// $Id: //open/dev/fennel/lucidera/bitmap/LbmSortedAggExecStream.cpp#6 $
// Fennel is a library of data storage and processing components.
// Copyright (C) 2005-2009 LucidEra, Inc.
// Copyright (C) 2005-2009 The Eigenbase Project
//
// This program is free software; you can redistribute it and/or modify it
// under the terms of the GNU General Public License as published by the Free
// Software Foundation; either version 2 of the License, or (at your option)
// any later version approved by The Eigenbase Project.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
*/

#include "fennel/common/CommonPreamble.h"
#include "fennel/lucidera/bitmap/LbmSortedAggExecStream.h"
#include "fennel/exec/ExecStreamBufAccessor.h"
#include "fennel/lucidera/bitmap/LbmByteSegment.h"
#include "fennel/tuple/StandardTypeDescriptor.h"

FENNEL_BEGIN_CPPFILE("$Id: //open/dev/fennel/lucidera/bitmap/LbmSortedAggExecStream.cpp#6 $");

class LbmRepeatingAggComputer : public AggComputer
{
    AggComputer *pComputer;

public:
    explicit LbmRepeatingAggComputer(AggComputer *pComputer);

    // implement AggComputer
    virtual void setInputAttrIndex(uint iInputAttrIndex);

    virtual void clearAccumulator(
        TupleDatum &accumulatorDatum);

    virtual void updateAccumulator(
        TupleDatum &accumulatorDatum,
        TupleData const &inputTuple);

    virtual void computeOutput(
        TupleDatum &outputDatum,
        TupleDatum const &accumulatorDatum);

    // unused...
    virtual void initAccumulator(
        TupleDatum &accumulatorDatumDest,
        TupleData const &inputTuple);

    virtual void initAccumulator(
        TupleDatum &accumulatorDatumSrc,
        TupleDatum &accumulatorDatumDest);

    virtual void updateAccumulator(
        TupleDatum &accumulatorDatumSrc,
        TupleDatum &accumulatorDatumDest,
        TupleData const &inputTuple);
};

LbmRepeatingAggComputer::LbmRepeatingAggComputer(
    AggComputer *pComputer)
{
    this->pComputer = pComputer;
}

void LbmRepeatingAggComputer::setInputAttrIndex(uint iInputAttrIndex)
{
    AggComputer::setInputAttrIndex(iInputAttrIndex);
    pComputer->setInputAttrIndex(iInputAttrIndex);
}

void LbmRepeatingAggComputer::clearAccumulator(
    TupleDatum &accumulatorDatum)
{
    pComputer->clearAccumulator(accumulatorDatum);
}

void LbmRepeatingAggComputer::updateAccumulator(
    TupleDatum &accumulatorDatum,
    TupleData const &inputTuple)
{
    // segment data should be contained in the last field
    TupleDatum segmentDatum = inputTuple[inputTuple.size() - 1];
    uint loops = LbmByteSegment::countBits(segmentDatum);

    for (uint i = 0; i < loops; i++) {
        pComputer->updateAccumulator(accumulatorDatum, inputTuple);
    }
}

void LbmRepeatingAggComputer::computeOutput(
    TupleDatum &outputDatum,
    TupleDatum const &accumulatorDatum)
{
    pComputer->computeOutput(outputDatum, accumulatorDatum);
}

void LbmRepeatingAggComputer::initAccumulator(
    TupleDatum &accumulatorDatumDest,
    TupleData const &inputTuple)
{
    // sorted aggregates never use this call
    assert(false);
}

void LbmRepeatingAggComputer::initAccumulator(
    TupleDatum &accumulatorDatumSrc,
    TupleDatum &accumulatorDatumDest)
{
    // sorted aggregates never use this call
    assert(false);
}

void LbmRepeatingAggComputer::updateAccumulator(
    TupleDatum &accumulatorDatumSrc,
    TupleDatum &accumulatorDatumDest,
    TupleData const &inputTuple)
{
    // sorted aggregates never use this call
    assert(false);
}

void LbmSortedAggExecStream::prepare(
    LbmSortedAggExecStreamParams const &params)
{
    SortedAggExecStream::prepare(params);
}

AggComputer *LbmSortedAggExecStream::newAggComputer(
    AggFunction aggFunction,
    TupleAttributeDescriptor const *pAttrDesc)
{
    AggComputer *pComputer =
        SortedAggExecStream::newAggComputer(aggFunction, pAttrDesc);

    switch (aggFunction) {
    case AGG_FUNC_COUNT:
    case AGG_FUNC_SUM:
        pComputer = new LbmRepeatingAggComputer(pComputer);
    default:
        ;
    }
    return pComputer;
}

FENNEL_END_CPPFILE("$Id: //open/dev/fennel/lucidera/bitmap/LbmSortedAggExecStream.cpp#6 $");

// End LbmSortedAggExecStream.cpp

---