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

Class HadoopClientProtocol

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol

All Implemented Interfaces:

org.apache.hadoop.ipc.VersionedProtocol, org.apache.hadoop.mapreduce.protocol.ClientProtocol

public class HadoopClientProtocol
extends Object
implements org.apache.hadoop.mapreduce.protocol.ClientProtocol

Hadoop client protocol.

Field Summary

Fields inherited from interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

versionID

Constructor Summary

Constructors

Constructor and Description
HadoopClientProtocol(Configuration conf, MapReduceClient cli) Constructor.

Method Summary

Modifier and Type	Method and Description
void	cancelDelegationToken(Token<org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier> token)
MapReduceClient	client() Gets the GridClient data.
TaskTrackerInfo[]	getActiveTrackers()
JobStatus[]	getAllJobs()
TaskTrackerInfo[]	getBlacklistedTrackers()
QueueInfo[]	getChildQueues(String queueName)
ClusterMetrics	getClusterMetrics()
Token<org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier>	getDelegationToken(Text renewer)
String	getFilesystemName()
Counters	getJobCounters(JobID jobId)
String	getJobHistoryDir()
JobStatus	getJobStatus(JobID jobId)
Cluster.JobTrackerStatus	getJobTrackerStatus()
LogParams	getLogFileParams(JobID jobID, TaskAttemptID taskAttemptID)
JobID	getNewJobID()
org.apache.hadoop.ipc.ProtocolSignature	getProtocolSignature(String protocol, long clientVersion, int clientMethodsHash)
long	getProtocolVersion(String protocol, long clientVersion)
QueueInfo	getQueue(String queueName)
QueueAclsInfo[]	getQueueAclsForCurrentUser()
AccessControlList	getQueueAdmins(String queueName)
QueueInfo[]	getQueues()
QueueInfo[]	getRootQueues()
String	getStagingAreaDir()
String	getSystemDir()
TaskCompletionEvent[]	getTaskCompletionEvents(JobID jobid, int fromEventId, int maxEvents)
String[]	getTaskDiagnostics(TaskAttemptID taskId)
TaskReport[]	getTaskReports(JobID jobid, TaskType type)
long	getTaskTrackerExpiryInterval()
void	killJob(JobID jobId)
boolean	killTask(TaskAttemptID taskId, boolean shouldFail)
long	renewDelegationToken(Token<org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier> token)
void	setJobPriority(JobID jobid, String priority)
JobStatus	submitJob(JobID jobId, String jobSubmitDir, Credentials ts)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopClientProtocol

public HadoopClientProtocol(Configuration conf,
                            MapReduceClient cli)

Constructor.

Parameters:

conf - Configuration.

cli - Client.

Method Detail

getNewJobID

public JobID getNewJobID()
                  throws IOException,
                         InterruptedException

Specified by:

getNewJobID in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

submitJob

public JobStatus submitJob(JobID jobId,
                           String jobSubmitDir,
                           Credentials ts)
                    throws IOException,
                           InterruptedException

Specified by:

submitJob in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getClusterMetrics

public ClusterMetrics getClusterMetrics()
                                 throws IOException,
                                        InterruptedException

Specified by:

getClusterMetrics in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getJobTrackerStatus

public Cluster.JobTrackerStatus getJobTrackerStatus()
                                             throws IOException,
                                                    InterruptedException

Specified by:

getJobTrackerStatus in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getTaskTrackerExpiryInterval

public long getTaskTrackerExpiryInterval()
                                  throws IOException,
                                         InterruptedException

Specified by:

getTaskTrackerExpiryInterval in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getQueueAdmins

public AccessControlList getQueueAdmins(String queueName)
                                 throws IOException

Specified by:

getQueueAdmins in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

killJob

public void killJob(JobID jobId)
             throws IOException,
                    InterruptedException

Specified by:

killJob in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

setJobPriority

public void setJobPriority(JobID jobid,
                           String priority)
                    throws IOException,
                           InterruptedException

Specified by:

setJobPriority in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

killTask

public boolean killTask(TaskAttemptID taskId,
                        boolean shouldFail)
                 throws IOException,
                        InterruptedException

Specified by:

killTask in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getJobStatus

public JobStatus getJobStatus(JobID jobId)
                       throws IOException,
                              InterruptedException

