FusionInsight HD 系统中，Fume 数据流在节点内不需要

单选题 FusionInsight HD 系统中，Fume 数据流在节点内不需要经过哪个组件？

A、 source

B、 channel

C、 sink

D、 topic

查看答案

下载APP答题

由4l***uo提供分享举报纠错

相关试题

单选题在 HBase 写数据的业务逻辑实现过程中，如下哪个接口或类是不需要涉及的

A、Put

B、HTable

C、HBaseAdmin

D、PutList

查看答案

单选题在 Spark 应用开发中，以下哪项的代码能正确进行单词统计

A、val counts = textFile.map(line => line.split(" ")).map(word => (word, 1)).reduceByKey(_ + _)

B、val counts = textFile.flatMap(line => line.split(" ")).map(word => (word, 1)).reduceByKey(_ + _)

C、val counts = textFile.map(line => line.split(" ")).map(word => (word, 1)).groupByKey()

D、val counts = textFile.flatMap(line => line.split(" ")).map(word => (word, 1)).groupByKey()

查看答案

单选题 MapReduce 任务最终是在下列哪一项中被执行的

A、NodeManager

B、container

C、ResourceManager

D、AppMaster

查看答案

单选题在 Spark 中，假设 lines 是一个 DStream 对象，以下哪个语句可以周期统计这个流上的单词数

A、lines.flatMap {_.split(" ")}.map(word => (word, 1)).reduceByKey(_+_).print()

B、lines.flatMap {_.split(" ")}.map(word => (word, word.hashCode())).reduceByKey(_+_).print()

C、lines.flatMap {_.split(" ")}.map(word => (word, 1)).reduceByKey(_+_).print()

D、lines.flatMap {_.split(" ")}.flatMap(word => (word, 1)).groupByKey(_+_).print()

查看答案

单选题 FusionInsight HD 中，假设一个拓扑，设置了 spout 并发度为 3，bk1 并发度为 2，bk2 并发度为 3，worker 数目为 2，则 bolt1 的 executor 在 worker 中是如何分布的？

A、两个 executor 分布在一个 worker 中

B、两个 executor 分布在两个 worker 中

C、三个 executor 分布在一个 worker 中

D、三个 executor 分布在两个 worker 中

查看答案

单选题 Redis 集群模式下，使用 JAVA 进行应用开发，下列哪种是最佳实践

A、使用 Jedis 连接 Redis Server,调用 Jedis的 set、get 等命令操作

B、使用 JedisPool 对象连接 Redis Server,每次业务操作先从 JedisPool 中获取一个 Jedis 对象,不用调用 Jedis 的 set、get 等命令操作专门进行资源释放

C、使用 redisCluster 对象连接 Redis Server,调用 JedisCluster的 set、get 等命令操作专门进行资源释放

D、在 JedisCluster 对象连接 Redis Server,调用 JedisCluster的 set、get 等命令操作时,如果超时就关闭 JedisCluster 对象

查看答案

单选题将数据块存储大小设置为 128M，HDFS 客户端在写文件时，当写入一个 100M 大，存储空间为多大

A、128M

B、100M

C、84M

D、50M

查看答案

单选题在 FusionInsight HD 产品中，Kafka 服务的角色名称是

A、Producer

B、Broker

C、Consumer

D、ZooKeeper

查看答案