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

Class HadoopKerberosFileSystemFactoryDelegate

java.lang.Object

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

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

All Implemented Interfaces:

HadoopFileSystemFactoryDelegate, LifecycleAware

public class HadoopKerberosFileSystemFactoryDelegate
extends HadoopBasicFileSystemFactoryDelegate

Kerberos Hadoop file system factory delegate.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate

cfg, fullUri, proxy, workDir

Constructor Summary

Constructors

Constructor and Description
HadoopKerberosFileSystemFactoryDelegate(KerberosHadoopFileSystemFactory 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	getWithMappedName(String name) Internal file system create routine.
void	start()

Methods inherited from class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate

get, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopKerberosFileSystemFactoryDelegate

public HadoopKerberosFileSystemFactoryDelegate(KerberosHadoopFileSystemFactory proxy)

Constructor.

Parameters:

proxy - Proxy.

Method Detail

getWithMappedName

public FileSystem getWithMappedName(String name)
                             throws IOException

Internal file system create routine.

Overrides:

getWithMappedName in class HadoopBasicFileSystemFactoryDelegate

Parameters:

name - 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.

Overrides:

create in class HadoopBasicFileSystemFactoryDelegate

Parameters:

usrName - User name.

Returns:

File system.

Throws:

IOException - If failed.

InterruptedException - if the current thread is interrupted.

start

public void start()
           throws IgniteException

Description copied from class: HadoopBasicFileSystemFactoryDelegate

Specified by:

start in interface LifecycleAware

Overrides:

start in class HadoopBasicFileSystemFactoryDelegate

Throws:

IgniteException