下列关于Flink中TransFormation的说法正确的是()
A.filter操作是对每个元素执行boolean函数
B.keyBy是将源头数据按照key进行分组,以保证同一个key的源数据分到同样的组中
C.可以通过windows设定时间窗口
D.flatMap可以对文本进行切分
ABCD
A.filter操作是对每个元素执行boolean函数
B.keyBy是将源头数据按照key进行分组,以保证同一个key的源数据分到同样的组中
C.可以通过windows设定时间窗口
D.flatMap可以对文本进行切分
ABCD
A.Stream是指在系统中流转的,动态的无边界数据集
B.Operator是指针对数据流执行操作以产生其他数据流的功能
C.Source是指数据流进入系统的入口点
D.Sink是指数据流离开Flink系统后进入到的位置,槽可以是数据库或到其他系统的连接器
A.ShufflePartitioner数据会被随机分发到下游算子的每一个实例中进行处理
B.RebalancePartitioner数据会被循环发送到下游的每一个实例中进行处理
C.BroadcastPartitioner将记录输出到下游本地的算子实例
D.GlobalPartitioner数据会被分发到下游算子的第一个实例中进行处理
A.SparkStreaming与Flink相比,时延更低
B.Flink流式处理引擎能够同时提供支持流处理和批处理应用的功能
C.checkpoint实现了Flink的容错
D.与FusionInghtHD中的Streaming相比,Flink具有更高的吞吐量
A.SparkStreaming与Flink相比,时延更低
B.Flink流式处理引擎能够同时提供支持流处理和批处理应用的功能
C.与FusionInghtHD中的Streaming相比,Flink具有更高的吞吐量
D.checkpoint实现了Fink的容错
A.RocksDBStateBackend
B.FsStateBackend
C.MemoryStateBackend
D.FileStateBackend
A.Event Time
B.Processing Time
C.Ingestion Time
D.Party Time