Class OutputOperationInfo

Object
org.apache.spark.streaming.scheduler.OutputOperationInfo
All Implemented Interfaces:
Serializable, scala.Equals, scala.Product

public class OutputOperationInfo extends Object implements scala.Product, Serializable
:: DeveloperApi :: Class having information on output operations. param: batchTime Time of the batch param: id Id of this output operation. Different output operations have different ids in a batch. param: name The name of this output operation. param: description The description of this output operation. param: startTime Clock time of when the output operation started processing param: endTime Clock time of when the output operation started processing param: failureReason Failure reason if this output operation fails
See Also:
  • Constructor Details

    • OutputOperationInfo

      public OutputOperationInfo(Time batchTime, int id, String name, String description, scala.Option<Object> startTime, scala.Option<Object> endTime, scala.Option<String> failureReason)
  • Method Details

    • apply

      public abstract static R apply(T1 v1, T2 v2, T3 v3, T4 v4, T5 v5, T6 v6, T7 v7)
    • toString

      public static String toString()
    • batchTime

      public Time batchTime()
    • id

      public int id()
    • name

      public String name()
    • description

      public String description()
    • startTime

      public scala.Option<Object> startTime()
    • endTime

      public scala.Option<Object> endTime()
    • failureReason

      public scala.Option<String> failureReason()
    • duration

      public scala.Option<Object> duration()
      Return the duration of this output operation.
      Returns:
      (undocumented)