Scan 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#3277,ye#3278,dataTime#3279] PushedFilters: [], ReadSchema: struct<F0000080:string,ye:string,dataTime:string>
== Physical Plan ==
* HashAggregate (7)
+- Exchange (6)
+- * HashAggregate (5)
+- * SerializeFromObject (4)
+- * MapElements (3)
+- * DeserializeToObject (2)
+- * Scan 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] (1)
(1) Scan 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] [codegen id : 1]
Output [3]: [F0000080#3277, ye#3278, dataTime#3279]
ReadSchema: struct<F0000080:string,ye:string,dataTime:string>
(2) DeserializeToObject [codegen id : 1]
Input [3]: [F0000080#3277, ye#3278, dataTime#3279]
Arguments: createexternalrow(F0000080#3277.toString, ye#3278.toString, dataTime#3279.toString, StructField(F0000080,StringType,true), StructField(ye,StringType,true), StructField(dataTime,StringType,true)), obj#3395: org.apache.spark.sql.Row
(3) MapElements [codegen id : 1]
Input [1]: [obj#3395]
Arguments: smartbix.datamining.engine.execute.node.preprocess.DivideNode$2@168bf452, obj#3396: org.apache.spark.sql.Row
(4) SerializeFromObject [codegen id : 1]
Input [1]: [obj#3396]
(5) HashAggregate [codegen id : 1]
Input: []
Keys: []
Functions [1]: [partial_count(1)]
Aggregate Attributes [1]: [count#3430L]
Results [1]: [count#3431L]
(6) Exchange
Input [1]: [count#3431L]
Arguments: SinglePartition, ENSURE_REQUIREMENTS, [id=#1145]
(7) HashAggregate [codegen id : 2]
Input [1]: [count#3431L]
Keys: []
Functions [1]: [count(1)]
Aggregate Attributes [1]: [count(1)#3427L]
Results [1]: [count(1)#3427L AS count#3428L]