org.apache.spark.streaming.scheduler

Class OutputOperationInfo

Object

org.apache.spark.streaming.scheduler.OutputOperationInfo

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

public class OutputOperationInfo
extends Object
implements scala.Product, scala.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:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
OutputOperationInfo(Time batchTime, int id, String name, String description, scala.Option<Object> startTime, scala.Option<Object> endTime, scala.Option<String> failureReason)

Method Summary

Modifier and Type	Method and Description
abstract static R	apply(T1 v1, T2 v2, T3 v3, T4 v4, T5 v5, T6 v6, T7 v7)
Time	batchTime()
String	description()
scala.Option<Object>	duration() Return the duration of this output operation.
scala.Option<Object>	endTime()
scala.Option<String>	failureReason()
int	id()
String	name()
scala.Option<Object>	startTime()
static String	toString()

Methods inherited from class Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

OutputOperationInfo

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

Method Detail

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)