Nowcasting the Financial Time Series with Streaming Data Analytics Under Apache Spark
摘要
This paper proposes nowcasting of high-frequency financial datasets in real-time with a 5-min interval using the streaming analytics feature of Apache Spark. The proposed 2-stage method consists of modelling chaos in the first stage followed by using a sliding window approach for separately training Lasso Regression (LR), Ridge Regression (RR), Generalized Linear Model (GLM), Gradient Boosting Tree (GBT) and Random Forest (RF) available in the MLLib library of Apache Spark in the second stage. The effectiveness of the proposed methodology is demonstrated on National Stock Exchange (NSE) dataset, Bombay Stock Exchange (BSE) dataset, and Bitcoin-INR conversion dataset. For evaluating the proposed methodology, we used measures such as Symmetric Mean Absolute Percentage Error (SMAPE), Directional Symmetry (DS) and Theil’s U Coefficient. We tested the statistical significance of the performance of the models using the Diebold Mariano (DM) test.