A.filter(condifionExpr:String):DataFrame
B.Join(right:DataFrame,joinExprs:Column):DataFrame
C.Intersect(other:DataFrame)
D.dropDuplicates():DataFrame
您可能感興趣的試卷
你可能感興趣的試題
A.Solr用戶組用戶可以創(chuàng)建配置集,并在創(chuàng)建Collection時指定該配置集
B.Solr用戶組的用戶可以創(chuàng)建Collection
C.Collection創(chuàng)建者、對該Collection具有讀寫權(quán)限的角色以及Solradmin
D.只有Collection創(chuàng)建者和Solradmin角色可以刪除Collection
A.CRC
B.Parquet
C.RCFile
D.TextFile
A.KafkaUtils.createStream(....)
B.KafkaUtils.createDirectStream(....)
C.StreamingContext.socketStream(....)
D.StreamingContext.fileStream(....)
A.Kafka集群安全訪問端口默認(rèn)為21007,非安全訪問端口默認(rèn)為21005
B.舊API通過21005端口訪問某個Topic的前ᨀ是:服務(wù)端參數(shù)allow.everyone.if.no.acl.found設(shè)置為true,且此Topic未設(shè)置ACL屬性
C.舊API僅支持訪問21005端口;新API兼容訪問非安全端口21005和安全端口21007
D.對于設(shè)置了ACL的Topic,可以使用舊API連接21005端口進(jìn)行訪問
最新試題
Fiume支持實時采集數(shù)據(jù)的source類型是哪項?()
在MapReduce應(yīng)用程序開發(fā)中,setMapOutputCompressorClass類的作用是什么?()
在通過Fusionlnsight manager界面創(chuàng)建用戶時,想要該用戶對所有Topic具有讀寫權(quán)限,但不具有常見Topic的權(quán)限,應(yīng)該加入Kafka服務(wù)的那個組?()
在Kafka中,關(guān)于Consumer說法正確的是()。
Fusionlnsight HD中,Streaming打包工具用于將業(yè)務(wù)代碼jar包和其他所依賴的jar包等,打包成一個完整的Streaming應(yīng)用的jar包。()
Oozie的workflow.xml文件是工作流配置文件。()
在Spark應(yīng)用開發(fā)中,以下哪項的代碼能正確進(jìn)行單詞統(tǒng)計?()
FusionLnsigt HD用戶想通過HBase shell操作來查詢某個HBase表中的內(nèi)容,這中場景下推薦管理員給這個用戶分配一個機(jī)機(jī)賬號。()
Fusionlnsight HD關(guān)于Oozie的作業(yè)操作命令,下列哪幾項敘述是正確的?()
對于HBase rowkey的設(shè)計原則,如下敘述正確的是?()