StreamingDotFeatures.h

Go to the documentation of this file.

/*
 * 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 3 of the License, or
 * (at your option) any later version.
 *
 * Written (W) 2011 Shashwat Lal Das
 * Copyright (C) 2011 Berlin Institute of Technology and Max-Planck-Society
 */
#ifndef _STREAMING_DOTFEATURES__H__
#define _STREAMING_DOTFEATURES__H__

#include <shogun/lib/common.h>
#include <shogun/lib/Time.h>
#include <shogun/mathematics/Math.h>
#include <shogun/features/StreamingFeatures.h>
#include <shogun/features/DotFeatures.h>
#include <shogun/io/StreamingFile.h>

namespace shogun
{
class CStreamingDotFeatures : public CStreamingFeatures
{

    virtual void init() { };

    virtual void init(CStreamingFile *file, bool is_labelled, int32_t size) { };

public:
    CStreamingDotFeatures()
        : CStreamingFeatures()
    {
        init();
        set_property(FP_STREAMING_DOT);
    }

    CStreamingDotFeatures(CStreamingFile* file, bool is_labelled, int32_t size)
        : CStreamingFeatures()
    {
        init(file, is_labelled, size);
        set_property(FP_STREAMING_DOT);
    }

    CStreamingDotFeatures(CDotFeatures* dot_features, float64_t* lab=NULL)
    {
        SG_NOTIMPLEMENTED;
        return;
    }

    virtual ~CStreamingDotFeatures() { }

    virtual float32_t dot(CStreamingDotFeatures* df)=0;

    virtual float32_t dense_dot(const float32_t* vec2, int32_t vec2_len)=0;

    virtual void dense_dot_range(float32_t* output, float32_t* alphas, float32_t* vec, int32_t dim, float32_t b, int32_t num_vec=0)
    {
        ASSERT(num_vec>=0);

        int32_t counter=0;
        start_parser();
        while (get_next_example())
        {
            if (alphas)
                output[counter]=alphas[counter]*dense_dot(vec, dim)+b;
            else
                output[counter]=dense_dot(vec, dim)+b;

            release_example();

            counter++;
            if ((counter>=num_vec) && (num_vec>0))
                break;
        }
        end_parser();
    }

    virtual void add_to_dense_vec(float32_t alpha, float32_t* vec2, int32_t vec2_len, bool abs_val=false)=0;

    inline virtual void expand_if_required(float32_t*& vec, int32_t &len)
    {
        int32_t dim = get_dim_feature_space();
        if (dim > len)
        {
            vec = SG_REALLOC(float32_t, vec, dim);
            memset(&vec[len], 0, (dim-len) * sizeof(float32_t));
            len = dim;
        }
    }

    inline virtual void expand_if_required(float64_t*& vec, int32_t &len)
    {
        int32_t dim = get_dim_feature_space();
        if (dim > len)
        {
            vec = SG_REALLOC(float64_t, vec, dim);
            memset(&vec[len], 0, (dim-len) * sizeof(float64_t));
            len = dim;
        }
    }

    virtual int32_t get_dim_feature_space() const=0;

    virtual void* get_feature_iterator()
    {
        SG_NOTIMPLEMENTED;
        return NULL;
    }

    virtual int32_t get_nnz_features_for_vector()
    {
        SG_NOTIMPLEMENTED;
        return -1;
    }

    virtual bool get_next_feature(int32_t& index, float32_t& value, void* iterator)
    {
        SG_NOTIMPLEMENTED;
        return false;
    }

    virtual void free_feature_iterator(void* iterator)
    {
        SG_NOTIMPLEMENTED;
        return;
    }


protected:

    float32_t combined_weight;
};
}
#endif // _STREAMING_DOTFEATURES__H__