Analyze Flights Delays

This workflow reads in a dataset. It then analyzes flights delay with sample datasets and prints the results.

Workflow

Below is the workflow. It does the following:

• Reads data from a sample dataset.
• Prints the sample datasets results.
• Column to be cast for new datatype double.
• Column to be cast for new datatype string.
• Updates the column name of datatype string.
• Prints the result of data updating after stringindexer Node.
• Executes the SQL queries with the given conditions.
• Prints the results.

Reading from Dataset

It reads Dataset files.

Processor Configuration

Processor Output

Print the sample datasets results

It prints the sample datasets results.

Processor Configuration

Processor Output

Column to be cast for new datatype double

It casts for new datatype double using castcolumn type Node.

Processor Configuration

Processor Output

Column to be cast for new datatype string

It casts for new datatype string using castcolumn type Node.

Processor Configuration

Processor Output

Updates the column name of datatype string

It updates the column name of datatype string using stringindexer type Node.

Processor Configuration

Processor Output

Prints the Results

It prints the result of data updating after stringindexer Node.

Processor Configuration

Processor Output

Executes the SQL queries

It executes the SQL queries with the given conditions.

Processor Configuration

Processor Output

Prints the Results

It prints the results after satisfied condition by sql queries.

Processor Configuration

Processor Output