在 Python 中使用 Map-Reduce 实现 ARIMA 或 Holt Winter

Question

我正在尝试在不使用 StatsModel 包的情况下在 Hadoop 基础架构上使用 Python 中的 Map-Reduce 部署时间序列模型。但是，由于我是 Map-Reduce 编程的新手，所以我无法弄清楚如何实现一个。我做了一些关于滚动窗口方法的阅读。但仍然无法了解如何实施它。

我的数据集看起来像这样 -

Answer 1

代码分为四个部分，映射器、组合器、缩减器和包含所有类的文件 (slidingwindow.py)。我们使用滑动窗口方法来计算预测。组合器将所有预测成功的条目标记为“F”，无法填充窗口的条目标记为“B”和“E”。减速器预测标记为“B”和“E”的条目并产生输出。可以在此处找到 python 文件的链接 -https://github.com/abhiray92/mapreduce_arima/tree/main/Linux_Server