SQL =========== This node runs the given SQL on the incoming DataFrame Input -------------- It takes in a DataFrame as input and transforms it to another DataFrame Output -------------- It runs the given SQL on the incoming DataFrame to generate the output DataFrame Type --------- transform Class --------- fire.nodes.etl.NodeSQL Fields --------- .. list-table:: :widths: 10 5 10 :header-rows: 1 * - Name - Title - Description * - tempTable - Temp Table - Temp Table Name to be used * - sql - SQL - SQL to be run * - schema - InferSchema - * - outputColNames - Output Column Names - Name of the Output Columns * - outputColTypes - Output Column Types - Data Type of the Output Columns * - outputColFormats - Output Column Formats - Format of the Output Columns Details ------- SQL Details +++++++++++++++ SQL node receives an input data frame. It creates a temporary table on top of that data frame. It executes the provided SQL in the node on the temporary table. The resulting data frame of running the SQL is passed on to the next node. Examples ------- SQL Examples +++++++++++++++ Below are some examples of SQL. Temporary table name used : tempTable The schema of the Input Dataframe is : id, price, lotsize, bedrooms, bathrms, stories, driveway, recroom, fullbase, gashw, airco, garagepl, prefarea find the average price of houses +++++++++++++++ select avg(price) as avg_price from tempTable find bedrooms with avg price greater than 10000 +++++++++++++++ select bedrooms, avg_price from (select bedrooms, avg(price) as avg_price from tempTable group by bedrooms) as temp where avg_price > 10000 details of houses with bedrooms avg price greater than 10000 +++++++++++++++ select tempTable.* , inner_table.avg_price from (select bedrooms, avg_price from (select bedrooms, avg(price) as avg_price from tempTable group by bedrooms) as temp where avg_price > 10000) as inner_table JOIN tempTable ON(inner_table.bedrooms = tempTable.bedrooms)