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

Class HadoopIgfsUtils

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils

public class HadoopIgfsUtils
extends Object

Utility constants and methods for IGFS Hadoop file system.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PARAM_IGFS_ENDPOINT_IGNITE_CFG_PATH Parameter name for endpoint path to Ignite client configuration.
static String	PARAM_IGFS_ENDPOINT_NO_EMBED Parameter name for endpoint no embed mode flag.
static String	PARAM_IGFS_ENDPOINT_NO_LOCAL_SHMEM Parameter name for endpoint no shared memory flag.
static String	PARAM_IGFS_ENDPOINT_NO_LOCAL_TCP Parameter name for endpoint no local TCP flag.
static String	PARAM_IGFS_ENDPOINT_NO_REMOTE_TCP Parameter name for endpoint no remote TCP flag.

Method Summary

Modifier and Type	Method and Description
static IOException	cast(IgniteCheckedException e) Cast Ignite exception to appropriate IO exception.
static IOException	cast(IgniteCheckedException e, String path) Cast Ignite exception to appropriate IO exception.
static void	clear(AbstractFileSystem fs) Deletes all files from the given file system.
static void	clear(FileSystem fs) Deletes all files from the given file system.
static boolean	parameter(Configuration cfg, String name, String authority, boolean dflt) Get boolean parameter.
static int	parameter(Configuration cfg, String name, String authority, int dflt) Get integer parameter.
static String	parameter(Configuration cfg, String name, String authority, String dflt) Get string parameter.

Methods inherited from class java.lang.Object

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

Field Detail

PARAM_IGFS_ENDPOINT_NO_EMBED

public static final String PARAM_IGFS_ENDPOINT_NO_EMBED

Parameter name for endpoint no embed mode flag.

See Also:

Constant Field Values

PARAM_IGFS_ENDPOINT_NO_LOCAL_SHMEM

public static final String PARAM_IGFS_ENDPOINT_NO_LOCAL_SHMEM

Parameter name for endpoint no shared memory flag.

See Also:

Constant Field Values

PARAM_IGFS_ENDPOINT_NO_LOCAL_TCP

public static final String PARAM_IGFS_ENDPOINT_NO_LOCAL_TCP

Parameter name for endpoint no local TCP flag.

See Also:

Constant Field Values

PARAM_IGFS_ENDPOINT_NO_REMOTE_TCP

public static final String PARAM_IGFS_ENDPOINT_NO_REMOTE_TCP

Parameter name for endpoint no remote TCP flag.

See Also:

Constant Field Values

PARAM_IGFS_ENDPOINT_IGNITE_CFG_PATH

public static final String PARAM_IGFS_ENDPOINT_IGNITE_CFG_PATH

Parameter name for endpoint path to Ignite client configuration.

See Also:

Constant Field Values

Method Detail

parameter

public static String parameter(Configuration cfg,
                               String name,
                               String authority,
                               String dflt)

Get string parameter.

Parameters:

cfg - Configuration.

name - Parameter name.

authority - Authority.

dflt - Default value.

Returns:

String value.

parameter

public static int parameter(Configuration cfg,
                            String name,
                            String authority,
                            int dflt)
                     throws IOException

Get integer parameter.

Parameters:

cfg - Configuration.

name - Parameter name.

authority - Authority.

dflt - Default value.

Returns:

Integer value.

Throws:

IOException - In case of parse exception.

parameter

public static boolean parameter(Configuration cfg,
                                String name,
                                String authority,
                                boolean dflt)

Get boolean parameter.

Parameters:

cfg - Configuration.

name - Parameter name.

authority - Authority.

dflt - Default value.

Returns:

Boolean value.

cast

public static IOException cast(IgniteCheckedException e)

Cast Ignite exception to appropriate IO exception.

Parameters:

e - Exception to cast.

Returns:

Casted exception.

cast

public static IOException cast(IgniteCheckedException e,
                               @Nullable
                               String path)

Cast Ignite exception to appropriate IO exception.

Parameters:

e - Exception to cast.

path - Path for exceptions.

Returns:

Casted exception.

clear

public static void clear(FileSystem fs)
                  throws IOException

Deletes all files from the given file system.

Parameters:

fs - The file system to clean up.

Throws:

IOException - On error.

clear

public static void clear(AbstractFileSystem fs)
                  throws IOException

Deletes all files from the given file system.

Parameters:

fs - The file system to clean up.

Throws:

IOException - On error.