单项选择题
针对每行数据内容为”Timestamp Url”的数据文件,在用JobConf对象conf设置conf.setInputFormat(WhichInputFormat.class)来读取这个文件时,WhichInputFormat应该为以下的()
A.TextInputFormat
B.KeyValueTextInputFormat
C.SequenceFileInputFormat
D.NLineInputFormat
点击查看答案&解析
相关考题
-
多项选择题
下面哪个是Spark的转换操作()
A.map
B.take
C.reduceByKey
D.union -
多项选择题
以下属于Flink批处理Data源的是()
A.从csv文件中读取
B.从迭代器创建数据集
C.从socket读取数据
D.从压缩文件中读取数据 -
多项选择题
以下关于Watermark的说法正确的是()
A.Watermark可以标识数据的来源
B.给数据添加Watermark在一定程度上可以防止被盗用
C.Watermark主要用来处理乱序事件
D.Watermark需要开发人员手动添加上去