mbracesample2.fs

let prices : (int * float) array =
    [ "http://publicdata.landregistry.gov.uk/market-trend-data/price-paid-data/a/pp-2015.csv" ]
    |> CloudFlow.OfHttpFileByLine                                                                    // Stream the HTTP file across the cluster
    |> CloudFlow.map (HousePrices.ParseRows >> Seq.head)                                             // Convert from raw text to our CSV Provided type
    |> CloudFlow.groupBy(fun row -> row.DateOfTransfer.Month)                                        // Group by month
    |> CloudFlow.map(fun (month, rows) -> month, rows |> Seq.averageBy (fun row -> float row.Price)) // Get the average price for each month
    |> CloudFlow.toArray
    |> cluster.Run