Ruter API - ADLA Job

job.sql

REFERENCE ASSEMBLY [Newtonsoft.Json];
REFERENCE ASSEMBLY [Microsoft.Analytics.Samples.Formats];

DECLARE @out string="adl://contoso.azuredatalakestore.net/foo/delayedDepartures.csv";

@departure =
  EXTRACT DataFrameRef string,
  DatedVehicleJourneyRef string,
  DestinationName string,
  AimedArrivalTime string,
  ExpectedArrivalTime string,
  InCongestion string,
  Delay string,
  VehicleJourneyName string,
  filename string
  FROM "adl://contoso.azuredatalakestore.net/Ruter/departures/{filename:*}.json"
  USING new Microsoft.Analytics.Samples.Formats.Json.JsonExtractor();

@testthis = SELECT * 
  FROM @departure
  WHERE Delay != "00:00:00";

OUTPUT @testthis TO @out USING Outputters.Csv();