== Physical Plan ==
Execute CreateViewCommand (1)
+- CreateViewCommand (2)
+- Project (19)
+- Project (18)
+- SubqueryAlias (17)
+- SerializeFromObject (16)
+- MapElements (15)
+- DeserializeToObject (14)
+- Project (13)
+- Generate (12)
+- SubqueryAlias (11)
+- SerializeFromObject (10)
+- MapElements (9)
+- DeserializeToObject (8)
+- Project (7)
+- Project (6)
+- Project (5)
+- Project (4)
+- LogicalRelation (3)
(1) Execute CreateViewCommand
Output: []
(2) CreateViewCommand
Arguments: `88c809ab0cd84938b8390e8afbb8d7ad_1744329607326`, false, true, LocalTempView
(3) LogicalRelation
Arguments: JDBCRelation(( SELECT
DISTINCT t1.F0000080,
case when t4.ye<>''
THEN t4.ye
ELSE DATE_FORMAT(NOW(),'%Y') end ye
,
'01-02-03-04-05-06-07-08-09-10-11-12' dataTime
from (SELECT F0000080 from `立项审批` WHERE `Status`='1' ) t1
LEFT JOIN `井位信息` t2 on t2.ObjectId=t1.F0000080 and t2.`Status`='1'
LEFT JOIN `井位运行情况表` t3 on t2.ObjectId=t3.F0000026 and t3.`Status`='1'
LEFT JOIN(
SELECT DISTINCT F0000031,
CASE WHEN date_format(F0000030, '%d')>25 and date_format(F0000030, '%c')=12
THEN date_format(F0000030, '%Y')+1
ELSE date_format(F0000030, '%Y')
END ye
FROM `日报填报`
where Status='1'
)t4 on t4.F0000031=t3.ObjectId
) as T) [numPartitions=1], [F0000080#14477, ye#14478, dataTime#14479], false
(4) Project
Arguments: [F0000080#14477, ye#14478, dataTime#14479]
(5) Project
Arguments: [F0000080#14477 AS F0000080#14486, ye#14478, dataTime#14479]
(6) Project
Arguments: [F0000080#14486, ye#14478 AS ye#14490, dataTime#14479]
(7) Project
Arguments: [F0000080#14486, ye#14490, dataTime#14479 AS dataTime#14494]
(8) DeserializeToObject
Arguments: createexternalrow(F0000080#14486.toString, ye#14490.toString, dataTime#14494.toString, StructField(F0000080,StringType,true), StructField(ye,StringType,true), StructField(dataTime,StringType,true)), obj#14595: org.apache.spark.sql.Row
(9) MapElements
Arguments: smartbix.datamining.engine.execute.node.preprocess.DivideNode$2@6cf249, interface org.apache.spark.sql.Row, [StructField(F0000080,StringType,true), StructField(ye,StringType,true), StructField(dataTime,StringType,true)], obj#14596: org.apache.spark.sql.Row
(10) SerializeFromObject
Arguments: [if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 0, F0000080), StringType), true, false) AS F0000080#14597, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 1, ye), StringType), true, false) AS ye#14598, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 2, dataTime), StringType), true, false) AS dataTime#14599, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 3, dataTime_0), StringType), true, false) AS dataTime_0#14600, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 4, dataTime_1), StringType), true, false) AS dataTime_1#14601, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 5, dataTime_2), StringType), true, false) AS dataTime_2#14602, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 6, dataTime_3), StringType), true, false) AS dataTime_3#14603, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 7, dataTime_4), StringType), true, false) AS dataTime_4#14604, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 8, dataTime_5), StringType), true, false) AS dataTime_5#14605, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 9, dataTime_6), StringType), true, false) AS dataTime_6#14606, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 10, dataTime_7), StringType), true, false) AS dataTime_7#14607, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 11, dataTime_8), StringType), true, false) AS dataTime_8#14608, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 12, dataTime_9), StringType), true, false) AS dataTime_9#14609, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 13, dataTime_10), StringType), true, false) AS dataTime_10#14610, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 14, dataTime_11), StringType), true, false) AS dataTime_11#14611]
(11) SubqueryAlias
Arguments: 5db8665f759f42978ed368ebad772741_1744329604541
(12) Generate
Arguments: stack(12, dataTime_0, dataTime_0#14600, dataTime_1, dataTime_1#14601, dataTime_2, dataTime_2#14602, dataTime_3, dataTime_3#14603, dataTime_4, dataTime_4#14604, dataTime_5, dataTime_5#14605, dataTime_6, dataTime_6#14606, dataTime_7, dataTime_7#14607, dataTime_8, dataTime_8#14608, dataTime_9, dataTime_9#14609, dataTime_10, dataTime_10#14610, dataTime_11, dataTime_11#14611), false, [monname#14648, mon#14649]
(13) Project
Arguments: [F0000080#14597, ye#14598, dataTime#14599, monname#14648, mon#14649]
(14) DeserializeToObject
Arguments: createexternalrow(F0000080#14597.toString, ye#14598.toString, dataTime#14599.toString, monname#14648.toString, mon#14649.toString, StructField(F0000080,StringType,true), StructField(ye,StringType,true), StructField(dataTime,StringType,true), StructField(monname,StringType,true), StructField(mon,StringType,true)), obj#14676: org.apache.spark.sql.Row
(15) MapElements
Arguments: smartbix.datamining.engine.execute.node.preprocess.ValueReplaceNode$2@468048be, interface org.apache.spark.sql.Row, [StructField(F0000080,StringType,true), StructField(ye,StringType,true), StructField(dataTime,StringType,true), StructField(monname,StringType,true), StructField(mon,StringType,true)], obj#14677: org.apache.spark.sql.Row
(16) SerializeFromObject
Arguments: [if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 0, F0000080), StringType), true, false) AS F0000080#14678, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 1, ye), StringType), true, false) AS ye#14679, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 2, dataTime), StringType), true, false) AS dataTime#14680, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 3, monname), StringType), true, false) AS monname#14681, if (assertnotnull(input[0, org.apache.spark.sql.Row, true]).isNullAt) null else staticinvoke(class org.apache.spark.unsafe.types.UTF8String, StringType, fromString, validateexternaltype(getexternalrowfield(assertnotnull(input[0, org.apache.spark.sql.Row, true]), 4, mon), StringType), true, false) AS mon#14682]
(17) SubqueryAlias
Arguments: e30ee6179520420faf9bcdcba72266ed_1744329607230
(18) Project
Arguments: [F0000080#14678, ye#14679, dataTime#14680, monname#14681, mon#14682, concat(ye#14679, mon#14682) AS yemon#14924]
(19) Project
Arguments: [F0000080#14678, ye#14679, monname#14681, mon#14682, yemon#14924]