回答此问题可获得 20 贡献值,回答如果被采纳可获得 50 分。
<p>我有一个rdd,看起来像这样:</p>
<pre><code>totalsrdd = [((2, 16),[[1,2,3,...,36],[2,2,3,...,36]]),((2,17),[[1,2,3,...,36]]),...]
</code></pre>
<p>键是天(2,16)等,它们分别对应一个或多个36个数字的列表。对于每个日期,我需要一个列表,其中列表中的第I个条目是每个列表中第I个条目的平均值。你知道吗</p>
<p>例如,对于(2,16),第一个条目的平均值为(1+2)/(36+36)或.04166,因为该日期有两个列表。你知道吗</p>
<pre><code>newRdd = [((2,16),[[.04166,.055555,.083333,...,1]]),(2,17),[[.027777,.055555,.083333,...,1]]),...]
</code></pre>
<p>因为(2,17)只有一个列表,所以列表中的每个条目都除以36。你知道吗</p>
<p>这是我目前掌握的密码。数据远不止两个日期。你知道吗</p>
<pre><code>def get_partition(x):
j = [(x[1][i]).total_seconds() for i in range(len(x[1]))]
return (x[0],j)
newTimeDeltaRdd2 = newtimeDeltaRdd.map(lambda x : ((x[1].month,x[1].day), x[0]))
totals = newTimeDeltaRdd2.map(lambda x: (get_partition(x)))
totalsrdd = totals.groupByKey().map(lambda x : (x[0], list(x[1])))
</code></pre>
<p>谢谢!你知道吗</p>