Package org.apache.hadoop.yarn.server.timelineservice.storage.flow

Class FlowRunTable

java.lang.Object
org.apache.hadoop.yarn.server.timelineservice.storage.common.BaseTable<FlowRunTable>
org.apache.hadoop.yarn.server.timelineservice.storage.flow.FlowRunTable
public final class FlowRunTable extends BaseTable<FlowRunTable>
The flow run table has column family info Stores per flow run information aggregated across applications. Metrics are also stored in the info column family. Example flow run table record: 
 flow_run table
 |-------------------------------------------|
 |  Row key   | Column Family                |
 |            | info                         |
 |-------------------------------------------|
 | clusterId! | flow_version:version7        |
 | userName!  |                              |
 | flowName!  | running_apps:1               |
 | flowRunId  |                              |
 |            | min_start_time:1392995080000 |
 |            | #0:""                        |
 |            |                              |
 |            | min_start_time:1392995081012 |
 |            | #0:appId2                    |
 |            |                              |
 |            | min_start_time:1392993083210 |
 |            | #0:appId3                    |
 |            |                              |
 |            |                              |
 |            | max_end_time:1392993084018   |
 |            | #0:""                        |
 |            |                              |
 |            |                              |
 |            | m!mapInputRecords:127        |
 |            | #0:""                        |
 |            |                              |
 |            | m!mapInputRecords:31         |
 |            | #2:appId2                    |
 |            |                              |
 |            | m!mapInputRecords:37         |
 |            | #1:appId3                    |
 |            |                              |
 |            |                              |
 |            | m!mapOutputRecords:181       |
 |            | #0:""                        |
 |            |                              |
 |            | m!mapOutputRecords:37        |
 |            | #1:appId3                    |
 |            |                              |
 |            |                              |
 |-------------------------------------------|

  • Constructor Details

    • FlowRunTable

      public FlowRunTable()