web UI中的输入大小列表示什么？

Question

spark streaming中批次的输入大小表示什么？它是指示批次中的行数还是其他什么？我读了卡夫卡的文章。

​

​

Answer 1

输入大小表示从Kafka接收的数据集/JSON的数量，以便在该特定时间段内进行处理。

它还取决于您正在处理的数据类型。如下图所示：

​

，

它是在上述时间段内从Kafka队列接收/读取的数据集的数量。

在这里，微批被安排在15秒的周期内。