ObservableInterfaceProxy.h

Go to the documentation of this file.

#ifndef OBSERVABLE_INTERFACE_PROXY_H
#define OBSERVABLE_INTERFACE_PROXY_H
 
#include <vector>
#include <stdexcept>
 
#include "ports/IModel.h"
#include "ObservableInterface.h"
#include "StatParamOptimizerProxy.h"
#include "StatParameterProxy.h"
#include "IStatParamOptimizerProxy.h"
 
class ObservableInterfaceProxy final : public IModel {
public:
    ObservableInterfaceProxy(
    std::shared_ptr<ObservableInterface> obs,
    std::vector<ParamId> p_specs,
    std::vector<ParamId> eta_specs);
    
    ObservableInterfaceProxy(std::shared_ptr<ObservableInterface> obs, std::shared_ptr<IStatParamOptimizerProxy> spop);
 
    std::shared_ptr<IModel> clone_for_worker() const override;
 
    bool can_clone_for_worker() const override { return true; }
 
    std::unique_ptr<IModelThreadGuard> force_decay_threads(size_t n_threads) override;
 
    std::size_t n_observables() const override;
 
    void prepare_for_prediction() override;
 
    std::unordered_set<ParamId> get_obs_deps(ObservableId id) override;
 
    std::vector<BinnedObservableId> get_obs_ids() override;
 
    std::map<ObservableId, std::vector<ObservableValue>> predict_optimized(
        const std::map<ParamId, double>& p,
        const std::map<ParamId, double>& eta) override;
 
    void compute_observables() const;
 
private:
    std::shared_ptr<ObservableInterface> oi_;             
    std::shared_ptr<IStatParamOptimizerProxy> spop_;      
    std::vector<ParamId> p_specs_;                        
    std::vector<ParamId> eta_specs_;                      
};
 
#endif