com.cloudera.lib.service
Interface Hadoop

All Known Implementing Classes:

HadoopService

public interface Hadoop

Nested Class Summary

static interface	Hadoop.FileSystemExecutor<T>
static interface	Hadoop.JobClientExecutor<T>

Method Summary

org.apache.hadoop.fs.FileSystem	createFileSystem(String user, org.apache.hadoop.conf.Configuration conf)
<T> T	execute(String user, org.apache.hadoop.conf.Configuration conf, Hadoop.FileSystemExecutor<T> executor)
<T> T	execute(String user, org.apache.hadoop.conf.Configuration conf, Hadoop.JobClientExecutor<T> executor)
org.apache.hadoop.conf.Configuration	getDefaultConfiguration()
void	releaseFileSystem(org.apache.hadoop.fs.FileSystem fs)

Method Detail

execute

<T> T execute(String user,
              org.apache.hadoop.conf.Configuration conf,
              Hadoop.FileSystemExecutor<T> executor)
          throws HadoopException

Throws:

HadoopException

execute

<T> T execute(String user,
              org.apache.hadoop.conf.Configuration conf,
              Hadoop.JobClientExecutor<T> executor)
          throws HadoopException

Throws:

HadoopException

createFileSystem

org.apache.hadoop.fs.FileSystem createFileSystem(String user,
                                                 org.apache.hadoop.conf.Configuration conf)
                                                 throws IOException,
                                                        HadoopException

Throws:

IOException

HadoopException

releaseFileSystem

void releaseFileSystem(org.apache.hadoop.fs.FileSystem fs)
                       throws IOException

Throws:

IOException

getDefaultConfiguration

org.apache.hadoop.conf.Configuration getDefaultConfiguration()