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

---

VirtualFeatureTableIOBufferReader.h

Go to the documentation of this file.

#ifndef Impala_Core_Feature_VirtualFeatureTableIOBufferReader_h
#define Impala_Core_Feature_VirtualFeatureTableIOBufferReader_h

#include "Core/Feature/VirtualFeatureTable.h"
#include "Core/Matrix/VirtualMatrixIOBufferReader.h"
#include "Core/Column/Read.h"

namespace Impala
{
namespace Core
{
namespace Feature
{


class VirtualFeatureTableIOBufferReader : public VirtualFeatureTable
{
public:

    VirtualFeatureTableIOBufferReader(Util::IOBuffer* buffer, bool ownBuffer)
    {
        Init(buffer, ownBuffer);
    }

    virtual
    ~VirtualFeatureTableIOBufferReader()
    {
        delete mMatrix;
        mMatrix = 0;
        if (mOwnBuffer)
        {
            delete mIOBuffer;
            mIOBuffer = 0;
        }
    }

    virtual int
    Size() const
    {
        return mSize;
    }

    virtual void
    GetQuids(Table::QuidTable* quids)
    {
        mIOBuffer->SetPosition(mBaseOffset + mQuidsOffset);
        Column::Read(quids->GetColumn1(), mIOBuffer);
        quids->SetSize(Size());
    }

    virtual int
    GetVectorLength() const
    {
        return mVectorLength;
    }

private:

    virtual int
    GetVectorImpl(int rowNr, Real64* buffer, int bufferSize)
    {
        return mMatrix->GetRow(rowNr, buffer, bufferSize);
    }

    void
    Init(Util::IOBuffer* buffer, bool ownBuffer)
    {
        mIOBuffer = buffer;
        mOwnBuffer = ownBuffer;
        mBaseOffset = buffer->GetPosition();

        mIOBuffer->SetPosition(mBaseOffset + 1024);
        Int64 footer[16];
        Int64 nRead = mIOBuffer->Read(footer, sizeof(Int64) * 16);
        mSize = footer[3];
        mQuidsOffset = footer[4];
        mIOBuffer->SetPosition(mBaseOffset + footer[5]);
        mMatrix = new Core::Matrix::VirtualMatrixIOBufferReader<Matrix::Mat>
                                                             (mIOBuffer, false);
        mVectorLength = mMatrix->NrCol();
    }

    Util::IOBuffer*        mIOBuffer;
    bool                   mOwnBuffer;
    Int64                  mBaseOffset;
    Int64                  mQuidsOffset;
    Int64                  mSize;
    Int64                  mVectorLength;
    Matrix::VirtualMatrix* mMatrix;

    ILOG_VAR_DEC;
};

ILOG_VAR_INIT(VirtualFeatureTableIOBufferReader, Impala.Core.Feature);

} // namespace Feature
} // namespace Core
} // namespace Impala

#endif

---