Packages

abstract class PipelineRunner extends AnyRef

Implements the main entry points of applications based on the Data Processing Library.

The command line is parsed, a SparkContext is created, a com.here.platform.data.processing.driver.config.DriverConfig is constructed and passed to a new com.here.platform.data.processing.driver.Driver. Finally that com.here.platform.data.processing.driver.Driver is run with the version parameters.

Note

This is a Java friendly version of com.here.platform.data.processing.driver.runner.pipeline.PipelineRunner mixed in with com.here.platform.data.processing.driver.DriverSetupWithBuilder.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PipelineRunner
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new PipelineRunner()

Abstract Value Members

  1. abstract def applicationVersion: String

    The running application version.

  2. abstract def configureCompiler(completeConfig: CompleteConfig, context: java.driver.DriverContext, builder: java.driver.DriverBuilder): java.driver.DriverBuilder

    Configures the compiler the processing library runs using a com.here.platform.data.processing.java.driver.DriverBuilder.

Concrete 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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  6. val delegate: pipeline.PipelineRunner
    Attributes
    protected
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def main(args: Array[String]): Unit

    Runs an application based on the Data Processing Library.

  14. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  15. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. def runWith(args: Array[String], sparkContext: JavaSparkContext, pipelineContext: PipelineContext): Unit

    Runs the runner with the provided Spark context and pipeline context.

    Runs the runner with the provided Spark context and pipeline context. This method is useful for testing.

    args

    The command line arguments.

    sparkContext

    The Spark context.

    pipelineContext

    The pipeline context.

  18. def runWith(args: Array[String], pipelineContext: PipelineContext): Unit

    Runs the runner with the provided pipeline context.

    Runs the runner with the provided pipeline context. This method is useful for testing.

    args

    The command line arguments.

    pipelineContext

    The pipeline context.

  19. def runWith(args: Array[String], sparkContext: JavaSparkContext): Unit

    Runs the runner with the provided Spark context.

    Runs the runner with the provided Spark context. This method is useful for testing.

    args

    The command line arguments.

    sparkContext

    The Spark context,.

  20. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  21. def toString(): String
    Definition Classes
    AnyRef → Any
  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped