sql-client-config.yaml

tables:
  - name: TaxiRides
    type: source-table
    update-mode: append
    connector:
      type: taxi-rides
      path: "/Users/david/stuff/flink-training/trainingData/nycTaxiRides.gz"
      max-event-delay-secs: 60
      serving-speed-factor: 1800
  - name: TaxiFares
    type: source-table
    update-mode: append
    connector:
      type: taxi-fares
      path: "/Users/david/stuff/flink-training/trainingData/nycTaxiFares.gz"
      max-event-delay-secs: 60
      serving-speed-factor: 1800

functions:
- name: timeDiff
  from: class
  class: com.ververica.flinktraining.exercises.datastream_java.utils.TimeDiff
- name: isInNYC
  from: class
  class: com.ververica.flinktraining.exercises.datastream_java.utils.GeoUtils$IsInNYC
- name: toCellId
  from: class
  class: com.ververica.flinktraining.exercises.datastream_java.utils.GeoUtils$ToCellId
- name: toAreaId
  from: class
  class: com.ververica.flinktraining.exercises.datastream_java.utils.GeoUtils$ToCellId
- name: toCoords
  from: class
  class: com.ververica.flinktraining.exercises.datastream_java.utils.GeoUtils$ToCoords

execution:
  type: streaming                   # required: execution mode either 'batch' or 'streaming'
  result-mode: table                # required: either 'table' or 'changelog'
  time-characteristic: event-time   # optional: 'processing-time' or 'event-time' (default)
  parallelism: 1                    # optional: Flink's parallelism (1 by default)