Skip to content
Browse files

removing unused code

  • Loading branch information...
1 parent 9018444 commit af387e92a520b5426147da9081f1a3b02a787deb @jseidman committed
Showing with 2 additions and 2 deletions.
  1. +2 −2 airline/src/deptdelay_by_month/R/rmr/deptdelay-rmr.R
View
4 airline/src/deptdelay_by_month/R/rmr/deptdelay-rmr.R
@@ -5,13 +5,13 @@
# Requires rmr package (https://github.com/RevolutionAnalytics/RHadoop/wiki).
library(rmr)
+
csvtextinputformat = function(line) keyval(NULL, unlist(strsplit(line, "\\,")))
deptdelay = function (input, output) {
mapreduce(input = input,
output = output,
textinputformat = csvtextinputformat,
- textoutputformat = csvtextoutputformat,
map = function(k, fields) {
# Skip header lines and bad records:
if (!(identical(fields[[1]], "Year")) & length(fields) == 29) {
@@ -28,4 +28,4 @@ deptdelay = function (input, output) {
})
}
-from.dfs(deptdelay("/data/airline/", "/dept-delay-month"))
+from.dfs(deptdelay("/data/airline/1987.csv", "/dept-delay-month"))

0 comments on commit af387e9

Please sign in to comment.
Something went wrong with that request. Please try again.