RDD_1 には、次のような行が含まれます。
(u'id2875421', 2, datetime.datetime(2016, 3, 14, 17, 24, 55), datetime.datetime(2016, 3, 14, 17, 32, 30), 1, -73.9821548461914, 40.76793670654297, -73.96463012695312, 40.765602111816406, u'N', 455)
RDD_2 には、次のような行が含まれます。
(u'id2875421', 1.9505895451732258)
私がやろうとしているのは、次の形式でrddを取得することです
(u'id2875421', 2, datetime.datetime(2016, 3, 14, 17, 24, 55), datetime.datetime(2016, 3, 14, 17, 32, 30), 1, 1.9505895451732258, u'N', 455)
そのため、場所の列を距離の列に置き換えようとしています。
rdd1.join(rdd2) は私に与えます:
(u'id1585324', (1, 0.9773030754631484))
そして rdd1.union(rdd2) は私に与えます:
(u'id2875421', 2, datetime.datetime(2016, 3, 14, 17, 24, 55), datetime.datetime(2016, 3, 14, 17, 32, 30), 1, -73.9821548461914, 40.76793670654297, -73.96463012695312, 40.765602111816406, u'N', 455)