Class JobMetric

    • Constructor Detail

      • JobMetric

        public JobMetric​(PhysicalPlan physicalPlan)
        Constructor.
        Parameters:
        physicalPlan - physical plan to derive the id from.
      • JobMetric

        public JobMetric​(String id)
        Constructor with the designated id.
        Parameters:
        id - the id.
    • Method Detail

      • getIRDAG

        public com.fasterxml.jackson.databind.JsonNode getIRDAG()
      • getIrDagSummary

        public String getIrDagSummary()
      • getInputSize

        public Long getInputSize()
      • getVertexProperties

        public String getVertexProperties()
      • getEdgeProperties

        public String getEdgeProperties()
      • setIRDAG

        public void setIRDAG​(IRDAG irDag)
        Setter for the IR DAG.
        Parameters:
        irDag - the IR DAG.
      • getStageDAG

        public com.fasterxml.jackson.databind.JsonNode getStageDAG()
      • setStageDAG

        public void setStageDAG​(DAG<Stage,​StageEdge> dag)
        Setter for the stage DAG.
        Parameters:
        dag - the stage DAG.
      • getId

        public String getId()
        Description copied from interface: Metric
        Get its unique id.
        Specified by:
        getId in interface Metric
        Returns:
        an unique id
      • processMetricMessage

        public boolean processMetricMessage​(String metricField,
                                            byte[] metricValue)
        Description copied from interface: Metric
        Process metric message from evaluators.
        Specified by:
        processMetricMessage in interface Metric
        Parameters:
        metricField - field name of the metric.
        metricValue - byte array of serialized data value.
        Returns:
        true if the metric was changed or false if not.