org.apache.ignite.internal.processors.hadoop

Class HadoopCommonUtils

java.lang.Object

org.apache.ignite.internal.processors.hadoop.HadoopCommonUtils

public class HadoopCommonUtils
extends Object

Common Hadoop utility methods which do not depend on Hadoop API.

Field Summary

Fields

Modifier and Type	Field and Description
static String	JOB_CLS_NAME Job class name.
static String	JOB_COUNTER_WRITER_PROPERTY Property to set custom writer of job statistics.
static String	JOB_SUBMISSION_START_TS_PROPERTY Property to store timestamp of job submission.
static String	REQ_NEW_JOBID_TS_PROPERTY Property to store timestamp of new job id request.
static String	RESPONSE_NEW_JOBID_TS_PROPERTY Property to store timestamp of response of new job id request.

Method Summary

Modifier and Type	Method and Description
static void	restoreContextClassLoader(ClassLoader oldLdr) Restore context class loader.
static ClassLoader	setContextClassLoader(ClassLoader newLdr) Set context class loader.
static List<HadoopInputSplit>	sortInputSplits(Collection<HadoopInputSplit> splits) Sort input splits by length.

Methods inherited from class java.lang.Object

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

Field Detail

JOB_CLS_NAME

public static final String JOB_CLS_NAME

Job class name.

See Also:

Constant Field Values

REQ_NEW_JOBID_TS_PROPERTY

public static final String REQ_NEW_JOBID_TS_PROPERTY

Property to store timestamp of new job id request.

See Also:

Constant Field Values

RESPONSE_NEW_JOBID_TS_PROPERTY

public static final String RESPONSE_NEW_JOBID_TS_PROPERTY

Property to store timestamp of response of new job id request.

See Also:

Constant Field Values

JOB_SUBMISSION_START_TS_PROPERTY

public static final String JOB_SUBMISSION_START_TS_PROPERTY

Property to store timestamp of job submission.

See Also:

Constant Field Values

JOB_COUNTER_WRITER_PROPERTY

public static final String JOB_COUNTER_WRITER_PROPERTY

Property to set custom writer of job statistics.

See Also:

Constant Field Values

Method Detail

sortInputSplits

public static List<HadoopInputSplit> sortInputSplits(Collection<HadoopInputSplit> splits)

Sort input splits by length.

Parameters:

splits - Splits.

Returns:

Sorted splits.

setContextClassLoader

@Nullable
public static ClassLoader setContextClassLoader(@Nullable
                                                          ClassLoader newLdr)

Set context class loader.

Parameters:

newLdr - New class loader.

Returns:

Old class loader.

restoreContextClassLoader

public static void restoreContextClassLoader(@Nullable
                                             ClassLoader oldLdr)

Restore context class loader.

Parameters:

oldLdr - Original class loader.