HDInsightStreamingActivity Class

HDInsight streaming activity type.

All required parameters must be populated in order to send to Azure.

Inheritance

azure.synapse.artifacts.models._models_py3.ExecutionActivity

HDInsightStreamingActivity

Constructor

HDInsightStreamingActivity(*, name: str, mapper: object, reducer: object, input: object, output: object, file_paths: List[object], additional_properties: Optional[Dict[str, object]] = None, description: Optional[str] = None, depends_on: Optional[List[azure.synapse.artifacts.models._models_py3.ActivityDependency]] = None, user_properties: Optional[List[azure.synapse.artifacts.models._models_py3.UserProperty]] = None, linked_service_name: Optional[azure.synapse.artifacts.models._models_py3.LinkedServiceReference] = None, policy: Optional[azure.synapse.artifacts.models._models_py3.ActivityPolicy] = None, storage_linked_services: Optional[List[azure.synapse.artifacts.models._models_py3.LinkedServiceReference]] = None, arguments: Optional[List[object]] = None, get_debug_info: Optional[Union[str, azure.synapse.artifacts.models._artifacts_client_enums.HDInsightActivityDebugInfoOption]] = None, file_linked_service: Optional[azure.synapse.artifacts.models._models_py3.LinkedServiceReference] = None, combiner: Optional[object] = None, command_environment: Optional[List[object]] = None, defines: Optional[Dict[str, object]] = None, **kwargs)

Parameters

additional_properties

dict[str, object]

Required

Unmatched properties from the message are deserialized to this collection.

name

str

Required

Required. Activity name.

type

str

Required

Required. Type of activity.Constant filled by server.

description

str

Required

Activity description.

depends_on

list[ActivityDependency]

Required

Activity depends on condition.

user_properties

list[UserProperty]

Required

Activity user properties.

linked_service_name

LinkedServiceReference

Required

Linked service reference.

policy

ActivityPolicy

Required

Activity policy.

storage_linked_services

list[LinkedServiceReference]

Required

Storage linked service references.

arguments

list[object]

Required

User specified arguments to HDInsightActivity.

get_debug_info

str or HDInsightActivityDebugInfoOption

Required

Debug info option. Possible values include: "None", "Always", "Failure".

mapper

object

Required

Required. Mapper executable name. Type: string (or Expression with resultType string).

reducer

object

Required

Required. Reducer executable name. Type: string (or Expression with resultType string).

input

object

Required

Required. Input blob path. Type: string (or Expression with resultType string).

output

object

Required

Required. Output blob path. Type: string (or Expression with resultType string).

file_paths

list[object]

Required

Required. Paths to streaming job files. Can be directories.

file_linked_service

LinkedServiceReference

Required

Linked service reference where the files are located.

combiner

object

Required

Combiner executable name. Type: string (or Expression with resultType string).

command_environment

list[object]

Required

Command line environment values.

defines

dict[str, object]

Required

Allows user to specify defines for streaming job request.