alluxio.job.wire

Class WorkflowInfo

java.lang.Object

alluxio.job.wire.WorkflowInfo

All Implemented Interfaces:

JobInfo

public class WorkflowInfo
extends Object
implements JobInfo

The workflow description.

Constructor Summary

Constructors

Constructor and Description
WorkflowInfo(JobInfo jobInfo) Constructor from the proto object.
WorkflowInfo(long id, String name, Status status, long lastUpdated, String errorType, String errorMessage, List<JobInfo> children) Default constructor.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
List<JobInfo>	getChildren()
String	getDescription()
String	getErrorMessage()
String	getErrorType()
long	getId()
long	getLastUpdated()
String	getName()
Long	getParentId()
Serializable	getResult()
Status	getStatus()
int	hashCode()
JobInfo	toProto()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

WorkflowInfo

public WorkflowInfo(long id,
                    String name,
                    Status status,
                    long lastUpdated,
                    String errorType,
                    String errorMessage,
                    List<JobInfo> children)

Default constructor.

Parameters:

id - id of the workflow

name - name of the workflow

status - Status of the workflow

lastUpdated - lastUpdated time in milliseconds

errorType - error type

errorMessage - error message

children - list of child job infos

WorkflowInfo

public WorkflowInfo(JobInfo jobInfo)
             throws IOException

Constructor from the proto object.

Parameters:

jobInfo - proto representation of the job

Throws:

IOException

Method Detail

getId

public long getId()

Specified by:

getId in interface JobInfo

Returns:

job id

getParentId

@Nullable
public Long getParentId()

Specified by:

getParentId in interface JobInfo

Returns:

parent job id

getName

@Nonnull
public String getName()

Specified by:

getName in interface JobInfo

Returns:

name of the job

getDescription

@Nonnull
public String getDescription()

Specified by:

getDescription in interface JobInfo

Returns:

description of the job

getStatus

@Nonnull
public Status getStatus()

Specified by:

getStatus in interface JobInfo

Returns:

status of the job

getLastUpdated

public long getLastUpdated()

Specified by:

getLastUpdated in interface JobInfo

Returns:

last updated time in milliseconds

getChildren

@Nonnull
public List<JobInfo> getChildren()

Specified by:

getChildren in interface JobInfo

Returns:

collection of children

getResult

@Nullable
public Serializable getResult()

Specified by:

getResult in interface JobInfo

Returns:

result of the job

getErrorType

@Nonnull
public String getErrorType()

Specified by:

getErrorType in interface JobInfo

Returns:

error type

getErrorMessage

@Nonnull
public String getErrorMessage()

Specified by:

getErrorMessage in interface JobInfo

Returns:

error message

toProto

@Nonnull
public JobInfo toProto()
                         throws IOException

Specified by:

toProto in interface JobInfo

Returns:

proto representation of the job info

Throws:

IOException - if serialization fails

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object