多项选择题X 纠错
A.复杂事物操作
B.计算器应用:例如统计某个网站的登录人数
C.一条消息被多个消费者同时消费且保证消息被所有订阅者成功消费的消息队
D.取最新N个数据:例如对某条微博,获取最新的10个评论
你可能喜欢
多项选择题
A.Kafka是一个高吞吐、分布式、基于发布订阅的消息系统
B.Kafka可以做到消息的持久化
C.Kafka适用于离线和在线的消息消费场景
D.Kafka可以保证每个Partion内的消息有序
单项选择题
A.kafkaadmin组
B.kafka组
C.kafkasuperuser组
多项选择题
A.按照源文件名,直接生成文件
B.设置文件生成间隔,达到时间间隔时就关闭老文件,新数据将被写入新文
C.设置单个文件大小,当文件大小达到所设定值时,就关闭老文件,新数据
D.设置单个文件存放在event数量,当文件所存放event数量到设定值时
单项选择题
A.组网隔离环境下,ZooKeeper的IP既可以配置成业务IP,也可以配置成管理IP
B.Hive与传统数据库不同,因此JDBC建立的连接不需要关闭
C.安全集群环境下,建立与Hive的连接前,需要使用统一认证方式进行登陆
D.使用JDBCᨀ交SQL时,可以再SQL语句后面加上分号“;”
多项选择题
A.Producer是消息生产者
B.Producer生产数据需要制定Topic
C.可以同时引起多个Producer进程向同一个Topic进行数据发送
D.Producer生产数据时需要先连接ZooKeeper,而后才连接Broker
多项选择题
A.广播变量在每Task中保存一份
B.广播变量在每个Executor中保村一份
C.广播变量是只读的
D.广播变量通过SparkContext.broadcast()方法生成