last-seen.flow.yaml

import:
  - rides.flow.yaml

collections:
  examples/citi-bike/last-seen:
    key: [/bike_id]
    schema:
      type: object
      properties:
        bike_id: { $ref: ride.schema.yaml#/properties/bike_id }
        last: { $ref: ride.schema.yaml#/$defs/terminus }
      required: [bike_id, last]

    derive:
      using:
        sqlite:
          migrations: []
      transforms:
        - name: locationFromRide
          source: { name: examples/citi-bike/rides }
          shuffle: any
          lambda: select $bike_id, $end as last;