万佛，美国车顶上架个东西不违反交规吧？# PhotoGear - 摄影器材
b*5
1 楼
看了看documentation， examples， 都是些简单的basic operation， 比如count，
join， filter啊什么的。。。
我以前有个storm topology， 很多bolt， 其实就是一个asynchronous http call to
some other API。。。 但是在apache stream里，好像没有哪个transforming step是
能够asynchronous http call的？
比如我现在有这个
class Tweet {
id;
text;
language;
}
我现在tweet DStream， 要call 一个3rd party web API， 那个3rd party web api
要text， response会告诉我是什么language， 然后我save到Tweet class的language
field。
这个在apache spark里怎么搞啊？
join， filter啊什么的。。。
我以前有个storm topology， 很多bolt， 其实就是一个asynchronous http call to
some other API。。。 但是在apache stream里，好像没有哪个transforming step是
能够asynchronous http call的？
比如我现在有这个
class Tweet {
id;
text;
language;
}
我现在tweet DStream， 要call 一个3rd party web API， 那个3rd party web api
要text， response会告诉我是什么language， 然后我save到Tweet class的language
field。
这个在apache spark里怎么搞啊？
