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

Class HadoopFileSystemsUtils

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemsUtils

public class HadoopFileSystemsUtils
extends Object

Utilities for configuring file systems to support the separate working directory per each thread.

Field Summary

Fields

Modifier and Type	Field and Description
static String	LOC_FS_WORK_DIR_PROP Name of the property for setting working directory on create new local FS instance.

Constructor Summary

Constructors

Constructor and Description
HadoopFileSystemsUtils()

Method Summary

Modifier and Type	Method and Description
static void	clearFileSystemCache() Clears Hadoop FileSystem cache.
static String	disableFsCachePropertyName(String scheme) Gets the property name to disable file system cache.
static void	setupFileSystems(Configuration cfg) Setup wrappers of filesystems to support the separate working directory.

Methods inherited from class java.lang.Object

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

Field Detail

LOC_FS_WORK_DIR_PROP

public static final String LOC_FS_WORK_DIR_PROP

Name of the property for setting working directory on create new local FS instance.

Constructor Detail

HadoopFileSystemsUtils

public HadoopFileSystemsUtils()

Method Detail

setupFileSystems

public static void setupFileSystems(Configuration cfg)

Setup wrappers of filesystems to support the separate working directory.

Parameters:

cfg - Config for setup.

disableFsCachePropertyName

public static String disableFsCachePropertyName(@Nullable
                                                String scheme)

Gets the property name to disable file system cache.

Parameters:

scheme - The file system URI scheme.

Returns:

The property name. If scheme is null, returns "fs.null.impl.disable.cache".

clearFileSystemCache

public static void clearFileSystemCache()
                                 throws IOException

Clears Hadoop FileSystem cache.

Throws:

IOException - On error.