Package org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity

Class FlowActivityDocument

java.lang.Object

org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument

All Implemented Interfaces:

TimelineDocument<FlowActivityDocument>

public class FlowActivityDocument
extends Object
implements TimelineDocument<FlowActivityDocument>

This doc represents the FlowActivityEntity which is used for showing all the flow runs with limited information.

Constructor Summary

Constructors

Constructor	Description
FlowActivityDocument()
FlowActivityDocument(String flowName, String flowVersion, long flowRunId)

Method Summary

Modifier and Type	Method	Description
void	addFlowActivity(String flowActivityName, String flowVersion, long flowRunId)
long	getCreatedTime()
long	getDayTimestamp()
Set<FlowActivitySubDoc>	getFlowActivities()
String	getFlowName()
String	getId()
String	getType()
String	getUser()
void	merge(FlowActivityDocument flowActivityDocument)	Merge the FlowActivityDocument that is passed with the current document for upsert.
void	setCreatedTime(long time)
void	setDayTimestamp(long dayTimestamp)
void	setFlowActivities(Set<FlowActivitySubDoc> flowActivities)
void	setFlowName(String flowName)
void	setId(String id)
void	setUser(String user)

Methods inherited from class java.lang.Object

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

Constructor Details

FlowActivityDocument

public FlowActivityDocument()

FlowActivityDocument

public FlowActivityDocument(String flowName,
 String flowVersion,
 long flowRunId)

Method Details

merge

public void merge(FlowActivityDocument flowActivityDocument)

Merge the FlowActivityDocument that is passed with the current document for upsert.

Specified by:

merge in interface TimelineDocument<FlowActivityDocument>

Parameters:

flowActivityDocument - that has to be merged

getId

public String getId()

Specified by:

getId in interface TimelineDocument<FlowActivityDocument>

setId

public void setId(String id)

getType

public String getType()

Specified by:

getType in interface TimelineDocument<FlowActivityDocument>

addFlowActivity

public void addFlowActivity(String flowActivityName,
 String flowVersion,
 long flowRunId)

getFlowActivities

public Set<FlowActivitySubDoc> getFlowActivities()

setFlowActivities

public void setFlowActivities(Set<FlowActivitySubDoc> flowActivities)

getCreatedTime

public long getCreatedTime()

Specified by:

getCreatedTime in interface TimelineDocument<FlowActivityDocument>

setCreatedTime

public void setCreatedTime(long time)

Specified by:

setCreatedTime in interface TimelineDocument<FlowActivityDocument>

getDayTimestamp

public long getDayTimestamp()

setDayTimestamp

public void setDayTimestamp(long dayTimestamp)

getUser

public String getUser()

setUser

public void setUser(String user)

getFlowName

public String getFlowName()

setFlowName

public void setFlowName(String flowName)