AwsS3CpActivity

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. def <(that: PipelineObject): Boolean

   

   Definition Classes

   Ordered

4. def <=(that: PipelineObject): Boolean

   

   Definition Classes

   Ordered

5. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

6. def >(that: PipelineObject): Boolean

   

   Definition Classes

   Ordered

7. def >=(that: PipelineObject): Boolean

   

   Definition Classes

   Ordered

8. val activityFields: ActivityFields[Ec2Resource]

   

   Definition Classes

   AwsS3CpActivity → PipelineActivity

9. val additionalArguments: Seq[HString]

   

10. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

11. def attemptTimeout: Option[HDuration]

    

    Definition Classes

    PipelineActivity

12. val baseFields: BaseFields

    

    Definition Classes

    AwsS3CpActivity → NamedPipelineObject

13. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

14. def compare(that: PipelineObject): Int

    

    Definition Classes

    PipelineObject → Ordered

15. def compareTo(that: PipelineObject): Int

    

    Definition Classes

    Ordered → Comparable

16. def dependsOn: Seq[PipelineActivity[_]]

    

    Definition Classes

    PipelineActivity

17. val destinationS3Path: HS3Uri

    

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

    

    Definition Classes

    AnyRef

19. def failureAndRerunMode: Option[FailureAndRerunMode]

    

    Definition Classes

    PipelineActivity

20. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

22. def groupedBy(group: String): Self

    

    Postfix the name field

    Postfix the name field

    Definition Classes

    NamedPipelineObject

23. def id: PipelineObjectId

    

    Definition Classes

    NamedPipelineObject → PipelineObject

24. def idGroupedBy(group: String): Self

    

    Have a grouping postfix in the id field

    Have a grouping postfix in the id field

    Definition Classes

    NamedPipelineObject

    Note

    Id naming is more restrictive, it is recommended to not changing the id unleass you have a good reason

25. def idNamed(namePrefix: String): Self

    

    Id field will be prefixed with name

    Id field will be prefixed with name

    Definition Classes

    NamedPipelineObject

    Note

    Id naming is more restrictive, it is recommended to not changing the id unless you have a good reason

26. def input: Seq[S3DataNode]

    

    Definition Classes

    BaseShellCommandActivity

27. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

28. val isOverwrite: HBoolean

    

29. val isRecursive: HBoolean

    

30. def lateAfterTimeout: Option[HDuration]

    

    Definition Classes

    PipelineActivity

31. def maxActiveInstances: Option[HInt]

    

    Definition Classes

    PipelineActivity

32. def maximumRetries: Option[HInt]

    

    Definition Classes

    PipelineActivity

33. def name: Option[String]

    

    Name of the pipeline object, if not set, it will defaults to

    Name of the pipeline object, if not set, it will defaults to

    Option(id)

    Definition Classes

    NamedPipelineObject

34. def named(namePrefix: String): Self

    

    Give the object a name prefix

    Give the object a name prefix

    Definition Classes

    NamedPipelineObject

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

    

    Definition Classes

    AnyRef

36. final def notify(): Unit

    

    Definition Classes

    AnyRef

37. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

38. def objects: Iterable[PipelineObject]

    

    Definition Classes

    BaseShellCommandActivity → PipelineActivity → PipelineObject

39. def onFail(alarms: SnsAlarm*): Self

    

    Definition Classes

    PipelineActivity

40. def onFailAlarms: Seq[SnsAlarm]

    

    Definition Classes

    PipelineActivity

41. def onLateAction(alarms: SnsAlarm*): Self

    

    Definition Classes

    PipelineActivity

42. def onLateActionAlarms: Seq[SnsAlarm]

    

    Definition Classes

    PipelineActivity

43. def onSuccess(alarms: SnsAlarm*): Self

    

    Definition Classes

    PipelineActivity

44. def onSuccessAlarms: Seq[SnsAlarm]

    

    Definition Classes

    PipelineActivity

45. def output: Seq[S3DataNode]

    

    Definition Classes

    BaseShellCommandActivity

46. def preconditions: Seq[Precondition]

    

    Definition Classes

    PipelineActivity

