AiravatJobListener

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. val airavatJobMetric: TableQuery[AiravatJobMetric]

   

5. val airavatQueryMetric: TableQuery[AiravatQueryMetric]

   

6. var appId: String

   

7. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

8. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

9. val db: slick.jdbc.JdbcBackend.Database

   

10. var disposableJobsQueue: Queue[Int]

    

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

    

    Definition Classes

    AnyRef

12. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

13. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

15. val gson: Gson

    

16. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

17. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

18. var jobInfo: Map[Int, JobMetricTuple]

    

19. var jobMap: Map[Int, Int]

    

20. def logQueryMetrics(queryMetricTuple: QueryMetricTuple): Unit

    

21. val logger: Logger

    

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

    

    Definition Classes

    AnyRef

23. final def notify(): Unit

    

    Definition Classes

    AnyRef

24. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

25. def onApplicationEnd(applicationEnd: SparkListenerApplicationEnd): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

26. def onApplicationStart(applicationStart: SparkListenerApplicationStart): Unit

    

    Definition Classes

    AiravatJobListener → SparkListener → SparkListenerInterface

27. def onBlockManagerAdded(blockManagerAdded: SparkListenerBlockManagerAdded): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

28. def onBlockManagerRemoved(blockManagerRemoved: SparkListenerBlockManagerRemoved): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

29. def onBlockUpdated(blockUpdated: SparkListenerBlockUpdated): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

30. def onEnvironmentUpdate(environmentUpdate: SparkListenerEnvironmentUpdate): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

31. def onExecutorAdded(executorAdded: SparkListenerExecutorAdded): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

32. def onExecutorBlacklisted(executorBlacklisted: SparkListenerExecutorBlacklisted): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

33. def onExecutorBlacklistedForStage(executorBlacklistedForStage: SparkListenerExecutorBlacklistedForStage): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

34. def onExecutorMetricsUpdate(executorMetricsUpdate: SparkListenerExecutorMetricsUpdate): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

35. def onExecutorRemoved(executorRemoved: SparkListenerExecutorRemoved): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

36. def onExecutorUnblacklisted(executorUnblacklisted: SparkListenerExecutorUnblacklisted): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

37. def onJobEnd(jobEnd: SparkListenerJobEnd): Unit

    

    Definition Classes

    AiravatJobListener → SparkListener → SparkListenerInterface

38. def onJobStart(jobStart: SparkListenerJobStart): Unit

    

    Definition Classes

    AiravatJobListener → SparkListener → SparkListenerInterface

39. def onNodeBlacklisted(nodeBlacklisted: SparkListenerNodeBlacklisted): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

40. def onNodeBlacklistedForStage(nodeBlacklistedForStage: SparkListenerNodeBlacklistedForStage): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

41. def onNodeUnblacklisted(nodeUnblacklisted: SparkListenerNodeUnblacklisted): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

42. def onOtherEvent(event: SparkListenerEvent): Unit

    

    Definition Classes

    AiravatJobListener → SparkListener → SparkListenerInterface

43. def onSpeculativeTaskSubmitted(speculativeTask: SparkListenerSpeculativeTaskSubmitted): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

44. def onStageCompleted(stageCompleted: SparkListenerStageCompleted): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

45. def onStageSubmitted(stageSubmitted: SparkListenerStageSubmitted): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

46. def onTaskEnd(taskEnd: SparkListenerTaskEnd): Unit

    

    Definition Classes

    AiravatJobListener → SparkListener → SparkListenerInterface

47. def onTaskGettingResult(taskGettingResult: SparkListenerTaskGettingResult): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

48. def onTaskStart(taskStart: SparkListenerTaskStart): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

49. def onUnpersistRDD(unpersistRDD: SparkListenerUnpersistRDD): Unit

    

    Definition Classes

    SparkListener → SparkListenerInterface

50. var queryInfo: Map[Long, QueryMetricTuple]

    

51. var queryMap: Map[Long, Seq[Int]]

    

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

    

    Definition Classes

    AnyRef

53. def toString(): String

    

    Definition Classes

    AnyRef → Any

54. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )