ExampleS3DistCpWorkflow

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. def defaultObject: DefaultObject

   

   Definition Classes

   DataPipelineDefGroup

9. val emrCluster: MapReduceCluster

   

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

    

    Definition Classes

    AnyRef

11. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

12. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

14. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

15. implicit val hc: HyperionContext

    

    Definition Classes

    ExampleS3DistCpWorkflow → DataPipelineDefGroup

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

    

    Definition Classes

    HdfsUriHelper

17. def hdfs: HdfsUriBuilder

    

    Definition Classes

    HdfsUriHelper

18. val instanceBid: UnencryptedParameter[Double]

    

19. val instanceCount: UnencryptedParameter[Int]

    

20. val instanceType: UnencryptedParameter[String]

    

21. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

22. val jar: S3Uri

    

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

    

    Definition Classes

    HyperionCli

24. def nameKeySeparator: String

    

    Definition Classes

    DataPipelineDefGroup

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

    

    Definition Classes

    AnyRef

26. final def notify(): Unit

    

    Definition Classes

    AnyRef

27. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

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

    

    Definition Classes

    ExampleS3DistCpWorkflow → DataPipelineDefGroup

29. def pipelineName: String

    

    Definition Classes

    DataPipelineDefGroup

30. implicit val pv: ParameterValues

    

    Definition Classes

    DataPipelineDefGroup

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

    

    Definition Classes

    S3UriHelper

32. def s3: S3UriBuilder

    

    Definition Classes

    S3UriHelper

33. val s3DistCPActivity: S3DistCpActivity[MapReduceCluster]

    

34. lazy val schedule: RecurringSchedule

    

    Definition Classes

    ExampleS3DistCpWorkflow → DataPipelineDefGroup

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

    
    ignoreMissing

    ignores the parameter with id unknown to the definition

    Definition Classes

    DataPipelineDefGroup

36. val source: String

    

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

    

    Definition Classes

    AnyRef

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

    

    Definition Classes

    ExampleS3DistCpWorkflow → DataPipelineDefGroup

39. val target: UnencryptedParameter[HdfsUri]

    

40. def toString(): String

    

    Definition Classes

    AnyRef → Any

41. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

44. def workflow: WorkflowExpression

    

    Workflow to be defined

    Workflow to be defined

    Definition Classes

    ExampleS3DistCpWorkflow → DataPipelineDef

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

    

    Definition Classes

    WorkflowExpressionImplicits

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

    

    Definition Classes

    DataPipelineDef → DataPipelineDefGroup