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.
- Alphabetic
- By Inheritance
- PipelineRunner
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new PipelineRunner()
Abstract Value Members
- 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(scala.this.throws.<init>$default$1[Exception])
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- 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
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def exitOnFailure: Boolean
Specifies whether the pipeline should exit (by calling
sys.exit(1)) when an exception is thrown by therunmethod; defaults tofalse.Specifies whether the pipeline should exit (by calling
sys.exit(1)) when an exception is thrown by therunmethod; defaults tofalse.- Attributes
- protected
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def main(args: Array[String]): Unit
The entry point for the pipeline application, from where the
runmethod is called.The entry point for the pipeline application, from where the
runmethod is called.- args
The command line arguments.
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- 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
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)