ExampleSpark

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. implicit def activity2WorkflowExpression(activity: PipelineActivity[_ <: ResourceObject]): WorkflowExpression

   

   Definition Classes

   WorkflowExpressionImplicits

5. implicit def activityIterable2WorkflowExpression(activities: Iterable[PipelineActivity[_ <: ResourceObject]]): WorkflowExpression

   

   Definition Classes

   WorkflowExpressionImplicits

6. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

7. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

8. val dataNode: S3DataNode

   

9. def defaultObject: DefaultObject

   

   Definition Classes

   DataPipelineDefGroup

10. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

11. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

12. val filterActivity: SparkTaskActivity

    

13. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

14. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

15. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

16. implicit val hc: HyperionContext

    

    Definition Classes

    ExampleSpark → DataPipelineDefGroup

17. def hdfs(uri: String*): HdfsUri

    

    Definition Classes

    HdfsUriHelper

18. def hdfs: HdfsUriBuilder

    

    Definition Classes

    HdfsUriHelper

19. val instanceBid: UnencryptedParameter[Double]

    

20. val instanceCount: UnencryptedParameter[Int]

    

21. val instanceType: UnencryptedParameter[String]

    

22. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

23. val jar: S3Uri

    

24. val location: UnencryptedParameter[S3Uri]

    

25. val mailAction: SnsAlarm

    

26. def main(args: Array[String]): Unit

    

    Definition Classes

    HyperionCli

27. def nameKeySeparator: String

    

    Definition Classes

    DataPipelineDefGroup

28. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

29. final def notify(): Unit

    

    Definition Classes

    AnyRef

30. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

31. def parameters: Iterable[Parameter[_]]

    

    Definition Classes

    ExampleSpark → DataPipelineDefGroup

32. def pipelineName: String

    

    Definition Classes

    DataPipelineDefGroup

33. implicit val pv: ParameterValues

    

    Definition Classes

    DataPipelineDefGroup

34. def s3(uri: String*): S3Uri

    

    Definition Classes

    S3UriHelper

35. def s3: S3UriBuilder

    

    Definition Classes

    S3UriHelper

36. lazy val schedule: RecurringSchedule

    

    Definition Classes

    ExampleSpark → DataPipelineDefGroup

37. val scoreActivity: SparkActivity

    

38. val scoreStep1: SparkStep

    

39. val scoreStep2: SparkStep

    

40. val scoreStep3: SparkStep

    

41. val scoreStep4: SparkStep

    

42. def setParameterValue(id: String, value: String, ignoreMissing: Boolean = true): Unit

    
    ignoreMissing

    ignores the parameter with id unknown to the definition

    Definition Classes

    DataPipelineDefGroup

43. val sparkCluster: SparkCluster

    

44. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

45. lazy val tags: Map[String, Option[String]]

    

    Definition Classes

    ExampleSpark → DataPipelineDefGroup

46. val target: String

    

47. def toString(): String

    

    Definition Classes

    AnyRef → Any

48. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

49. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

50. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

51. def workflow: WorkflowExpression

    

    Workflow to be defined

    Workflow to be defined

    Definition Classes

    ExampleSpark → DataPipelineDef

52. implicit def workflowIterable2WorkflowExpression(activities: Iterable[WorkflowExpression]): WorkflowExpression

    

    Definition Classes

    WorkflowExpressionImplicits

53. final def workflows: Map[WorkflowKey, WorkflowExpression]

    

    Definition Classes

    DataPipelineDef → DataPipelineDefGroup