org.apache.ignite.yarn.utils

Class IgniteYarnUtils

java.lang.Object

org.apache.ignite.yarn.utils.IgniteYarnUtils

public class IgniteYarnUtils
extends Object

Utils.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_IGNITE_CONFIG
static String	JAR_NAME
static String	SPACE
static String	YARN_LOG_OUT

Constructor Summary

Constructors

Constructor and Description
IgniteYarnUtils()

Method Summary

Modifier and Type	Method and Description
static Path	copyLocalToHdfs(FileSystem fs, String src, String dst)
static ByteBuffer	createTokenBuffer(Credentials creds) Creates a ByteBuffer with serialized Credentials.
static LocalResource	setupFile(Path file, FileSystem fs, LocalResourceType type)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_IGNITE_CONFIG

public static final String DEFAULT_IGNITE_CONFIG

See Also:

Constant Field Values

SPACE

public static final String SPACE

See Also:

Constant Field Values

JAR_NAME

public static final String JAR_NAME

See Also:

Constant Field Values

YARN_LOG_OUT

public static final String YARN_LOG_OUT

See Also:

Constant Field Values

Constructor Detail

IgniteYarnUtils

public IgniteYarnUtils()

Method Detail

setupFile

public static LocalResource setupFile(Path file,
                                      FileSystem fs,
                                      LocalResourceType type)
                               throws Exception

Parameters:

file - Path.

fs - File system.

type - Local resource type.

Throws:

Exception - If failed.

copyLocalToHdfs

public static Path copyLocalToHdfs(FileSystem fs,
                                   String src,
                                   String dst)
                            throws Exception

Parameters:

fs - File system.

src - Source path.

dst - Destination path.

Returns:

Path to file to hdfs file system.

Throws:

Exception

createTokenBuffer

public static ByteBuffer createTokenBuffer(Credentials creds)
                                    throws IOException

Creates a ByteBuffer with serialized Credentials.

Parameters:

creds - The credentials.

Returns:

The ByteBuffer with the credentials.

Throws:

IOException