《大數(shù)據(jù)實(shí)時(shí)流計(jì)算》期末考試復(fù)習(xí)題庫(kù)（含答案）單選題1.在Scala中執(zhí)行并發(fā)的主要類是？A、ThreadB、FutureC、ActorD、Task參考答案：B2.在Scala中如何定義一個(gè)空集合？A、valemptyList=List（）B、valemptyList=newList（）C、valemptyList=nullD、以上都不正確參考答案：A3.在Scala中，用于篩選集合的函數(shù)是？A、filterB、selectC、ollectD、choice參考答案：A4.在Scala中，用于排列集合的函數(shù)是？A、groupByB、sortC、arrangeD、orderBy參考答案：B5.在Scala中，用于定義隱式參數(shù)的關(guān)鍵字是？A、implicitB、hiddenC、optionalD、hiddenparam參考答案：A6.在Scala中，用于定義抽象類的關(guān)鍵字是？A、bstractB、traitC、lassD、efine參考答案：A7.在Scala中，修改List元素的函數(shù)是？A、ppendB、addC、updateD、List是不可變的參考答案：D8.在Scala中，使用future的主要目的是？A、處理異步計(jì)算B、實(shí)現(xiàn)遞歸C、導(dǎo)入包D、定義類型參考答案：A9.在Scala中，什么是Tuple？A、有序的值組合B、可以更改的集合C、不可變的映射D、以上均不正確參考答案：A10.在Scala中，如何將集合中的元素進(jìn)行映射？A、mapB、transformC、modifyD、change參考答案：A11.在Scala中，如何合并兩個(gè)集合？A、concatB、mergeC、++D、union參考答案：C12.在Scala中，如何定義一個(gè)匿名函數(shù)？A、def（x:Int）=x+1B、x=>x+1C、function（x:Int）{x+1}D、lambda{x=>x+1}參考答案：B13.在Scala中，如何定義一個(gè)可變的Map？A、varmyMap=Map（）B、varmyMap=collection.mutablMap（）C、varmyMap=newMap（）D、以上都不正確參考答案：B14.在Scala中，如何定義一個(gè)高階函數(shù)？A、defhigherOrder（f:Int=>Int）=f（10）B、defhigherOrder（f:Int）=f=>f＋1C、defhigherOrder（f）=f（10）D、functionhigherOrder（f:Int=>Int）=f（10）參考答案：A15.在Scala中，如何定義一個(gè)不可變的變量？A、varB、valC、defD、let參考答案：B16.在Scala中，如何定義默認(rèn)參數(shù)？A、deffunc（x:Int=0）{}B、deffunc（x:Int）:0{}C、deffunc（x=0）:Int{}D、effunc（x:Intdefaultsto0）{}參考答案：A17.在Scala中，如何導(dǎo)入一個(gè)包？A、includeB、requireC、importD、use參考答案：C18.在Scala中，如何從Map中獲取一個(gè)值？A、map.get（key）B、map（key）C、map.index（key）D、以上都可以參考答案：D19.在Scala中，如何表示可選值？A、MaybeB、OptionC、NullableD、Either參考答案：B20.在Scala中，哪些數(shù)據(jù)結(jié)構(gòu)是不可變的？A、List和SetB、Array和ArrayBufferC、StringBuilder和BufferD、以上都是參考答案：A21.在Scala中，模式匹配使用哪個(gè)關(guān)鍵字？A、caseB、matchC、ifD、switch參考答案：B22.在Scala中，表示單例對(duì)象的關(guān)鍵字是？A、classB、objectC、traitD、singleton參考答案：B23.在Scala中，Unit的作用是什么？A、表示一個(gè)值的類型B、表示無(wú)值C、表示空集合D、以上都不正確參考答案：B24.在Scala中，tailrec注解的作用是？A、顯示錯(cuò)誤B、提高性能C、確保尾遞歸D、防止內(nèi)存泄漏參考答案：C25.在Scala中，sealed關(guān)鍵字用于定義什么？A、包B、類層次結(jié)構(gòu)C、訪問(wèn)權(quán)限D(zhuǎn)、抽象類參考答案：B26.在Scala中，match語(yǔ)句的功能類似于哪個(gè)其他結(jié)構(gòu)？A、if-elseB、switch-caseC、loopD、try-catch參考答案：B27.在Scala中，List的操作通常是？A、像數(shù)組一樣可變B、不可變的C、有序的D、以上都正確參考答案：D28.在Scala中，lazyval的作用是什么？A、立即初始化B、延遲初始化C、可變變量D、定義私有變量參考答案：B29.在Scala中，implicit關(guān)鍵字的作用是？A、隱式類型轉(zhuǎn)換B、限制訪問(wèn)權(quán)限C、定義懶加載D、定義常量參考答案：A30.在Scala中，deprecated注解用于標(biāo)記什么？A、不再使用的代碼B、運(yùn)行時(shí)錯(cuò)誤C、需要優(yōu)化的代碼D、可改進(jìn)的類型參考答案：A31.在Flink中，執(zhí)行計(jì)劃的構(gòu)建和優(yōu)化是在哪個(gè)階段完成的？A、作業(yè)提交時(shí)B、作業(yè)運(yùn)行時(shí)C、編譯時(shí)D、數(shù)據(jù)讀取時(shí)參考答案：A32.在Flink中，用于指定作業(yè)并行度的配置參數(shù)是什么？A、parallelismB、execution-modeC、cess.sizeD、cess.size參考答案：A33.在Flink中，用于執(zhí)行流計(jì)算作業(yè)的環(huán)境是什么？A、StreamExecutionEnvironmentB、atchExecutionEnvironmentC、ExecutionEnvironmentD、ClusterEnvironment參考答案：A34.在Flink中，用于表示批處理數(shù)據(jù)的基本抽象是什么？（注意：此題基于Flink早期版本，F(xiàn)link1.12+已逐步統(tǒng)一為DataStream）A、DataStreamB、DataSetC、ExecutionEnvironmentD、ExecutionPlan參考答案：B35.在Flink中，以下哪種狀態(tài)后端用于在內(nèi)存中存儲(chǔ)狀態(tài)？（）A、MemoryStateBackendB、FsStateBackendC、RocksDBStateBackendD、None參考答案：A36.在Flink中，以下哪種數(shù)據(jù)類型用于表示時(shí)間戳？（）A、LongB、DoubleC、TimestD、ate參考答案：C37.在Flink中，以下哪種數(shù)據(jù)結(jié)構(gòu)用于表示流中的元素？（）A、TupleB、ListC、MapD、Set參考答案：A38.在Flink中，以下哪種時(shí)間語(yǔ)義表示數(shù)據(jù)的產(chǎn)生時(shí)間？（）A、事件時(shí)間（EventTimeB、攝入時(shí)間（IngestionTimeC、處理時(shí)間（ProcessintimeD、系統(tǒng)時(shí)間（SystemTime參考答案：A39.在Flink中，以下哪種機(jī)制用于保證數(shù)據(jù)的一致性和可靠性？（）A、檢查點(diǎn)（Checkpoint）B、容錯(cuò)機(jī)制C、分布式協(xié)調(diào)D、以上都是參考答案：D40.在Flink中，以下哪種方式用于配置Flink作業(yè)的并發(fā)度？（）A、在代碼中設(shè)置并行度參數(shù)B、通過(guò)配置文件設(shè)置C、在集群管理器中設(shè)置D、以上都是參考答案：D41.在Flink中，以下哪種方式用于定義流計(jì)算的數(shù)據(jù)源？A、使用SourceFunction接口B、配置文件C、手動(dòng)編寫數(shù)據(jù)D、以上都不是參考答案：A42.在Flink中，以下哪種方式用于定義流計(jì)算的數(shù)據(jù)源？（）A、使用SourceFunction接口B、配置文件C、手動(dòng)編寫數(shù)據(jù)D、以上都不是參考答案：A43.在Flink中，以下哪種方式用于處理有界數(shù)據(jù)流？（）A、僅使用窗口函數(shù)B、僅使用狀態(tài)后端C、結(jié)合窗口函數(shù)和狀態(tài)后端D、以上都不對(duì)參考答案：C44.在Flink中，以下哪種窗口類型用于按照時(shí)間進(jìn)行劃分？（）A、滾動(dòng)窗口（TumblingWindow）B、滑動(dòng)窗口（SlidingWindow）C、會(huì)話窗口（SessionWindow）D、以上都是參考答案：D45.在Flink中，以下哪個(gè)API用于創(chuàng)建執(zhí)行流計(jì)算作業(yè)的環(huán)境？A、BatchExecutionEnvironmentB、StreamExecutionEnvironmentC、ExecutionEnvironmentD、ClusterEnvironment參考答案：B46.在Flink中，如何設(shè)置作業(yè)的重啟策略？A、通過(guò)配置文件B、通過(guò)命令行參數(shù)C、通過(guò)代碼中的APID、以上都可以參考答案：C47.在Flink中，如何獲取一個(gè)作業(yè)的執(zhí)行計(jì)劃？A、通過(guò)配置文件B、通過(guò)命令行參數(shù)C、通過(guò)FlinkWeUID、通過(guò)代碼中的API參考答案：C48.在Flink中，如何獲取一個(gè)作業(yè)的執(zhí)行計(jì)劃？A、通過(guò)配置文件B、通過(guò)命令行參數(shù)C、通過(guò)FlinkWebUID、通過(guò)代碼中的API（如ExecutionPlan，但需注意ExecutionPlan在Flink1.12+中已被淘汰）參考答案：C49.在Flink中，如何管理作業(yè)的狀態(tài)？A、通過(guò)配置文件B、通過(guò)命令行參數(shù)C、通過(guò)狀態(tài)后端（StateBackend）D、通過(guò)代碼中的API參考答案：C50.在Flink中，如何觸發(fā)一個(gè)窗口的計(jì)算？A、當(dāng)窗口內(nèi)數(shù)據(jù)達(dá)到指定數(shù)量時(shí)B、當(dāng)窗口時(shí)間到達(dá)時(shí)C、當(dāng)窗口內(nèi)數(shù)據(jù)或時(shí)間滿足指定條件時(shí)D、手動(dòng)觸發(fā)參考答案：C51.以下哪個(gè)選項(xiàng)不是Flink支持的窗口類型？A、滾動(dòng)窗口B、全局窗口C、滑動(dòng)窗口D、靜態(tài)窗口參考答案：D52.如何在Scala中訪問(wèn)數(shù)組的元素？A、rr.get（0）B、arr（0）C、arr[0]D、arr.index（0）參考答案：B53.如何在Scala中定義一個(gè)伴生對(duì)象？A、classMyClass{objectMyClass{}}B、objectMyClass{}C、lassMyClasscompanion{}D、traitMyClasscompanion{}參考答案：A54.哪個(gè)庫(kù)允許在Scala中進(jìn)行并行處理？A、SparkB、PlayC、AkkaD、Allofabove參考答案：D55.Scala中用于在for循環(huán)中生成序列的關(guān)鍵字是？A、generateB、yieldC、reateD、collect參考答案：B56.Scala中用于實(shí)現(xiàn)多態(tài)的關(guān)鍵字是什么？A、overrideB、implementC、baseD、abstract參考答案：A57.Scala中用于捕獲異常的結(jié)構(gòu)是？A、try-catchB、exceptionC、errorD、catch-try參考答案：A58.Scala中用來(lái)實(shí)現(xiàn)反射的庫(kù)是？A、scalA,reflectB、scalAannotationC、scalAconcurrentD、scalAutil參考答案：A59.Scala中為類定義構(gòu)造函數(shù)使用的關(guān)鍵字是？A、newB、defC、lassD、init參考答案：C60.Scala中如何定義一個(gè)可變的集合？A、ListB、SetC、ArrayBufferD、Map參考答案：C61.Scala中如何定義一個(gè)Map？A、valmyMap=Map（"key"->"value"）B、valmyMap=newMap（"key"->"value"）C、valmyMap=Map（key=value）D、以上都是參考答案：A62.Scala中如何創(chuàng)建一個(gè)集合的副本？A、cloneB、copyC、duplicateD、toList參考答案：A63.Scala中如何表示空值？A、NoneB、nullC、0D、unit參考答案：A64.Scala中哪個(gè)場(chǎng)景下使用final關(guān)鍵字？A、變量B、類C、方法D、以上都有參考答案：D65.Scala中的trait最接近于哪個(gè)概念？A、接口B、類C、抽象類D、模塊參考答案：A66.Scala中的main是什么？A、表示主函數(shù)的注解B、表示入口點(diǎn)的注解C、表示不推薦使用的代碼D、以上都不正確參考答案：A67.Scala中的for表達(dá)式主要用于？A、循環(huán)B、異常處理C、函數(shù)定義D、數(shù)據(jù)變換參考答案：A68.Scala中的caseobject與caseclass的主要區(qū)別是什么？A、可變性B、伴生對(duì)象C、序列化D、模式匹配支持參考答案：A69.Scala中的caseclass的優(yōu)點(diǎn)是？A、可以被實(shí)例化B、自動(dòng)生成副本方法C、支持模式匹配D、以上均是參考答案：D70.Scala中表現(xiàn)為隨機(jī)訪問(wèn)的數(shù)據(jù)結(jié)構(gòu)是？A、ListB、ArrayC、SetD、Queue參考答案：B71.Scala語(yǔ)言的設(shè)計(jì)者是誰(shuí)？A、MartinOderskyB、jarnStroustrupC、GuidovanRossumD、JamesGosling參考答案：A72.JDBC連接器的主要參數(shù)不包括？（）A、connectorB、urlC、table-nameD、select參考答案：D73.Flink作業(yè)的執(zhí)行模式不包括以下哪種（）A、本地模式B、集群模式C、器模式D、虛擬模式參考答案：D74.Flink中以下哪個(gè)組件負(fù)責(zé)任務(wù)的調(diào)度和資源管理？（）A、TaskManagerB、JobManagerC、ResourceManagerD、SlotManager參考答案：B75.Flink中的狀態(tài)后端（StateBackend）主要用于存儲(chǔ)什么？A、作業(yè)配置B、計(jì)算結(jié)果C、流數(shù)據(jù)D、任務(wù)狀態(tài)參考答案：D76.Flink中的SinkFunction主要用于什么目的？A、從外部系統(tǒng)讀取數(shù)據(jù)B、將數(shù)據(jù)寫入外部系統(tǒng)C、對(duì)流數(shù)據(jù)進(jìn)行轉(zhuǎn)換D、對(duì)流數(shù)據(jù)進(jìn)行分組參考答案：B77.Flink中的KeyBy操作主要用于什么目的？A、對(duì)數(shù)據(jù)進(jìn)行分組B、對(duì)數(shù)據(jù)進(jìn)行排序C、對(duì)數(shù)據(jù)進(jìn)行過(guò)濾D、對(duì)數(shù)據(jù)進(jìn)行聚合參考答案：A78.Flink中的DataStreamAPI主要用于處理什么類型的數(shù)據(jù)？A、靜態(tài)數(shù)據(jù)集B、實(shí)時(shí)數(shù)據(jù)流C、圖數(shù)據(jù)D、批量數(shù)據(jù)參考答案：B79.Flink中的"窗口"概念是指什么？（）A、圖形用戶界面的窗口B、用于劃分?jǐn)?shù)據(jù)流的邏輯時(shí)間區(qū)域C、數(shù)字簽名的一種方式D、用于訪問(wèn)文件系統(tǒng)的接口參考答案：B80.Flink中，以下哪個(gè)操作符用于將流中的元素轉(zhuǎn)換為另一種類型？（）A、MapB、FlatMapC、FilterD、Reduce參考答案：A81.Flink中，以下哪個(gè)操作符用于將流中的元素按照指定的規(guī)則進(jìn)行分組？（）A、GroupByB、PartitionByC、ReduceByD、AggregateBy參考答案：A82.Flink中，以下哪個(gè)操作符用于將流中的元素按照指定的規(guī)則進(jìn)行分區(qū)？（）A、PartitionByB、GroupByC、ReduceByD、AggregateBy參考答案：A83.Flink中，以下哪個(gè)操作符用于將多個(gè)流進(jìn)行連接？（）A、JoinB、UnionC、SplitD、CoGroup參考答案：A84.Flink中，以下哪個(gè)操作符用于過(guò)濾數(shù)據(jù)？（）A、FilterB、MapC、ReduceD、Join參考答案：A85.Flink中，以下哪個(gè)操作符用于對(duì)分組后的數(shù)據(jù)進(jìn)行聚合計(jì)算？（）A、ReduceB、AggregateC、FoldD、以上都是參考答案：D86.Flink支持哪些類型的時(shí)間語(yǔ)義？A、事件時(shí)間（EventTime）B、處理時(shí)間（ProcessingTime）C、攝入時(shí)間（IngestionTime）D、以上都是參考答案：D87.Flink支持哪些類型的連接器（Connector）用于與外部系統(tǒng)交互？A、KafkaB、JDBCC、文件系統(tǒng)D、以上都是參考答案：D88.Flink提供了哪種機(jī)制來(lái)實(shí)現(xiàn)容錯(cuò)？A、分布式鎖B、事務(wù)C、檢查點(diǎn)（Checkpointin和保存點(diǎn)（Savepoint）D、消息隊(duì)列參考答案：C89.Flink提供了哪種機(jī)制來(lái)確保在分布式環(huán)境中數(shù)據(jù)的一致性？A、分布式鎖B、事務(wù)C、檢查點(diǎn)（Checkpointing）D、消息隊(duì)列參考答案：C90.Flink提供了哪些類型的廣播狀態(tài)（BroadcastState）？（注意：此題基于Flink支持廣播狀態(tài)的版本）A、鍵值對(duì)狀態(tài)（KeyeStatB、操作符狀態(tài)（OperatorState）C、廣播變量（BroadcastVariable）D、映射狀態(tài)（MapState）參考答案：C91.Flink集群中的TaskManager負(fù)責(zé)執(zhí)行什么任務(wù)？A、作業(yè)調(diào)度B、任務(wù)執(zhí)行C、資源分配D、作業(yè)監(jiān)控參考答案：B92.Flink的作業(yè)調(diào)度是基于什么策略進(jìn)行的？A、先來(lái)先服務(wù)（FCFS）B、最短作業(yè)優(yōu)先（SJC、優(yōu)先級(jí)調(diào)度D、基于任務(wù)的并行度和資源可用性參考答案：C93.Flink的基本編程抽象包括（）A、DataSet和DataStreamB、RDDC、僅DataStreamD、TableAPI參考答案：A簡(jiǎn)答題1.在Flink中，（）用于在作業(yè)之間傳遞數(shù)據(jù)。答：數(shù)據(jù)流2.在Flink中，（）用于描述作業(yè)如何并行執(zhí)行以及任務(wù)之間的依賴關(guān)系。答：執(zhí)行計(jì)劃3.在Flink中，（）用于描述作業(yè)的運(yùn)行時(shí)屬性，如并行度、任務(wù)槽數(shù)等。答：作業(yè)配置4.在Flink中，（）是處理數(shù)據(jù)流的基本單位。答：任務(wù)5.在Flink中，（）操作符用于將流中的元素按照指定的鍵進(jìn)行分組。答：KeyBy6.在Flink中，（）操作符用于按照指定的鍵對(duì)流中的元素進(jìn)行分組。答：KeyBy7.在Flink的作業(yè)配置中，（）參數(shù)用于指定作業(yè)的并行度。答：parallelism.default8.在Flink的作業(yè)配置中，（）參數(shù)用于指定作業(yè)的并行度。答：parallelism9.使用nc命令生成一個(gè)端口為1234的Socket服務(wù)端的命令（）。答：nc-lk123410.Flink中負(fù)責(zé)具體任務(wù)執(zhí)行的是（）。答：TaskManager11.Flink中的窗口可以分為時(shí)間窗口和（）窗口。答：計(jì)數(shù)12.Flink中，用于連接兩個(gè)流的操作符是（）。答：join13.Flink中，用于處理亂序數(shù)據(jù)的機(jī)制是（）。答：水位線14.Flink中，通過(guò)（）操作可以將一個(gè)流拆分成多個(gè)流。答：Split15.Flink中，容錯(cuò)機(jī)制主要包括（）（）。答：檢查點(diǎn)、自動(dòng)容錯(cuò)恢復(fù)16.Flink支持兩種類型的時(shí)間語(yǔ)義：事件時(shí)間和（）。答：處理時(shí)間17.Flink支持多種部署模式，包括獨(dú)立集群、YARN和（）。答：Kubernetes18.Flink支持多種部署模式，包括獨(dú)立集群、YARN、（）和Mesos。答：Kubernetes19.Flink支持的部署模式有本地模式、（）模式和云模式。答：集群20.Flink是一個(gè)開(kāi)源的流處理框架，它提供了高吞吐、低延遲的（）處理。答：數(shù)據(jù)流21.