Class HDInsightSparkActivity


public final class HDInsightSparkActivity extends ExecutionActivity
HDInsight Spark activity.
  • Constructor Details

    • HDInsightSparkActivity

      public HDInsightSparkActivity()
  • Method Details

    • withLinkedServiceName

      public HDInsightSparkActivity withLinkedServiceName(LinkedServiceReference linkedServiceName)
      Set the linkedServiceName property: Linked service reference.
      Overrides:
      withLinkedServiceName in class ExecutionActivity
      Parameters:
      linkedServiceName - the linkedServiceName value to set.
      Returns:
      the ExecutionActivity object itself.
    • withPolicy

      public HDInsightSparkActivity withPolicy(ActivityPolicy policy)
      Set the policy property: Activity policy.
      Overrides:
      withPolicy in class ExecutionActivity
      Parameters:
      policy - the policy value to set.
      Returns:
      the ExecutionActivity object itself.
    • withName

      public HDInsightSparkActivity withName(String name)
      Set the name property: Activity name.
      Overrides:
      withName in class ExecutionActivity
      Parameters:
      name - the name value to set.
      Returns:
      the Activity object itself.
    • withDescription

      public HDInsightSparkActivity withDescription(String description)
      Set the description property: Activity description.
      Overrides:
      withDescription in class ExecutionActivity
      Parameters:
      description - the description value to set.
      Returns:
      the Activity object itself.
    • withDependsOn

      public HDInsightSparkActivity withDependsOn(List<ActivityDependency> dependsOn)
      Set the dependsOn property: Activity depends on condition.
      Overrides:
      withDependsOn in class ExecutionActivity
      Parameters:
      dependsOn - the dependsOn value to set.
      Returns:
      the Activity object itself.
    • withUserProperties

      public HDInsightSparkActivity withUserProperties(List<UserProperty> userProperties)
      Set the userProperties property: Activity user properties.
      Overrides:
      withUserProperties in class ExecutionActivity
      Parameters:
      userProperties - the userProperties value to set.
      Returns:
      the Activity object itself.
    • rootPath

      public Object rootPath()
      Get the rootPath property: The root path in 'sparkJobLinkedService' for all the job’s files. Type: string (or Expression with resultType string).
      Returns:
      the rootPath value.
    • withRootPath

      public HDInsightSparkActivity withRootPath(Object rootPath)
      Set the rootPath property: The root path in 'sparkJobLinkedService' for all the job’s files. Type: string (or Expression with resultType string).
      Parameters:
      rootPath - the rootPath value to set.
      Returns:
      the HDInsightSparkActivity object itself.
    • entryFilePath

      public Object entryFilePath()
      Get the entryFilePath property: The relative path to the root folder of the code/package to be executed. Type: string (or Expression with resultType string).
      Returns:
      the entryFilePath value.
    • withEntryFilePath

      public HDInsightSparkActivity withEntryFilePath(Object entryFilePath)
      Set the entryFilePath property: The relative path to the root folder of the code/package to be executed. Type: string (or Expression with resultType string).
      Parameters:
      entryFilePath - the entryFilePath value to set.
      Returns:
      the HDInsightSparkActivity object itself.
    • arguments

      public List<Object> arguments()
      Get the arguments property: The user-specified arguments to HDInsightSparkActivity.
      Returns:
      the arguments value.
    • withArguments

      public HDInsightSparkActivity withArguments(List<Object> arguments)
      Set the arguments property: The user-specified arguments to HDInsightSparkActivity.
      Parameters:
      arguments - the arguments value to set.
      Returns:
      the HDInsightSparkActivity object itself.
    • getDebugInfo

      public HDInsightActivityDebugInfoOption getDebugInfo()
      Get the getDebugInfo property: Debug info option.
      Returns:
      the getDebugInfo value.
    • withGetDebugInfo

      public HDInsightSparkActivity withGetDebugInfo(HDInsightActivityDebugInfoOption getDebugInfo)
      Set the getDebugInfo property: Debug info option.
      Parameters:
      getDebugInfo - the getDebugInfo value to set.
      Returns:
      the HDInsightSparkActivity object itself.
    • sparkJobLinkedService

      public LinkedServiceReference sparkJobLinkedService()
      Get the sparkJobLinkedService property: The storage linked service for uploading the entry file and dependencies, and for receiving logs.
      Returns:
      the sparkJobLinkedService value.
    • withSparkJobLinkedService

      public HDInsightSparkActivity withSparkJobLinkedService(LinkedServiceReference sparkJobLinkedService)
      Set the sparkJobLinkedService property: The storage linked service for uploading the entry file and dependencies, and for receiving logs.
      Parameters:
      sparkJobLinkedService - the sparkJobLinkedService value to set.
      Returns:
      the HDInsightSparkActivity object itself.
    • className

      public String className()
      Get the className property: The application's Java/Spark main class.
      Returns:
      the className value.
    • withClassName

      public HDInsightSparkActivity withClassName(String className)
      Set the className property: The application's Java/Spark main class.
      Parameters:
      className - the className value to set.
      Returns:
      the HDInsightSparkActivity object itself.
    • proxyUser

      public Object proxyUser()
      Get the proxyUser property: The user to impersonate that will execute the job. Type: string (or Expression with resultType string).
      Returns:
      the proxyUser value.
    • withProxyUser

      public HDInsightSparkActivity withProxyUser(Object proxyUser)
      Set the proxyUser property: The user to impersonate that will execute the job. Type: string (or Expression with resultType string).
      Parameters:
      proxyUser - the proxyUser value to set.
      Returns:
      the HDInsightSparkActivity object itself.
    • sparkConfig

      public Map<String,Object> sparkConfig()
      Get the sparkConfig property: Spark configuration property.
      Returns:
      the sparkConfig value.
    • withSparkConfig

      public HDInsightSparkActivity withSparkConfig(Map<String,Object> sparkConfig)
      Set the sparkConfig property: Spark configuration property.
      Parameters:
      sparkConfig - the sparkConfig value to set.
      Returns:
      the HDInsightSparkActivity object itself.
    • validate

      public void validate()
      Validates the instance.
      Overrides:
      validate in class ExecutionActivity
      Throws:
      IllegalArgumentException - thrown if the instance is not valid.