OutputOperationInfo

:: DeveloperApi :: Class having information on output operations.

batchTime: Time of the batch
id: Id of this output operation. Different output operations have different ids in a batch.
name: The name of this output operation.
description: The description of this output operation.
startTime: Clock time of when the output operation started processing
endTime: Clock time of when the output operation started processing
failureReason: Failure reason if this output operation fails

Annotations: @DeveloperApi()
Source: OutputOperationInfo.scala

Linear Supertypes

Serializable, Serializable, Product, Equals, AnyRef, Any

Instance Constructors

new OutputOperationInfo(batchTime: Time, id: Int, name: String, description: String, startTime: Option[Long], endTime: Option[Long], failureReason: Option[String])

batchTime
Time of the batch
id
Id of this output operation. Different output operations have different ids in a batch.
name
The name of this output operation.
description
The description of this output operation.
startTime
Clock time of when the output operation started processing
endTime
Clock time of when the output operation started processing
failureReason
Failure reason if this output operation fails

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
val batchTime: Time

Time of the batch
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
val description: String

The description of this output operation.
def duration: Option[Long]

Return the duration of this output operation.
val endTime: Option[Long]

Clock time of when the output operation started processing
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
val failureReason: Option[String]

Failure reason if this output operation fails
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
val id: Int

Id of this output operation.
Id of this output operation. Different output operations have different ids in a batch.
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
val name: String

The name of this output operation.
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
val startTime: Option[Long]

Clock time of when the output operation started processing
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Related Doc: package scheduler

case class OutputOperationInfo(batchTime: Time, id: Int, name: String, description: String, startTime: Option[Long], endTime: Option[Long], failureReason: Option[String]) extends Product with Serializable

Instance Constructors

new OutputOperationInfo(batchTime: Time, id: Int, name: String, description: String, startTime: Option[Long], endTime: Option[Long], failureReason: Option[String])

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

val batchTime: Time

def clone(): AnyRef

val description: String

def duration: Option[Long]

val endTime: Option[Long]

final def eq(arg0: AnyRef): Boolean

val failureReason: Option[String]

def finalize(): Unit

final def getClass(): Class[_]

val id: Int

final def isInstanceOf[T0]: Boolean

val name: String

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

val startTime: Option[Long]

final def synchronized[T0](arg0: ⇒ T0): T0

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped