case class PipelineContext(config: PipelineConfig, job: Option[PipelineJob] = None) extends Product with Serializable
The complete configuration context for a pipeline.
- config
The pipeline configuration.
- job
An optional job configuration;
None
if not specified.
- Alphabetic
- By Inheritance
- PipelineContext
- Serializable
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
PipelineContext()
Overloaded constructor that loads the configuration set by the Pipeline Service.
-
new
PipelineContext(config: PipelineConfig, job: Optional[PipelineJob])
Overloaded constructor that supports Java types.
Overloaded constructor that supports Java types.
- config
The pipeline configuration.
- job
An optional job configuration;
None
if not specified.
-
new
PipelineContext(config: PipelineConfig, job: Option[PipelineJob] = None)
- config
The pipeline configuration.
- job
An optional job configuration;
None
if not specified.
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
-
lazy val
applicationConfig: Config
Returns the application's configuration, as specified in application.conf/json/properties.
Returns the application's configuration, as specified in application.conf/json/properties.
The configuration is cached and recomputed only if the pipeline context is serialized.
- Annotations
- @transient()
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- val config: PipelineConfig
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getConfig: PipelineConfig
- returns
the pipeline configuration.
-
def
getIdentity: Optional[PipelineIdentity]
- returns
the optional identity configuration as a Java Optional object.
-
def
getJob: Optional[PipelineJob]
- returns
the optional job configuration as a Java Optional object.
-
val
identity: Option[PipelineIdentity]
- returns
the optional identity setup by the service.
-
def
inputCatalogDescription(catalogId: String): InputCatalogDescription
Returns the description for a catalog given its symbolic ID as defined in the configuration.
Returns the description for a catalog given its symbolic ID as defined in the configuration.
- catalogId
The symbolic ID of the catalog.
- returns
InputCatalogDescription object containing HRN and a ProcessingType object or
None
if not specified.
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val job: Option[PipelineJob]
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
outputCatalogDescription: OutputCatalogDescription
Returns the description for the output catalog.
Returns the description for the output catalog.
- returns
OutputCatalogDescription object containing HRN and possibly a base version.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()