org.apache.reef.io.data.output

Class TaskOutputStreamProviderHDFS

java.lang.Object

org.apache.reef.io.data.output.TaskOutputStreamProvider

org.apache.reef.io.data.output.TaskOutputStreamProviderHDFS

All Implemented Interfaces:

OutputStreamProvider

public final class TaskOutputStreamProviderHDFS
extends TaskOutputStreamProvider

Implementation of TaskOutputStreamProvider. It provides FileOutputStreams on HDFS.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() release resources.
DataOutputStream	create(String name) create a file output stream using the given name.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public DataOutputStream create(String name)
                        throws IOException

create a file output stream using the given name. The path of the file on HDFS is 'outputPath/name/taskId'.

Parameters:

name - name of the created output stream It is used as the name of the directory if the created output stream is a file output stream

Returns:

OutputStream to a file on HDFS. The path of the file is 'outputPath/name/taskId'

Throws:

IOException

close

public void close()
           throws IOException

Description copied from interface: OutputStreamProvider

release resources.

Throws:

IOException