47. def ref: AdpRef[AdpActivity]

    

    Definition Classes

    PipelineActivity → PipelineObject

48. def retryDelay: Option[HDuration]

    

    Definition Classes

    PipelineActivity

49. def runsOn: Resource[Ec2Resource]

    

    Definition Classes

    PipelineActivity

50. def script: Script

    

    Definition Classes

    AwsS3CpActivity → BaseShellCommandActivity

51. def scriptArguments: Seq[HType]

    

    Definition Classes

    BaseShellCommandActivity

52. implicit def seq2Option[A](anySeq: Seq[A]): Option[Seq[A]]

    

    Definition Classes

    PipelineObject

53. def seqToOption[A, B](anySeq: Seq[A])(transform: (A) ⇒ B): Option[Seq[B]]

    

    Definition Classes

    PipelineObject

54. def serialize: AdpShellCommandActivity

    

    Definition Classes

    BaseShellCommandActivity → PipelineActivity → PipelineObject

55. val shellCommandActivityFields: ShellCommandActivityFields

    

    Definition Classes

    AwsS3CpActivity → WithS3Input → BaseShellCommandActivity

56. val sourceS3Path: HS3Uri

    

57. def stage: Option[HBoolean]

    

    Definition Classes

    BaseShellCommandActivity

58. def stderr: Option[HString]

    

    Definition Classes

    BaseShellCommandActivity

59. def stdout: Option[HString]

    

    Definition Classes

    BaseShellCommandActivity

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

    

    Definition Classes

    AnyRef

61. implicit def uniquePipelineId2String(id: PipelineObjectId): String

    

    Definition Classes

    PipelineObject

62. def updateActivityFields(fields: ActivityFields[Ec2Resource]): AwsS3CpActivity

    

    Definition Classes

    AwsS3CpActivity → PipelineActivity

63. def updateBaseFields(fields: BaseFields): AwsS3CpActivity

    

    Definition Classes

    AwsS3CpActivity → NamedPipelineObject

64. def updateShellCommandActivityFields(fields: ShellCommandActivityFields): AwsS3CpActivity

    

    Definition Classes

    AwsS3CpActivity → WithS3Input → BaseShellCommandActivity

65. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

68. def whenMet(conditions: Precondition*): Self

    

    Definition Classes

    PipelineActivity

69. def withAcl(cannedAcl: HString): AwsS3CpActivity

    

70. def withAdditionalArguments(arguments: HString*): AwsS3CpActivity

    

71. def withArguments(args: HString*): Self

    

    Definition Classes

    BaseShellCommandActivity

72. def withAttemptTimeout(duration: HDuration): Self

    

    Definition Classes

    PipelineActivity

73. def withDestinationRegion(destinationRegion: HString): AwsS3CpActivity

    

74. def withExclude(pattern: HString): AwsS3CpActivity

    

75. def withFailureAndRerunMode(mode: FailureAndRerunMode): Self

    

    Definition Classes

    PipelineActivity

76. def withGrant(permission: HString, granteeTypeAndId: Seq[(String, String)]): AwsS3CpActivity

    

77. def withInclude(pattern: HString): AwsS3CpActivity

    

78. def withInput(inputs: S3DataNode*): Self

    

    Definition Classes

    WithS3Input

79. def withLateAfterTimeout(duration: HDuration): Self

    

    Definition Classes

    PipelineActivity

80. def withMaxActiveInstances(activeInstances: HInt): Self

    

    Definition Classes

    PipelineActivity

81. def withMaximumRetries(retries: HInt): Self

    

    Definition Classes

    PipelineActivity

82. def withOverwrite(): AwsS3CpActivity

    

83. def withProfile(profile: HString): AwsS3CpActivity

    

84. def withRecursive(): AwsS3CpActivity

    

85. def withRetryDelay(duration: HDuration): Self

    

    Definition Classes

    PipelineActivity

86. def withSourceRegion(sourceRegion: HString): AwsS3CpActivity

    

87. def withStderrTo(err: HString): Self

    

    Definition Classes

    BaseShellCommandActivity

88. def withStdoutTo(out: HString): Self

    

    Definition Classes

    BaseShellCommandActivity