public interface IAnalysisService {

// map of appdelegates to connectedThingClient instances. The values are added internally by AnalysisSdk
// framework...do not modify or
// access this field explicitly, use GetClient to get the client instance
static final Map<Integer, PrivateObservable> appDelToObservable = new Hashtable<Integer, PrivateObservable>();
static final Logger LOG = LoggerFactory.getLogger(IAnalysisService.class);


long GetPid();

// Must return array of JSON objects with name, type and value attributes
default JSONArray GetPerformanceData() {
return null;
}

// [Description("Initialize the Application")]
// It is expected that the application will populate models with already deployed models in this call
public default void Initialize(Map<String, Object> initParams) {};

// [Description("Shutdown the Compute Engine/Application gracefully")]
// It is expected that the delegate will stop the compute engine/application and return only when the instance is
// stopped
public default void Shutdown() {};

// [Description("Return information about the application that is being exposed over REST. ")]
public ServiceInfo GetServiceInfo();

// [Description("Allow upload of models. The file(s) are uploaded as a multi-part message. ")]
public Model DeployModel(Model data) throws Exception;

// [Description("Return only the data structure of the inputs that the model requires")]
public ParamField[] GetInputData(String modelName);

// [Description("Return the data structure of the results that the model generates.")]
public ParamField[] GetResultData(String modelName);

// [Description("Submit a job for processing. The request indicates whether the job should be executed "+"synchronously or asynchronously")]
public Job PostJob(Job jb) throws Exception;

public default boolean AbortJob(String jobId) throws Exception {
// by default do nothing
return true;
}

public Job StartJob(Job jb) throws Exception;

public void UpdateJob(String jobId, JSONObject updatedProps) throws Exception;
public void UpdateJob(String jobId, JSONArray updatedProps) throws Exception;

public boolean StopJob(String jobId) throws Exception;

// [Description("Return requested result file for the given job id")]
public File GetJobResultFile(String id, String resultFileName) throws Exception;

public default PrivateObservable getObservable() {
if (appDelToObservable.containsKey(this.hashCode()))
return appDelToObservable.get(this.hashCode());
else {
PrivateObservable p = new PrivateObservable();
appDelToObservable.put(this.hashCode(), p);
return p;
}
}

public default void addObserver(Observer o) {
getObservable().addObserver(o);
}

public default void ReturnUpdate(Object o) {
getObservable().setChanged();
getObservable().notifyObservers(o);
}

// simply make setChanged public, and therefore usable in delegation
class PrivateObservable extends Observable {
@Override
public void setChanged() {
super.setChanged();
}
}

public default void processMessage(JSONObject payLoad) throws Exception {
};

public default String getClientId() {
return null;
}

public default void DeleteModel(Model model) throws Exception {};

}