org.apache.ignite.internal.processors.hadoop

Interface GridHadoopJobInfo

All Superinterfaces:

Serializable

public interface GridHadoopJobInfo
extends Serializable

Compact job description.

Method Summary

Methods

Modifier and Type	Method and Description
GridHadoopJob	createJob(GridHadoopJobId jobId, IgniteLogger log) Creates new job instance for the given ID.
boolean	hasCombiner() Checks whether job has combiner.
boolean	hasReducer() Checks whether job has reducer.
String	jobName() Gets job name.
String	property(String name) Gets optional configuration property for the job.
int	reducers()
String	user() Gets user name.

Method Detail

property

@Nullable
String property(String name)

Gets optional configuration property for the job.

Parameters:

name - Property name.

Returns:

Value or null if none.

hasCombiner

boolean hasCombiner()

Checks whether job has combiner.

Returns:

true If job has combiner.

hasReducer

boolean hasReducer()

Checks whether job has reducer. Actual number of reducers will be in GridHadoopMapReducePlan.reducers().

Returns:

Number of reducer.

createJob

GridHadoopJob createJob(GridHadoopJobId jobId,
                      IgniteLogger log)
                        throws IgniteCheckedException

Creates new job instance for the given ID. GridHadoopJobInfo is reusable for multiple jobs while GridHadoopJob is for one job execution. This method will be called once for the same ID on one node, though it can be called on the same host multiple times from different processes (in case of multiple nodes on the same host or external execution).

Parameters:

jobId - Job ID.

log - Logger.

Returns:

Job.

Throws:

IgniteCheckedException - If failed.

reducers

int reducers()

Returns:

Number of reducers configured for job.

jobName

String jobName()

Gets job name.

Returns:

Job name.

user

String user()

Gets user name.

Returns:

User name.