/// schema found in earlier nyc taxi files (e.g 2009)
schema found in earlier nyc taxi files
schema found in earlier nyc taxi files
fn nyc_taxi_v1_schema(time_unit: TimeUnit) -> Arc<Schema> {
    Arc::new(Schema::new(vec![
        Field::new("vendor_id", DataType::Utf8, true),
        Field::new(
            "pickup_at",
            DataType::Timestamp(time_unit.clone(), Option::None),
            true,
        ),
        Field::new(
            "dropoff_at",
            DataType::Timestamp(time_unit.clone(), Option::None),
            true,
        ),
        Field::new("passenger_count", DataType::Int8, true),
        Field::new("trip_distance", DataType::Float32, true),
        Field::new("pickup_longitude", DataType::Float32, true),
        Field::new("pickup_latitude", DataType::Float32, true),
        Field::new("rate_code_id", DataType::Null, true),
        Field::new("store_and_fwd_flag", DataType::Utf8, true),
        Field::new("dropoff_longitude", DataType::Float32, true),
        Field::new("dropoff_latitude", DataType::Float32, true),
        Field::new("payment_type", DataType::Utf8, true),
        Field::new("fare_amount", DataType::Float32, true),
        Field::new("extra", DataType::Float32, true),
        Field::new("mta_tax", DataType::Float32, true),
        Field::new("tip_amount", DataType::Float32, true),
        Field::new("tolls_amount", DataType::Float32, true),
        Field::new("total_amount", DataType::Float32, true),
    ]))
}
fn nyc_taxi_v1_schema ( time_unit : TimeUnit ) -> Arc < Schema > { Arc :: new ( Schema :: new ( vec ! [ Field new ( " " DataType Utf8 true ) Field new ( " " DataType Timestamp ( time_unit clone ( ) Option None ) true ) Field new ( " " DataType Timestamp ( time_unit clone ( ) Option None ) true ) Field new ( " " DataType Int8 true ) Field new ( " " DataType Float32 true ) Field new ( " " DataType Float32 true ) Field new ( " " DataType Float32 true ) Field new ( " " DataType Null true ) Field new ( " " DataType Utf8 true ) Field new ( " " DataType Float32 true ) Field new ( " " DataType Float32 true ) Field new ( " " DataType Utf8 true ) Field new ( " " DataType Float32 true ) Field new ( " " DataType Float32 true ) Field new ( " " DataType Float32 true ) Field new ( " " DataType Float32 true ) Field new ( " " DataType Float32 true ) Field new ( " " DataType Float32 true ) ] ) ) }
schema found in earlier nyc taxi files (e.g 2009)
schema found in earlier nyc taxi files ( e . g 2009 )
time_unit
TimeUnit