c

com.here.platform.pipeline

PipelineRunner

abstract class PipelineRunner extends AnyRef

A simple base trait for main classes that implement the pipeline processing logic. PipelineRunner that automatically generates a pipeline context. Subclasses need only to implement a run method. Additionally, you can use command line arguments to customize the context construction.

Linear Supertypes
AnyRef, Any
Known Subclasses
PipelineRunner, ImplPipelineRunner
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 run(context: PipelineContext, cmdLine: CommandLineConfig): Unit

    Runs a pipeline's processing logic, given the pipeline's context and the command line configuration.

    Runs a pipeline's processing logic, given the pipeline's context and the command line configuration.

    context

    The pipeline's context.

    cmdLine

    The command line configuration.

    Attributes
    protected
    Annotations
    @throws( ... )

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. def createContext(cmdLine: CommandLineConfig): PipelineContext

    Creates the context in which the pipeline runs.

    Creates the context in which the pipeline runs. The default implementation creates a context using the configuration provided by the Pipeline Service.

    cmdLine

    The command line configuration.

    returns

    a new pipeline context.

    Attributes
    protected
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. def exitOnFailure: Boolean

    Specifies whether the pipeline should exit (by calling sys.exit(1)) when an exception is thrown by the run method; defaults to false.

    Specifies whether the pipeline should exit (by calling sys.exit(1)) when an exception is thrown by the run method; defaults to false.

    Attributes
    protected
  10. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  11. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  14. final def main(args: Array[String]): Unit

    The entry point for the pipeline application, from where the run method is called.

    The entry point for the pipeline application, from where the run method is called.

    args

    The command line arguments.

  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. def parseCommandLine(args: Array[String]): CommandLineConfig

    Parses the command line arguments.

    Parses the command line arguments. Override this method to parse custom CommandLineConfig subclasses.

    args

    The command line arguments.

    returns

    the command line configuration.

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

Inherited from AnyRef

Inherited from Any

Ungrouped