odlomb03.sql

@stations =
    EXTRACT SensorId int,
            SensorType string,
            Measure string,
            StationId int,
            StationName string,
            Height int,
            Province string,
            City string,
            Address string,
            dontcare0 string,
            dontcare1 string,
            dontcare2 string,
            dontcare3 string,
            dontcare4 string
    FROM "/user/mindflavor/Stazioni_Meteorologiche_noheader.csv"
    USING Extractors.Csv();

@events =
    EXTRACT SensorId int,
            Data DateTime,
            Value float,
            State string
    FROM "/user/mindflavor/sensori_arpa_2015_noheader.csv"
    USING Extractors.Csv();

@joined =
    SELECT e.SensorId,
           s.SensorType,
           s.Measure,
           s.StationId,
           s.StationName,
           s.Height,
           s.Province,
           s.City,
           s.Address,
           e.Data,
           e.Value,
           e.State
    FROM @events AS e
         LEFT OUTER JOIN
             @stations AS s
         ON
         e.SensorId == s.SensorId;

OUTPUT @joined
TO "/user/mindflavor/output/joined.csv"
USING Outputters.Tsv();