Class HDInsightStreamingActivity


public class HDInsightStreamingActivity extends ExecutionActivity
HDInsight streaming activity type.
  • Constructor Details

    • HDInsightStreamingActivity

      public HDInsightStreamingActivity()
  • Method Details

    • getStorageLinkedServices

      public List<LinkedServiceReference> getStorageLinkedServices()
      Get the storageLinkedServices property: Storage linked service references.
      Returns:
      the storageLinkedServices value.
    • setStorageLinkedServices

      public HDInsightStreamingActivity setStorageLinkedServices(List<LinkedServiceReference> storageLinkedServices)
      Set the storageLinkedServices property: Storage linked service references.
      Parameters:
      storageLinkedServices - the storageLinkedServices value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • getArguments

      public List<Object> getArguments()
      Get the arguments property: User specified arguments to HDInsightActivity.
      Returns:
      the arguments value.
    • setArguments

      public HDInsightStreamingActivity setArguments(List<Object> arguments)
      Set the arguments property: User specified arguments to HDInsightActivity.
      Parameters:
      arguments - the arguments value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • getGetDebugInfo

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

      public HDInsightStreamingActivity setGetDebugInfo(HDInsightActivityDebugInfoOption getDebugInfo)
      Set the getDebugInfo property: Debug info option.
      Parameters:
      getDebugInfo - the getDebugInfo value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • getMapper

      public Object getMapper()
      Get the mapper property: Mapper executable name. Type: string (or Expression with resultType string).
      Returns:
      the mapper value.
    • setMapper

      public HDInsightStreamingActivity setMapper(Object mapper)
      Set the mapper property: Mapper executable name. Type: string (or Expression with resultType string).
      Parameters:
      mapper - the mapper value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • getReducer

      public Object getReducer()
      Get the reducer property: Reducer executable name. Type: string (or Expression with resultType string).
      Returns:
      the reducer value.
    • setReducer

      public HDInsightStreamingActivity setReducer(Object reducer)
      Set the reducer property: Reducer executable name. Type: string (or Expression with resultType string).
      Parameters:
      reducer - the reducer value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • getInput

      public Object getInput()
      Get the input property: Input blob path. Type: string (or Expression with resultType string).
      Returns:
      the input value.
    • setInput

      public HDInsightStreamingActivity setInput(Object input)
      Set the input property: Input blob path. Type: string (or Expression with resultType string).
      Parameters:
      input - the input value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • getOutput

      public Object getOutput()
      Get the output property: Output blob path. Type: string (or Expression with resultType string).
      Returns:
      the output value.
    • setOutput

      public HDInsightStreamingActivity setOutput(Object output)
      Set the output property: Output blob path. Type: string (or Expression with resultType string).
      Parameters:
      output - the output value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • getFilePaths

      public List<Object> getFilePaths()
      Get the filePaths property: Paths to streaming job files. Can be directories.
      Returns:
      the filePaths value.
    • setFilePaths

      public HDInsightStreamingActivity setFilePaths(List<Object> filePaths)
      Set the filePaths property: Paths to streaming job files. Can be directories.
      Parameters:
      filePaths - the filePaths value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • getFileLinkedService

      public LinkedServiceReference getFileLinkedService()
      Get the fileLinkedService property: Linked service reference where the files are located.
      Returns:
      the fileLinkedService value.
    • setFileLinkedService

      public HDInsightStreamingActivity setFileLinkedService(LinkedServiceReference fileLinkedService)
      Set the fileLinkedService property: Linked service reference where the files are located.
      Parameters:
      fileLinkedService - the fileLinkedService value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • getCombiner

      public Object getCombiner()
      Get the combiner property: Combiner executable name. Type: string (or Expression with resultType string).
      Returns:
      the combiner value.
    • setCombiner

      public HDInsightStreamingActivity setCombiner(Object combiner)
      Set the combiner property: Combiner executable name. Type: string (or Expression with resultType string).
      Parameters:
      combiner - the combiner value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • getCommandEnvironment

      public List<Object> getCommandEnvironment()
      Get the commandEnvironment property: Command line environment values.
      Returns:
      the commandEnvironment value.
    • setCommandEnvironment

      public HDInsightStreamingActivity setCommandEnvironment(List<Object> commandEnvironment)
      Set the commandEnvironment property: Command line environment values.
      Parameters:
      commandEnvironment - the commandEnvironment value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • getDefines

      public Map<String,Object> getDefines()
      Get the defines property: Allows user to specify defines for streaming job request.
      Returns:
      the defines value.
    • setDefines

      public HDInsightStreamingActivity setDefines(Map<String,Object> defines)
      Set the defines property: Allows user to specify defines for streaming job request.
      Parameters:
      defines - the defines value to set.
      Returns:
      the HDInsightStreamingActivity object itself.
    • setLinkedServiceName

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

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

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

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

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

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