#! /usr/bin/env Rscript # To disable the warning massages to be printed options(warn=-1) # To initiating the connection to standard input input = file("stdin", "r") # 从原始数据中读取每行,取出每行city,pagepath,输出给reduce while(length(currentLine = readLines(input, n=1, warn=FALSE)) > 0) { fields = unlist(strsplit(currentLine, ",")) # Capturing the city and pagePath from fields city = as.character(fields[3]) pagepath = as.character(fields[4]) # Printing bith to the standard output print(paste(city,pagepath,sep="\t"),stdout()) } # Closing the connection to that input stream close(input)