org.apache.ignite.internal.processors.hadoop.impl.delegate

Class HadoopBasicFileSystemFactoryDelegate

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate

All Implemented Interfaces:

HadoopFileSystemFactoryDelegate, LifecycleAware

Direct Known Subclasses:

HadoopCachingFileSystemFactoryDelegate, HadoopKerberosFileSystemFactoryDelegate

public class HadoopBasicFileSystemFactoryDelegate
extends Object
implements HadoopFileSystemFactoryDelegate

Basic Hadoop file system factory delegate.

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	cfg Configuration of the secondary filesystem, never null.
protected URI	fullUri Resulting URI.
protected HadoopFileSystemFactory	proxy Proxy.
protected Path	workDir Work directory.

Constructor Summary

Constructors

Constructor and Description
HadoopBasicFileSystemFactoryDelegate(BasicHadoopFileSystemFactory proxy) Constructor.

Method Summary

Modifier and Type	Method and Description
protected FileSystem	create(String usrName) Internal file system creation routine, invoked in correct class loader context.
FileSystem	get(String name) Gets file system for the given user name.
protected FileSystem	getWithMappedName(String usrName) Internal file system create routine.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

proxy

protected final HadoopFileSystemFactory proxy

Proxy.

cfg

protected Configuration cfg

Configuration of the secondary filesystem, never null.

fullUri

protected URI fullUri

Resulting URI.

workDir

protected Path workDir

Work directory.

Constructor Detail

HadoopBasicFileSystemFactoryDelegate

public HadoopBasicFileSystemFactoryDelegate(BasicHadoopFileSystemFactory proxy)

Constructor.

Parameters:

proxy - Proxy.

Method Detail

get

public FileSystem get(String name)
               throws IOException

Gets file system for the given user name.

Specified by:

get in interface HadoopFileSystemFactoryDelegate

Parameters:

name - User name

Returns:

File system.

Throws:

IOException - In case of error.

getWithMappedName

protected FileSystem getWithMappedName(String usrName)
                                throws IOException

Internal file system create routine.

Parameters:

usrName - User name.

Returns:

File system.

Throws:

IOException - If failed.

create

protected FileSystem create(String usrName)
                     throws IOException,
                            InterruptedException

Internal file system creation routine, invoked in correct class loader context.

Parameters:

usrName - User name.

Returns:

File system.

Throws:

IOException - If failed.

InterruptedException - if the current thread is interrupted.

start

public void start()
           throws IgniteException

Specified by:

start in interface LifecycleAware

Throws:

IgniteException

stop

public void stop()
          throws IgniteException

Specified by:

stop in interface LifecycleAware

Throws:

IgniteException