作者:手机用户2502910113_707 | 来源:互联网 | 2023-10-12 14:24
1.美图LogicalPlan:Project[value#23ASpage#32,count#28LAScount#33L]+-Aggregate[value#23],[va
1.美图
Logical Plan: Project [value#23 AS page#32, count#28L AS count#33L] +- Aggregate [value#23], [value#23, count(1) AS count#28L]+- SerializeFromObject [staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, input[0, java.lang.String, true], true) AS value#23]+- MapPartitions , obj#22: java.lang.String+- DeserializeToObject cast(value#15 as string).toString, obj#21: java.lang.String+- Project [cast(value#1 as string) AS value#15]+- StreamingExecutionRelation KafkaSource[Subscribe[topip-lcc]], [key#0, value#1, topic#2, partition#3, offset#4L, timestamp#5, timestampType#6]at org.apache.spark.sql.ex