gistfile1.scala

object Download extends Controller {
	import org.apache.commons.logging.Log
	import org.apache.hadoop.conf.Configuration
	import org.apache.hadoop.fs._

	import java.io.InputStream
	import java.net.URI
	import java.net.URLDecoder
	
	def download(filename: String) = {
		try {
			val uri  = play.configuration("hadoop.uri") // "hadoop.uri=hdfs://hadoop" in conf/application.conf file
			val conf = new Configuration()
			val hdfs = FileSystem.get(URI.create(uri), conf)
			
			response.setHeader("Content-type", "application/force-download")
			response.setHeader("Content-Disposition", "attachment; filename=\"" + filename + "\"")
			// response.setHeader("Content-Length", filesize + "");

			response.direct = hdfs.open(new Path(filename)).asInstanceOf[java.io.InputStream]
		}
		catch {
			case e: Exception => Logger.error(e, "Couldn't get file from Hadoop by the given filename")
		}
	}
}