com.cloudera.hoop.fs
Class FSOpen

java.lang.Object
  com.cloudera.hoop.fs.FSOpen

All Implemented Interfaces:

Hadoop.FileSystemExecutor<InputStream>

public class FSOpen
extends Object
implements Hadoop.FileSystemExecutor<InputStream>

Executor that performs a open Hadoop files system operation.

Constructor Summary

FSOpen(String path)
Creates a open executor.

Method Summary

InputStream

execute(org.apache.hadoop.fs.FileSystem fs) Executes the filesystem operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

FSOpen

public FSOpen(String path)

Creates a open executor.

Parameters:

path - file to open.

Method Detail

execute

public InputStream execute(org.apache.hadoop.fs.FileSystem fs)
                    throws IOException

Executes the filesystem operation.

Specified by:

execute in interface Hadoop.FileSystemExecutor<InputStream>

Parameters:

fs - filesystem instance to use.

Returns:

The inputstream of the file.

Throws:

IOException - thrown if an IO error occured.