com.cloudera.api.model

Class ApiActivity

java.lang.Object

com.cloudera.api.model.ApiActivity

public class ApiActivity
extends Object

Represents a user activity, such as a MapReduce job, a Hive query, an Oozie workflow, etc.

Constructor Summary

Constructors

Constructor and Description
ApiActivity()
ApiActivity(String id, String name, ApiActivityType type, ApiActivityStatus status, String parent, Date startTime, Date finishTime, String user, String group) Default view
ApiActivity(String id, String name, ApiActivityType type, ApiActivityStatus status, String parent, Date startTime, Date finishTime, String user, String group, String inputDir, String outputDir, String mapper, String combiner, String reducer, String queueName, String schedulerPriority) Full view of an activity

Method Summary

Methods

Modifier and Type	Method and Description
String	getCombiner() The combiner class.
Date	getFinishTime() The finish time of this activity.
String	getGroup() The user-group of this activity.
String	getId() Activity id, which is unique within a MapReduce service.
String	getInputDir() The input data directory of the activity.
String	getMapper() The mapper class.
String	getName() Activity name.
String	getOutputDir() The output result directory of the activity.
String	getParent() The name of the parent activity.
String	getQueueName() The scheduler queue this activity is in.
String	getReducer() The reducer class.
String	getSchedulerPriority() The scheduler priority of this activity.
Date	getStartTime() The start time of this activity.
ApiActivityStatus	getStatus() Activity status.
ApiActivityType	getType() Activity type.
String	getUser() The user who submitted this activity.
void	setCombiner(String combiner)
void	setFinishTime(Date finishTime)
void	setGroup(String group)
void	setId(String id)
void	setInputDir(String inputDir)
void	setMapper(String mapper)
void	setName(String name)
void	setOutputDir(String outputDir)
void	setParent(String parent)
void	setQueueName(String queueName)
void	setReducer(String reducer)
void	setSchedulerPriority(String schedulerPriority)
void	setStartTime(Date startTime)
void	setStatus(ApiActivityStatus status)
void	setType(ApiActivityType type)
void	setUser(String user)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ApiActivity

public ApiActivity()

ApiActivity

public ApiActivity(String id,
           String name,
           ApiActivityType type,
           ApiActivityStatus status,
           String parent,
           Date startTime,
           Date finishTime,
           String user,
           String group)

Default view

Parameters:

id - The id of the activity

name - The name of the activity

type - The activity type

status - The activity status

parent - The parent of the activity

startTime - The time the activity started

finishTime - The time the activity finished

user - The user running the activity

group - The group running the activity

ApiActivity

public ApiActivity(String id,
           String name,
           ApiActivityType type,
           ApiActivityStatus status,
           String parent,
           Date startTime,
           Date finishTime,
           String user,
           String group,
           String inputDir,
           String outputDir,
           String mapper,
           String combiner,
           String reducer,
           String queueName,
           String schedulerPriority)

Full view of an activity

Parameters:

id - The activity id

name - The activity name

type - The type of activity

status - The status of the activity

parent - The parent of the activity

startTime - The time the activity started

finishTime - The time the activity finished

user - The user who started the activity

group - The group of the running activity

inputDir - The input directory

outputDir - The output directory

mapper - The mapper class for the activity

combiner - The combiner class for the activity

reducer - The reducer class for the activity

queueName - The name of the scheduler queue

schedulerPriority - The scheduler priority

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getName

public String getName()

Activity name.

setName

public void setName(String name)

getType

public ApiActivityType getType()

Activity type. Whether it's an MR job, a Pig job, a Hive query, etc.

setType

public void setType(ApiActivityType type)

getParent

public String getParent()

The name of the parent activity.

setParent

public void setParent(String parent)

getStartTime

public Date getStartTime()

The start time of this activity.

setStartTime

public void setStartTime(Date startTime)

getFinishTime

public Date getFinishTime()

The finish time of this activity.

setFinishTime

public void setFinishTime(Date finishTime)

getId

public String getId()

Activity id, which is unique within a MapReduce service.

setId

public void setId(String id)

getStatus

public ApiActivityStatus getStatus()

Activity status.

setStatus

public void setStatus(ApiActivityStatus status)

getUser

public String getUser()

The user who submitted this activity.

setUser

public void setUser(String user)

getGroup

public String getGroup()

The user-group of this activity.

setGroup

public void setGroup(String group)

getInputDir

public String getInputDir()

The input data directory of the activity. An HDFS url.

setInputDir

public void setInputDir(String inputDir)

getOutputDir

public String getOutputDir()

The output result directory of the activity. An HDFS url.

setOutputDir

public void setOutputDir(String outputDir)

getMapper

public String getMapper()

The mapper class.

setMapper

public void setMapper(String mapper)

getCombiner

public String getCombiner()

The combiner class.

setCombiner

public void setCombiner(String combiner)

getReducer

public String getReducer()

The reducer class.

setReducer

public void setReducer(String reducer)

getQueueName

public String getQueueName()

The scheduler queue this activity is in.

setQueueName

public void setQueueName(String queueName)

getSchedulerPriority

public String getSchedulerPriority()

The scheduler priority of this activity.

setSchedulerPriority

public void setSchedulerPriority(String schedulerPriority)