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.
Analyze Flights Delays

Reading from Dataset

It reads Dataset files.

Processor Configuration

Analyze Flights Delays

Processor Output

Analyze Flights Delays

Column to be cast for new datatype double

It casts for new datatype double using castcolumn type Node.

Processor Configuration

Analyze Flights Delays

Processor Output

Analyze Flights Delays

Column to be cast for new datatype string

It casts for new datatype string using castcolumn type Node.

Processor Configuration

Analyze Flights Delays

Processor Output

Analyze Flights Delays

Updates the column name of datatype string

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

Processor Configuration

Analyze Flights Delays

Processor Output

Analyze Flights Delays

Prints the Results

It prints the result of data updating after stringindexer Node.

Processor Configuration

Analyze Flights Delays

Processor Output

Analyze Flights Delays

Executes the SQL queries

It executes the SQL queries with the given conditions.

Processor Configuration

Analyze Flights Delays

Processor Output

Analyze Flights Delays

Prints the Results

It prints the results after satisfied condition by sql queries.

Processor Configuration

Analyze Flights Delays

Processor Output

Analyze Flights Delays