我正在学习Python,这样我就可以很容易地修改了。我知道Java和C++,但是我发现仓库上的AIMA代码太模糊了。Python代码看起来更简单,更elegant...yet,我不知道Python。我想导入中的函数。我尝试创建一个search2.py文件,如下所示: pass~/aimapy", line 3, in
serverLocations), new Fields("count")我如何在Spark Streaming中实现同样的功能呢?我研究了一下updateStateByKey,但这似乎可以无限期地将状态保持在内部(而不是像Memcached那样将其保持在外部状态)。当我使用saveAsTextFile保存它时,它看起来也试