existSpark, assuminglinesIs anDStreamobject, which of the following statements can periodically count this number of words on a stream?

• A.lines.flatMap(_.split(" ")).map(word =>(word,word.length())).reduceByKey (_+_).print( )
• B.lines.flatMap(_.split(" ")).flatmap(word =>(word,1)).groupByKey(_+_).print ( )
• C.lines.flatMap(_.split(" ")).map(word =>(word,1)).reduce(_+_).print( )
• D.lines.flatMap(_.split(" ")).map(word =>(word,1)).reduceByKey(_+_).print ( )

Comment: *

Name: *

Email: *

Verification: *

FusionInsight HDin, useStreamingofLinuxWhen submitting a topology in command line mode, you need to first use a StreamingUser with submit permissionkinitway authentication

• A.False
• B.True

Comment: *

Name: *

Email: *

Verification: *

existFusionInsight HDproductSolrDuring application development, you canSolr Admin UIrightCollectionDo some verification.
Below aboutSolr Admin UIIs the statement correct? (multiple choice)

• A.Solruser group,Solr adminrole andSuper groupof users have access toSolr Admin UI
• B.enter aCollectionofShard ReplicaofCore Overviewinterface, you can view theReplicaIndex the actual document Number of bars, storage size and location information
• C.clickCloud, see eachCollectionunder eachShardReplicadistribution and status
• D.clickClouddownTree,CheckSolr CloudmiddleCollections, a configuration set, andlive_nodesand other metadata information

Comment: *

Name: *

Email: *

Verification: *

fusion insight HDmiddle,streamingWhat are the characteristics of?

• A.Scalable
• B.stream processing
• C.high performance
• D.High fault tolerance

Comment: *

Name: *

Email: *

Verification: *

existFusionInsight HDproduct, aboutKafkaWhich of the descriptions of secure and non-secure ports is wrong?
(Note: oldAPImeans oldProducerAPIand oldConsumerAPI. Among them, the oldConsumer API:
Refers tokafka.consumer.ConsumerConnectorinterface defined in; oldProducerAPI:Refers to kafka.producer.Producerinterface defined in . )

• A.for settingA, CLofTopic, you can use the oldAPIconnect21005port to access.
• B.KafkaThe cluster security access port defaults to21007, the non-secure access port defaults to21005.
• C.oldAPIpass through21005access to a portTopicThe premise is: server parameters allow.everyone.if.no.acd.foundSet astrue, and thisTopicnot setA, CLAttributes.
• D.oldAPIAccess only21005port; newAPICompatible access to non-secure ports21005and secure port
  21007.

Comment: *

Name: *

Email: *

Verification: *