真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

Storm使用非JVM的語言

Storm使用非JVM的語言
要點(diǎn):
1、創(chuàng)建topology(官方文檔說使用其他語言創(chuàng)建很簡單,因?yàn)閠opology本身是一個(gè)thrift結(jié)構(gòu),參考stotm.thrift)
2、用其他語言實(shí)現(xiàn)spout和bolt,被叫做 multilang components" 或"shelling"
a:這里有一個(gè)指定的協(xié)議Multilang protocol
b:thrift結(jié)構(gòu)允許你明確的定義multilang components作為程序和腳本
c:在Java中,你覆蓋ShellBolt或ShellSpolt來創(chuàng)建multilang components,注意輸出字段的聲明發(fā)生在thrift結(jié)構(gòu),所以在Java中創(chuàng)建multilang components如下所示:通過指定它在Java中聲明領(lǐng)域,用其他語言處理代碼指定shellbolt的結(jié)構(gòu),multilang使用JSON消息在標(biāo)準(zhǔn)輸入/輸出與子進(jìn)程進(jìn)行通信,storm伴隨ruby、python和其他語言實(shí)現(xiàn)協(xié)議,展示一個(gè)python的例子:
    python支持emitting, anchoring, acking, and logging
d:storm shell使得對nimbus打jar包和上傳更方便
    打jar包,上傳
    調(diào)用程序nimbus使用host/port,jar文件使用id號

樂山網(wǎng)站建設(shè)公司創(chuàng)新互聯(lián),樂山網(wǎng)站設(shè)計(jì)制作,有大型網(wǎng)站制作公司豐富經(jīng)驗(yàn)。已為樂山1000多家提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\成都外貿(mào)網(wǎng)站制作要多少錢,請找那個(gè)售后服務(wù)好的樂山做網(wǎng)站的公司定做!


為Storm定義一個(gè)非JVM的語言
    因?yàn)镾torm topology是一個(gè)thrift結(jié)構(gòu),并且nimbus是一個(gè)thrift進(jìn)程,你可創(chuàng)建和提交topology用任何語言,開始學(xué)習(xí)的地方是storm.thrift。當(dāng)你為spout和bolt創(chuàng)建thrift結(jié)構(gòu)時(shí),spolt和bolt指定的代碼結(jié)構(gòu)是:
union ComponentObject {
  1: binary serialized_java;
  2: ShellComponent shell;
  3: JavaObject java_object;
}
使用非jvm的語言,你可能會使用2或3.ShellCompont讓你指定腳本去運(yùn)行,JavaObject讓你指定java的spolt和bolt,storm shell命令幫你提交topology
storm shell resources/ python topology.py arg1 arg2

storm shell 將打jar包,上傳jar包給nimbus,命令如下:
python topology.py arg1 arg2 {nimbus-host} {nimbus-port} {uploaded-jar-location}

提交topology到集群上
void submitTopology(1: string name, 2: string uploadedJarLocation, 3: string jsonConf, 4: StormTopology topology) throws (1: AlreadyAliveException e, 2: InvalidTopologyException ite);


網(wǎng)站欄目:Storm使用非JVM的語言
URL鏈接:http://weahome.cn/article/gdpigi.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220(工作日)

18980820575(7×24)

提交需求

返回頂部