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

Class FlowRunDocument

java.lang.Object

org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument

All Implemented Interfaces:

TimelineDocument<FlowRunDocument>

public class FlowRunDocument
extends Object
implements TimelineDocument<FlowRunDocument>

This doc represents the flow run information for every job.

Constructor Summary

Constructors

Constructor	Description
FlowRunDocument()
FlowRunDocument(org.apache.hadoop.yarn.server.timelineservice.collector.TimelineCollectorContext collectorContext, Set<org.apache.hadoop.yarn.api.records.timelineservice.TimelineMetric> metrics)

Method Summary

Modifier and Type	Method	Description
Set<org.apache.hadoop.yarn.api.records.timelineservice.TimelineMetric>	fetchTimelineMetrics()
String	getClusterId()
long	getCreatedTime()
String	getFlowName()
Long	getFlowRunId()
String	getFlowVersion()
String	getId()
long	getMaxEndTime()
Map<String,TimelineMetricSubDoc>	getMetrics()
long	getMinStartTime()
String	getType()
String	getUsername()
void	merge(FlowRunDocument flowRunDoc)	Merge the FlowRunDocument that is passed with the current document for upsert.
void	setClusterId(String clusterId)
void	setCreatedTime(long createdTime)
void	setFlowName(String flowName)
void	setFlowRunId(Long flowRunId)
void	setFlowVersion(String flowVersion)
void	setId(String id)
void	setMaxEndTime(long maxEndTime)
void	setMetrics(Map<String,TimelineMetricSubDoc> metrics)
void	setMinStartTime(long minStartTime)
void	setUsername(String username)

Methods inherited from class java.lang.Object

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

Constructor Details

FlowRunDocument

public FlowRunDocument()

FlowRunDocument

public FlowRunDocument(org.apache.hadoop.yarn.server.timelineservice.collector.TimelineCollectorContext collectorContext,
 Set<org.apache.hadoop.yarn.api.records.timelineservice.TimelineMetric> metrics)

Method Details

merge

public void merge(FlowRunDocument flowRunDoc)

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

Specified by:

merge in interface TimelineDocument<FlowRunDocument>

Parameters:

flowRunDoc - that has to be merged

getId

public String getId()

Specified by:

getId in interface TimelineDocument<FlowRunDocument>

setId

public void setId(String id)

getClusterId

public String getClusterId()

setClusterId

public void setClusterId(String clusterId)

getUsername

public String getUsername()

setUsername

public void setUsername(String username)

getFlowName

public String getFlowName()

setFlowName

public void setFlowName(String flowName)

getFlowRunId

public Long getFlowRunId()

setFlowRunId

public void setFlowRunId(Long flowRunId)

getMetrics

public Map<String,TimelineMetricSubDoc> getMetrics()

setMetrics

public void setMetrics(Map<String,TimelineMetricSubDoc> metrics)

fetchTimelineMetrics

public Set<org.apache.hadoop.yarn.api.records.timelineservice.TimelineMetric> fetchTimelineMetrics()

getMinStartTime

public long getMinStartTime()

setMinStartTime

public void setMinStartTime(long minStartTime)

getMaxEndTime

public long getMaxEndTime()

setMaxEndTime

public void setMaxEndTime(long maxEndTime)

getType

public String getType()

Specified by:

getType in interface TimelineDocument<FlowRunDocument>

getCreatedTime

public long getCreatedTime()

Specified by:

getCreatedTime in interface TimelineDocument<FlowRunDocument>

setCreatedTime

public void setCreatedTime(long createdTime)

Specified by:

setCreatedTime in interface TimelineDocument<FlowRunDocument>

getFlowVersion

public String getFlowVersion()

setFlowVersion

public void setFlowVersion(String flowVersion)