tafel.h

Go to the documentation of this file.

// File: $Id$
// Author: John Wu <John.Wu at ACM.org>
// Copyright 2007-2012 the Regents of the University of California
#ifndef IBIS_TAFEL_H
#define IBIS_TAFEL_H
#include "table.h"      // ibis::table
#include "bitvector.h"  // ibis::bitvector


namespace ibis {
    class tafel;
}

class ibis::tafel : public ibis::tablex {
public:
    tafel() : mrows(0U) {}
    virtual ~tafel() {clear();}

    virtual int addColumn(const char* cname, ibis::TYPE_T ctype,
                          const char* cdesc, const char* idx);
    virtual int SQLCreateTable(const char *stmt, std::string&);

    virtual int append(const char* cname, uint64_t begin, uint64_t end,
                       void* values);
    virtual int appendRow(const ibis::table::row&);
    virtual int appendRow(const char*, const char*);
    virtual int appendRows(const std::vector<ibis::table::row>&);
    virtual int readCSV(const char* filename, int maxrows,
                        const char* outputdir, const char* delimiters);
    virtual int readSQLDump(const char* filename, std::string& tname,
                            int maxrows, const char* outputdir);

    virtual int write(const char* dir, const char* tname=0,
                      const char* tdesc=0, const char* idx=0,
                      const char* nvpairs=0) const;
    virtual int writeMetaData(const char* dir, const char* tname=0,
                              const char* tdesc=0, const char* idx=0,
                              const char* nvpairs=0) const;

    virtual void clearData();
    virtual int32_t reserveSpace(uint32_t);
    virtual uint32_t capacity() const;

    virtual uint32_t mRows() const {return mrows;}
    virtual uint32_t mColumns() const {return cols.size();}
    virtual void describe(std::ostream&) const;
    virtual table* toTable(const char* nm=0, const char* de=0);

    struct column {
        std::string name;
        std::string desc;
        std::string indexSpec;
        ibis::TYPE_T type;
        void* values;
        ibis::array_t<int64_t> starts;
        void* defval;
        ibis::bitvector mask;

        column();
        ~column();
    }; // column
    typedef std::map<const char*, column*, ibis::lessi> columnList;
    const columnList& getColumns() const {return cols;}

protected:
    columnList cols;
    std::vector<column*> colorder;
    ibis::bitvector::word_t mrows;

    void clear();

    void normalize();

    template <typename T>
    void append(const T* in, ibis::bitvector::word_t be,
                ibis::bitvector::word_t en, array_t<T>& out,
                const T& fill, ibis::bitvector& mask) const;
    void appendString(const std::vector<std::string>* in,
                      ibis::bitvector::word_t be,
                      ibis::bitvector::word_t en,
                      std::vector<std::string>& out,
                      ibis::bitvector& mask) const;
    void appendRaw(const ibis::array_t<unsigned char>* in,
                   ibis::bitvector::word_t be,
                   ibis::bitvector::word_t en,
                   std::vector<std::string>& out,
                   ibis::bitvector& mask) const;

    template <typename T>
    void locate(ibis::TYPE_T, std::vector<array_t<T>*>& buf,
                std::vector<ibis::bitvector*>& msk) const;
    void locateString(ibis::TYPE_T t,
                      std::vector<std::vector<std::string>*>& buf,
                      std::vector<ibis::bitvector*>& msk) const;
    template <typename T>
    void append(const std::vector<std::string>& nm, const std::vector<T>& va,
                std::vector<array_t<T>*>& buf,
                std::vector<ibis::bitvector*>& msk);
    void appendString(const std::vector<std::string>& nm,
                      const std::vector<std::string>& va,
                      std::vector<std::vector<std::string>*>& buf,
                      std::vector<ibis::bitvector*>& msk);
    int parseLine(const char* str, const char* del, const char* id);

    int32_t doReserve(uint32_t);
    int assignDefaultValue(ibis::tafel::column &col, const char *val) const;
    int readSQLStatement(std::istream &, ibis::fileManager::buffer<char>&,
                         ibis::fileManager::buffer<char>&) const;
    uint32_t preferredSize() const;

private:
    tafel(const tafel&);
    tafel& operator=(const tafel&);
}; // class ibis::tafel
#endif // IBIS_TAFEL_H