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

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)