org.apache.ignite.internal.processors.hadoop

Class HadoopAttributes

java.lang.Object

org.apache.ignite.internal.processors.hadoop.HadoopAttributes

All Implemented Interfaces:

Externalizable, Serializable

public class HadoopAttributes
extends Object
implements Externalizable

Hadoop attributes.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME Attribute name.

Constructor Summary

Constructors

Constructor and Description
HadoopAttributes() Externalizable support.
HadoopAttributes(HadoopConfiguration cfg) Constructor.

Method Summary

Modifier and Type	Method and Description
int	cores()
boolean	externalExecution()
static HadoopAttributes	forNode(ClusterNode node) Get attributes for node (if any).
int	maxParallelTasks()
int	maxTaskQueueSize()
String[]	nativeLibraryNames()
String	plannerClassName()
void	readExternal(ObjectInput in)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final String NAME

Attribute name.

See Also:

Constant Field Values

Constructor Detail

HadoopAttributes

public HadoopAttributes()

Externalizable support.

HadoopAttributes

public HadoopAttributes(HadoopConfiguration cfg)

Constructor.

Parameters:

cfg - Configuration.

Method Detail

forNode

@Nullable
public static HadoopAttributes forNode(ClusterNode node)

Get attributes for node (if any).

Parameters:

node - Node.

Returns:

Attributes or null if Hadoop Accelerator is not enabled for node.

plannerClassName

public String plannerClassName()

Returns:

Map reduce planner class name.

externalExecution

public boolean externalExecution()

Returns:

External execution flag.

maxParallelTasks

public int maxParallelTasks()

Returns:

Maximum parallel tasks.

maxTaskQueueSize

public int maxTaskQueueSize()

Returns:

Maximum task queue size.

nativeLibraryNames

public String[] nativeLibraryNames()

Returns:

Native library names.

cores

public int cores()

Returns:

Number of cores on machine.

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

toString

public String toString()

Overrides:

toString in class Object