Hi,
I develop an application that receive a stream file from Hadoop.
The client code:
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Prueba video</title>
</head>
<body>
<object id="video" width="320" height="240"
classid="clsid:6BF52A52-394A-11d3-B153-00C04F79FAA6"
type="application/x-oleobject">
<param name="url" value="GetVideo">
<param name="SendPlayStateChangeEvents" value="true">
<param name="AutoStart" VALUE="true">
<param name="uiMode" value="none">
<param name="PlayCount" value="9999">
</object>
</body>
</html>
The server code from servlet:
protected void processRequest(HttpServletRequest request,
HttpServletResponse response) throws ServletException, IOException {
ServletContext sc = getServletContext();
try {
response.reset();
response.setBufferSize(10240);
response.setContentType("video/avi");
Configuration config = new Configuration();
config.set("fs.default.name", HADOOP_DIR + ":" + HADOOP_PORT);
config.set("hadoop.job.ugi", "root, supergroup");
FileSystem hadoopFileSystem = FileSystem.get(config);
Path ficheroOrigen = new Path(hadoopFileSystem.getWorkingDirectory()
+ "/test/prueba.avi");
FSDataInputStream in = hadoopFileSystem.open(ficheroOrigen);
ServletOutputStream os = response.getOutputStream();
BufferedOutputStream bos = new BufferedOutputStream(os, 10240);
int read = 0;
byte[] bytes = new byte[512];
while((read = in.read(bytes)) != -1) {
bos.write(bytes, 0, read);
}
sc.log("Fin de la lectura del video.");
bos.close();
in.close();
hadoopFileSystem.close();
}
catch(Exception ex) {
ex.printStackTrace();
}
}
I get a SocketException from client, because I need a BufferedFSInputStream
from Hadoop file. The BufferedFSInputStream class have a construct like
this:
BufferedFSInputStream(FSInputStream in, int size)
How do I obtain a buffer stream from hadoop file?
Miguel Ángel Álvarez de la Concepción
Departamento de Lenguajes y Sistemas Informáticos
Escuela Técnica Superior de Ingeniería Informática
Universidad de Sevilla
Teléfono: 954.556.086
Email: maalva...@us.es