Specified by:

getJobStatus in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getJobCounters

public Counters getJobCounters(JobID jobId)
                        throws IOException,
                               InterruptedException

Specified by:

getJobCounters in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getTaskReports

public TaskReport[] getTaskReports(JobID jobid,
                                   TaskType type)
                            throws IOException,
                                   InterruptedException

Specified by:

getTaskReports in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getFilesystemName

public String getFilesystemName()
                         throws IOException,
                                InterruptedException

Specified by:

getFilesystemName in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getAllJobs

public JobStatus[] getAllJobs()
                       throws IOException,
                              InterruptedException

Specified by:

getAllJobs in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getTaskCompletionEvents

public TaskCompletionEvent[] getTaskCompletionEvents(JobID jobid,
                                                     int fromEventId,
                                                     int maxEvents)
                                              throws IOException,
                                                     InterruptedException

Specified by:

getTaskCompletionEvents in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getTaskDiagnostics

public String[] getTaskDiagnostics(TaskAttemptID taskId)
                            throws IOException,
                                   InterruptedException

Specified by:

getTaskDiagnostics in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getActiveTrackers

public TaskTrackerInfo[] getActiveTrackers()
                                    throws IOException,
                                           InterruptedException

Specified by:

getActiveTrackers in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getBlacklistedTrackers

public TaskTrackerInfo[] getBlacklistedTrackers()
                                         throws IOException,
                                                InterruptedException

Specified by:

getBlacklistedTrackers in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getSystemDir

public String getSystemDir()
                    throws IOException,
                           InterruptedException

Specified by:

getSystemDir in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getStagingAreaDir

public String getStagingAreaDir()
                         throws IOException,
                                InterruptedException

Specified by:

getStagingAreaDir in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getJobHistoryDir

public String getJobHistoryDir()
                        throws IOException,
                               InterruptedException

Specified by:

getJobHistoryDir in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getQueues

public QueueInfo[] getQueues()
                      throws IOException,
                             InterruptedException

Specified by:

getQueues in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getQueue

public QueueInfo getQueue(String queueName)
                   throws IOException,
                          InterruptedException

Specified by:

getQueue in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getQueueAclsForCurrentUser

public QueueAclsInfo[] getQueueAclsForCurrentUser()
                                           throws IOException,
                                                  InterruptedException

Specified by:

getQueueAclsForCurrentUser in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getRootQueues

public QueueInfo[] getRootQueues()
                          throws IOException,
                                 InterruptedException

Specified by:

getRootQueues in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getChildQueues

public QueueInfo[] getChildQueues(String queueName)
                           throws IOException,
                                  InterruptedException

Specified by:

getChildQueues in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getDelegationToken

public Token<org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier> getDelegationToken(Text renewer)
                                                                                                          throws IOException,
                                                                                                                 InterruptedException

Specified by:

getDelegationToken in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

renewDelegationToken

public long renewDelegationToken(Token<org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier> token)
                          throws IOException,
                                 InterruptedException

Specified by:

renewDelegationToken in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

cancelDelegationToken

public void cancelDelegationToken(Token<org.apache.hadoop.mapreduce.security.token.delegation.DelegationTokenIdentifier> token)
                           throws IOException,
                                  InterruptedException

Specified by:

cancelDelegationToken in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getLogFileParams

public LogParams getLogFileParams(JobID jobID,
                                  TaskAttemptID taskAttemptID)
                           throws IOException,
                                  InterruptedException

Specified by:

getLogFileParams in interface org.apache.hadoop.mapreduce.protocol.ClientProtocol

Throws:

IOException

InterruptedException

getProtocolVersion

public long getProtocolVersion(String protocol,
                               long clientVersion)
                        throws IOException

Specified by:

getProtocolVersion in interface org.apache.hadoop.ipc.VersionedProtocol

Throws:

IOException

getProtocolSignature

public org.apache.hadoop.ipc.ProtocolSignature getProtocolSignature(String protocol,
                                                                    long clientVersion,
                                                                    int clientMethodsHash)
                                                             throws IOException

Specified by:

getProtocolSignature in interface org.apache.hadoop.ipc.VersionedProtocol

Throws:

IOException

client

public MapReduceClient client()

Gets the GridClient data.

Returns:

The client data.