spark-ts TimeSeriesRDD - 如何创建每小时频率的 DateTimeIndex？

Question

我正在关注cloudera blog on using spark-ts for time series analysis in scala。我想创建一个每小时频率的 DateTimeIndex。博客中的示例显示了如何创建具有工作日频率的 DateTimeIndex，如下所示：

val dtIndex = DateTimeIndex.uniform(
  new DateTime("2015-08-03"), new DateTime("2015-09-22"), new BusinessDayFrequency(1))

我希望在github repository of DateTimeIndex.scala from author Sandy Ryza 中找到解决方案，但目前无法弄清楚。

我需要如何修改上面的示例以生成每小时频率的索引？

Answer 1

有一个HourFrequency 类：

val dtIndex = DateTimeIndex.uniform(
  new DateTime("2015-08-03"), new DateTime("2015-09-22"), new HourFrequency(1))

(https://github.com/sryza/spark-timeseries/blob/master/src/main/scala/com/cloudera/sparkts/Frequency.scala#L125-L129)