== Physical Plan ==
CollectLimit (4)
+- * Project (3)
+- * ColumnarToRow (2)
+- Scan parquet (1)
(1) Scan parquet
Output [9]: [loan_id#457, total_principal_received#458, total_interest_received#459, total_late_fee_received#460, total_payment_received#461, last_payment_amount#462, last_payment_date#463, next_payment_date#464, ingest_date#465]
Batched: true
Location: InMemoryFileIndex [hdfs://m01.itversity.com:9000/user/itv023599/lendingclubproject/cleaned/loan_repayments_parquet]
ReadSchema: struct<loan_id:string,total_principal_received:float,total_interest_received:float,total_late_fee_received:float,total_payment_received:float,last_payment_amount:float,last_payment_date:string,next_payment_date:string,ingest_date:timestamp>
(2) ColumnarToRow [codegen id : 1]
Input [9]: [loan_id#457, total_principal_received#458, total_interest_received#459, total_late_fee_received#460, total_payment_received#461, last_payment_amount#462, last_payment_date#463, next_payment_date#464, ingest_date#465]
(3) Project [codegen id : 1]
Output [9]: [loan_id#457, cast(total_principal_received#458 as string) AS total_principal_received#522, cast(total_interest_received#459 as string) AS total_interest_received#523, cast(total_late_fee_received#460 as string) AS total_late_fee_received#524, cast(total_payment_received#461 as string) AS total_payment_received#525, cast(last_payment_amount#462 as string) AS last_payment_amount#526, last_payment_date#463, next_payment_date#464, cast(ingest_date#465 as string) AS ingest_date#529]
Input [9]: [loan_id#457, total_principal_received#458, total_interest_received#459, total_late_fee_received#460, total_payment_received#461, last_payment_amount#462, last_payment_date#463, next_payment_date#464, ingest_date#465]
(4) CollectLimit
Input [9]: [loan_id#457, total_principal_received#522, total_interest_received#523, total_late_fee_received#524, total_payment_received#525, last_payment_amount#526, last_payment_date#463, next_payment_date#464, ingest_date#529]
Arguments: 21