SparkTaskActivity

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. object ActualEndTime extends ReferenceExpression with DateTimeExp with Product with Serializable

   

   The date and time that the scheduled run actually ended.

   The date and time that the scheduled run actually ended.

   Definition Classes

   RunnableObject

5. object ActualStartTime extends ReferenceExpression with DateTimeExp with Product with Serializable

   

   The date and time that the scheduled run actually started.

   The date and time that the scheduled run actually started.

   Definition Classes

   RunnableObject

6. object FailureReason extends ReferenceExpression with StringExp with Product with Serializable

   

   The reason for the failure to create the resource.

   The reason for the failure to create the resource.

   Definition Classes

   RunnableObject

7. object Hostname extends ReferenceExpression with DateTimeExp with Product with Serializable

   

   The host name of client that picked up the task attempt.

   The host name of client that picked up the task attempt.

   Definition Classes

   RunnableObject

8. object Name extends ReferenceExpression with StringExp with Product with Serializable

   

   Definition Classes

   RunnableObject

9. object PipelineId extends ReferenceExpression with StringExp with Product with Serializable

   

   Definition Classes

   RunnableObject

10. object ReportProgressTime extends ReferenceExpression with DateTimeExp with Product with Serializable

    

    The last time that Task Runner, or other code that is processing the tasks, called the ReportTaskProgress operation.

    The last time that Task Runner, or other code that is processing the tasks, called the ReportTaskProgress operation.

    Definition Classes

    RunnableObject

11. object ScheduledEndTime extends ReferenceExpression with DateTimeExp with Product with Serializable

    

    The date and time that the run was scheduled to end.

    The date and time that the run was scheduled to end.

    Definition Classes

    RunnableObject

12. object ScheduledStartTime extends ReferenceExpression with DateTimeExp with Product with Serializable

    

    The date and time that the run was scheduled to start.

    The date and time that the run was scheduled to start.

    Definition Classes

    RunnableObject

13. object Status extends ReferenceExpression with StringExp with Product with Serializable

    

    The status of this object.

    The status of this object. Possible values are: pending, waiting_on_dependencies, running, waiting_on_runner, successful, and failed.

    Definition Classes

    RunnableObject

14. object TriesLeft extends ReferenceExpression with IntExp with Product with Serializable

    

    The number of attempted runs remaining before setting the status of this object to failed.

    The number of attempted runs remaining before setting the status of this object to failed.

    Definition Classes

    RunnableObject

15. object WaitingOn extends ReferenceExpression with StringExp with Product with Serializable

    

    A list of all objects that this object is waiting on before it can enter the RUNNING state.

    A list of all objects that this object is waiting on before it can enter the RUNNING state.

    Definition Classes

    RunnableObject

16. def apply(jarUri: HString, mainClass: MainClass)(runsOn: Resource[SparkCluster])(implicit hc: HyperionContext): SparkTaskActivity

    

17. def apply(jarUri: HS3Uri, mainClass: MainClass)(runsOn: Resource[SparkCluster])(implicit hc: HyperionContext): SparkTaskActivity

    

18. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

19. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

20. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

21. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

22. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

23. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

24. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

25. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

26. def jobRunner(runsOn: Resource[SparkCluster])(implicit hc: HyperionContext): HString

    

    Definition Classes

    SparkCommandRunner

27. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

28. final def notify(): Unit

    

    Definition Classes

    AnyRef

29. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

30. def objectName: Option[String]

    

    Definition Classes

    RunnableObject

31. def scriptRunner(runsOn: Resource[SparkCluster]): HString

    

    Definition Classes

    SparkCommandRunner

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

    

    Definition Classes

    AnyRef

33. def toString(): String

    

    Definition Classes

    AnyRef → Any

34. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

36. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )