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

Implementing ARIMA or Holt Winter's using Map-Reduce in Python

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

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

代码分为四个部分,映射器、组合器、缩减器和包含所有 类 的文件 (slidingwindow.py)。我们使用 滑动 Window 方法来计算预测。组合器将所有预测成功的条目标记为 'F',无法填充 window 的条目标记为 'B' 和 'E'。 reducer 预测标记为 'B' 和 'E' 的条目并生成输出。

link 到 python 文件可以在这里找到 -

https://github.com/abhiray92/mapreduce_arima/tree/main/Linux_Server