dataset.nyctaxi

Introduction

The tags beginning with dataset.nyctaxi identify events generated by data sets belonging to NYC Taxi.

These are the valid tags and corresponding data tables that will receive the parsers' data:

Product / Service	Tags	Data tables

Product / Service	Tags	Data tables
NYC Taxi	`dataset.nyctaxi.green.1.1`	`dataset.nyctaxi.green`
NYC Taxi	`dataset.nyctaxi.yellow.2.2`	`dataset.nyctaxi.yellow`

For more information, read more About Devo tags.

These are the fields displayed in these tables:

Field	Type	Field transformation	Source field name	Extra fields

Field	Type	Field transformation	Source field name	Extra fields
eventdate	`timestamp`
rate_code	`str`		vrate
payment	`str`		vpayment
rate	`str`	`decode(rate_code, "1", "Standard rate", decode(rate_code, "2", "JFK", decode(rate_code, "3", "Newark", decode(rate_code, "4", "Nassau or Westchester", decode(rate_code, "5", "Negotiated fare", decode(rate_code, "6", "Group ride", "unknown"))))))`	rate_code
payment_type	`str`	`decode(payment, "1", "Credit Card", decode(payment, "2", "Cash", decode(payment, "3", "No Charge", decode(payment, "4", "Dispute", decode(payment, "5", "Unknown", decode(payment, "6", "Voided Trip", "unknown"))))))`	payment
pickup_datetime	`str`
dropoff_datetime	`str`
store_and_fwd_flag	`str`
pickup_longitude	`float8`
pickup_latitude	`float8`
dropoff_longitude	`float8`
dropoff_latitude	`float8`
passenger_count	`int8`
trip_distance	`float8`
fare_amount	`float8`
extra	`float8`
mta_tax	`float8`
tip_amount	`float8`
tolls_amount	`float8`
ehail_fee	`float8`
total_amount	`float8`
distance_between_service	`float8`
time_between_service	`int8`
trip_type	`int8`
hostchain	`str`			✓
tag	`str`			✓

Field	Type	Field transformation	Source field name	Extra fields

Field	Type	Field transformation	Source field name	Extra fields
eventdate	`timestamp`
vendor_id	`int8`
rate_code	`str`		vrate
payment	`str`		vpayment
rate	`str`	`decode(rate_code, "1", "Standard rate", decode(rate_code, "2", "JFK", decode(rate_code, "3", "Newark", decode(rate_code, "4", "Nassau or Westchester", decode(rate_code, "5", "Negotiated fare", decode(rate_code, "6", "Group ride", "unknown"))))))`	rate_code
payment_type	`str`		payment
pickup_datetime	`str`
dropoff_datetime	`str`
store_and_fwd_flag	`str`
pickup_longitude	`float8`
pickup_latitude	`float8`
dropoff_longitude	`float8`
dropoff_latitude	`float8`
passenger_count	`int8`
trip_distance	`float8`
fare_amount	`float8`
extra	`float8`
mta_tax	`float8`
tip_amount	`float8`
tolls_amount	`float8`
imp_surcharge	`float8`
total_amount	`float8`
hostchain	`str`			✓
tag	`str`			✓