object RunnerService extends ServiceBase[RunnerFacade]

Main class for launching the jar. main-method simply launches a runner servlet in a webserver.

Linear Supertypes
ServiceBase[RunnerFacade], Logging, LoggingLike, RealTimeAware, ServiceBaseFacade, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RunnerService
  2. ServiceBase
  3. Logging
  4. LoggingLike
  5. RealTimeAware
  6. ServiceBaseFacade
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

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. def apiKey: UUID
    Definition Classes
    ServiceBaseFacade
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  7. def debug(message: ⇒ String, context: ⇒ String = getClass.getSimpleName): Unit
    Definition Classes
    LoggingLike
  8. def debugScope[T](message: (Int) ⇒ String, context: ⇒ String = getClass.getSimpleName)(action: ⇒ T): T
    Definition Classes
    LoggingLike
  9. def endpoint: String
    Definition Classes
    ServiceBase
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  12. def error(message: ⇒ String, context: ⇒ String = getClass.getSimpleName): Unit
    Definition Classes
    LoggingLike
  13. def error(e: Throwable): Unit
    Definition Classes
    LoggingLike
  14. val facadeEnvironment: ServiceFacadeEnvironment
    Definition Classes
    ServiceBaseFacade
  15. def getApplicationService: ApplicationFacade
    Definition Classes
    ServiceBase
  16. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  17. def getMaxHeap: Int
  18. def handleMessage(timestamp: LocalDateTime, message: ⇒ String, level: String, context: ⇒ String): Unit
    Definition Classes
    Logging → LoggingLike
  19. def hasShutDownStarted: Boolean
  20. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  21. var heartbeatTimer: Timer
    Definition Classes
    ServiceBase
  22. def info(message: ⇒ String, context: ⇒ String = getClass.getSimpleName): Unit
    Definition Classes
    LoggingLike
  23. def initScalaCompiler(): Unit
  24. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  25. def isLocal: Boolean
  26. def isStopped: Boolean
    Definition Classes
    ServiceBase
  27. def loopEnvironments[T](serviceName: String)(action: (String) ⇒ T): List[T]
    Definition Classes
    ServiceBase
  28. def main(args: Array[String]): Unit
  29. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  30. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  31. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  32. val portNumber: Int
    Definition Classes
    RunnerService → ServiceBase
  33. def registerService(serviceName: String): Unit
    Definition Classes
    ServiceBase
  34. def scalaCompiler: AsyncObject[ScalaCompiler]
  35. var schedulerNames: Array[String]
  36. val serviceName: String
    Definition Classes
    ServiceBaseFacade
  37. def setConfigParameters(serviceName: String): Unit
    Definition Classes
    ServiceBase
  38. def shutdown(session: SparkSession, waitForCompletion: ⇒ Unit = { }): Unit
  39. var sparkJobLauncher: SparkJobLauncher
  40. var sparkMasterEndpoint: String
  41. def start(applicationServiceEndpoint: String, sparkMasterEndpoint: String, serviceName: String, schedulerNames: Array[String], apiKey: UUID, startScalaCompiler: Boolean, startJobLauncher: Boolean = true, startLogBuffer: Boolean = true): Unit
  42. def startHeartbeatTimer(serviceName: String, onCachePurge: ⇒ Unit = {}): Timer
    Definition Classes
    ServiceBase
  43. def startServlet[TServlet <: Servlet](servletClass: Class[TServlet], applicationServiceEndpoint: String, serviceName: String, apiKey: UUID, startLogBuffer: Boolean, databasePath: Option[String], beforeServletStart: ⇒ Unit = {}, startHeartbeat: Boolean = true, multipartConfig: Option[MultipartConfig] = None, onCachePurge: ⇒ Unit = {}): Unit
    Definition Classes
    ServiceBase
  44. def startThreads(startJobLauncher: Boolean = true, serviceName: String): Unit
  45. def stop(port: Int): Unit
  46. def stop(): Unit
    Definition Classes
    ServiceBase
  47. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  48. val systemAuthorization: SystemAuth
    Definition Classes
    ServiceBase
  49. val systemEnvironment: SystemEnvironment
    Definition Classes
    ServiceBase
  50. def toString(): String
    Definition Classes
    AnyRef → Any
  51. lazy val transformExecuterFactory: TransformExecuterFactory
  52. def utcNowJava: LocalDateTime

    The current UTC date and time.

    The current UTC date and time.

    Definition Classes
    RealTimeAware
  53. def utcTodayJava: LocalDateTime

    The current UTC date.

    The current UTC date.

    Definition Classes
    RealTimeAware
  54. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  55. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  56. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  57. def warn(message: ⇒ String, context: ⇒ String = getClass.getSimpleName): Unit
    Definition Classes
    LoggingLike

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated
    Deprecated

Inherited from ServiceBase[RunnerFacade]

Inherited from Logging

Inherited from LoggingLike

Inherited from RealTimeAware

Inherited from ServiceBaseFacade

Inherited from AnyRef

Inherited from Any

Ungrouped