Package com.azure.resourcemanager.datafactory.models

Class HDInsightStreamingActivity

  • public final class HDInsightStreamingActivity
extends ExecutionActivity
    HDInsight streaming activity type.

    • Constructor Detail

      • HDInsightStreamingActivity

        public HDInsightStreamingActivity()

    • Method Detail

      • storageLinkedServices

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

      • withStorageLinkedServices

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

      • arguments

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

      • withArguments

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

      • mapper

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

      • withMapper

        public HDInsightStreamingActivity withMapper​(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.

      • reducer

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

      • withReducer

        public HDInsightStreamingActivity withReducer​(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.

      • input

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

      • withInput

        public HDInsightStreamingActivity withInput​(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.

      • output

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

      • withOutput

        public HDInsightStreamingActivity withOutput​(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.

      • filePaths

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

      • withFilePaths

        public HDInsightStreamingActivity withFilePaths​(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.

      • fileLinkedService

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

      • withFileLinkedService

        public HDInsightStreamingActivity withFileLinkedService​(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.

      • combiner

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

      • withCombiner

        public HDInsightStreamingActivity withCombiner​(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.

      • commandEnvironment

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

      • withCommandEnvironment

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

      • defines

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

      • withDefines

        public HDInsightStreamingActivity withDefines​(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.