DStream的转换操作方法中,哪个方法可以直接调用RDD上的操作方法?
选项:
A:
transform(func)
B:
updateStateByKey(func)
C:
countByKey()
D:
cogroup(otherStream, numTasks])
transform(func)
updateStateByKey(func)
countByKey()
cogroup(otherStream, numTasks])
以下文字与答案无关
提示:有些试题内容 显示不完整,文字错误 或者 答案显示错误等问题,这是由于我们在扫描录入过程中 机器识别错误导致,人工逐条矫正总有遗漏,所以恳请 广大网友理解。
countByKey()
B:updateStateByKey(func)
C:cogroup(otherStream,numTasks])
D:transform(func)
func(1,22,333);
B:func();
C:func("#",20);
D:func(5,,9);
不会与原数据保持相同形状
B:会对产生的标量值进行广播操作
C:func参数只能传入内置函数
D:func参数可以传入多个内置函数
filter()
B:groupByKey()
C:reduceByKey()
D:map()
return 0;
}
">10.以下程序输出的结果是( )
#include <stdio.h>
int func(int a, int b) {
return (a + b);
}
int main() {
int x = 2, y = 5, z = 8, r;
r = func(func(x, y), z);
printf("%d\n", r);
return 0;
}
func();
printf("MAIN:x=%2d y=%2d n=%2d",x,y,n);
func();
}
void func()
{
static int x=4;
int y=10;
x=x+2;
n=n+10;
y=y+n;
printf("FUNC:x=%2d y=%2d n=%2d",x,y,n);
}
">11.以下程序的运行结果是____________。int n=1;
void main( )
{
static int x=5;
int y;
y=n;
printf("MAIN:x=%2d y=%2d n=%2d",x,y,n);
func();
printf("MAIN:x=%2d y=%2d n=%2d",x,y,n);
func();
}
void func()
{
static int x=4;
int y=10;
x=x+2;
n=n+10;
y=y+n;
printf("FUNC:x=%2d y=%2d n=%2d",x,y,n);
}
count
B:<label>reduceByKeyAndWidow</label><label>
</label>
<label>countByValue</label><label>
</label>
<label>reduceByKey</label>
A、通过创建输入DStream(Input Dstream)来定义输入源
B、通过对DStream应用转换操作和输出操作来定义流计算
C、调用StreamingContext对象的start()方法来开始接收数据和处理流程
D、通过调用StreamingContext对象的awaitTermination()方法来等待流计算进程结束
某软件公司欲开发一个数据格式转换工具,可以将不同数据源如txt文件、数据库、Excel表格中的数据转换成XML格式。为了让系统具有更好的扩展性,在未来支持新类型的数据源,开发人员使用工厂方法模式设计该转换工具的核心类。在工厂类中封装了具体转换类的初始化和创建过程,客户端只需使用工厂类即可获得具体的转换类对象,再调用其相应方法实现数据转换操作。
/*ConvertorCreator是抽象工厂接口,它声明了工厂方法getConvertor(),在其子类中实现该方法,用于创建具体的转换对象;Convertor是抽象产品接口,它声明了抽象数据转换方法transform(),在其子类中实现该方法,用于完成具体的数据转换操作。类DBConvertor和TXTConvertor分别用于将数据库中的数据和txt文件中的数据转换为XML格式。*/
interface ConvertorCreator
_(1_——;
)
interface Convertor
public String transform();
}
class DBConvertorCreator implements ConvertorCreator
public Convertor getConvertor()
(
___(2)——;}
}
class TXTConvertorCreator implements ConvertorCreator{
public Convertor getConvertor()(
_(3);}
}
class DBConvertor implements Convertor{
public String transform()(
实现代码省略}
}
class TXTConvertor implements Convertor{
public String transform(){
/实现代码省略}
}
class Test{
public static void main(String args)(
ConvertorCreator creator;_(4);
creator = new DBConvertorCreator();convertor = __(5)
convertor.transform(;)
}