星火数据集相关

-3

我的数据集是由下面的代码星火数据集相关

+------+---------------+----+ 
| City|  Timestamp|Sale| 
+------+---------------+----+ 
|City 3|6/30/2017 16:04| 28| 
|City 4| 7/4/2017 16:04| 12| 
|City 2|7/13/2017 16:04| 8| 
|City 4|7/16/2017 16:04| 21| 
|City 4| 7/3/2017 16:04| 24| 
|City 2|7/17/2017 16:04| 34| 
|City 3| 7/9/2017 16:04| 13| 
|City 3|7/18/2017 16:04| 26| 
|City 3| 7/6/2017 16:04| 16| 
|City 3|7/15/2017 16:04| 29| 
|City 4|7/18/2017 16:04| 39| 
|City 2| 7/1/2017 16:04| 19| 
|City 2|7/18/2017 16:04| 19| 
|City 4| 7/4/2017 16:04| 24| 
|City 2| 7/4/2017 16:04| 9| 
|City 4|7/15/2017 16:04| 20| 
|City 3|7/12/2017 16:04| 19| 
|City 1| 7/9/2017 16:04| 13| 
|City 1|7/13/2017 16:04| 25| 
|City 4|7/10/2017 16:04| 10| 
+------+---------------+----+

我们需要计算在本周底部的每一City的Sale总和看起来像这样。

来源

2017-07-06 Ved Prakash

火花斯卡拉提供解决方案 –

您可以按City和Time stamp，总结了Sales

data.groupBy("City", "TimeStamp").agg(sum(col("Sale")).as("TotalSale")).show

希望这有助于！

来源

2017-07-06 05:10:13

嗨，它工作得很好，但我需要明智的一周即。明智的每个城市的销售总额 –

嗨，它工作正常，但我需要每周明智的总和即即每周我需要在每个城市的销售总额[城市1周五01/06/2017 \t 38] –

如何可能某人确定周从你给定的输入？ –

星火数据集相关

回答

相关问题