This diagram shows us the task of updating the data for the registered symbols:
The step-by-step instructions are as follows:
- Call the getBaseData() method from the IEXService Spring Bean to extract the up-to-date data of the given symbol.
- Call the getLatestHistoryData() method from the EsDataService Spring Bean to get the latest data from the cf_etf_history_data index.
- If the data in Elasticsearch needs to be updated, then call the anomalyDetection() method from the EsHadoopSparkService Spring Bean to predict the class label. Finally, we update the data into Elasticsearch.
We can update data for a given symbol; ...