Skip to content

Commit

Permalink
[AutoPR datafactory/resource-manager] Add support for HDIinsight clus…
Browse files Browse the repository at this point in the history
…ter with Enterprise Serurity Package (#4002)

* Generated from 7b751f105846a18d948d19efc742af6f514303de

Add support for HDIinsight cluster with Enterprise Serurity Package

* Generated from 7b751f105846a18d948d19efc742af6f514303de

Add support for HDIinsight cluster with Enterprise Serurity Package
  • Loading branch information
AutorestCI authored Dec 6, 2018
1 parent df51f3b commit 6a480c4
Show file tree
Hide file tree
Showing 4 changed files with 30 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,11 @@ class HDInsightHiveActivity(ExecutionActivity):
~azure.mgmt.datafactory.models.LinkedServiceReference
:param defines: Allows user to specify defines for Hive job request.
:type defines: dict[str, object]
:param variables: User specified arguments under hivevar namespace.
:type variables: list[object]
:param query_timeout: Query timeout value (in minutes). Effective when
the HDInsight culster is with ESP (Enterprise Security Package)
:type query_timeout: int
"""

_validation = {
Expand All @@ -74,6 +79,8 @@ class HDInsightHiveActivity(ExecutionActivity):
'script_path': {'key': 'typeProperties.scriptPath', 'type': 'object'},
'script_linked_service': {'key': 'typeProperties.scriptLinkedService', 'type': 'LinkedServiceReference'},
'defines': {'key': 'typeProperties.defines', 'type': '{object}'},
'variables': {'key': 'typeProperties.variables', 'type': '[object]'},
'query_timeout': {'key': 'typeProperties.queryTimeout', 'type': 'int'},
}

def __init__(self, **kwargs):
Expand All @@ -84,4 +91,6 @@ def __init__(self, **kwargs):
self.script_path = kwargs.get('script_path', None)
self.script_linked_service = kwargs.get('script_linked_service', None)
self.defines = kwargs.get('defines', None)
self.variables = kwargs.get('variables', None)
self.query_timeout = kwargs.get('query_timeout', None)
self.type = 'HDInsightHive'
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,11 @@ class HDInsightHiveActivity(ExecutionActivity):
~azure.mgmt.datafactory.models.LinkedServiceReference
:param defines: Allows user to specify defines for Hive job request.
:type defines: dict[str, object]
:param variables: User specified arguments under hivevar namespace.
:type variables: list[object]
:param query_timeout: Query timeout value (in minutes). Effective when
the HDInsight culster is with ESP (Enterprise Security Package)
:type query_timeout: int
"""

_validation = {
Expand All @@ -74,14 +79,18 @@ class HDInsightHiveActivity(ExecutionActivity):
'script_path': {'key': 'typeProperties.scriptPath', 'type': 'object'},
'script_linked_service': {'key': 'typeProperties.scriptLinkedService', 'type': 'LinkedServiceReference'},
'defines': {'key': 'typeProperties.defines', 'type': '{object}'},
'variables': {'key': 'typeProperties.variables', 'type': '[object]'},
'query_timeout': {'key': 'typeProperties.queryTimeout', 'type': 'int'},
}

def __init__(self, *, name: str, additional_properties=None, description: str=None, depends_on=None, user_properties=None, linked_service_name=None, policy=None, storage_linked_services=None, arguments=None, get_debug_info=None, script_path=None, script_linked_service=None, defines=None, **kwargs) -> None:
def __init__(self, *, name: str, additional_properties=None, description: str=None, depends_on=None, user_properties=None, linked_service_name=None, policy=None, storage_linked_services=None, arguments=None, get_debug_info=None, script_path=None, script_linked_service=None, defines=None, variables=None, query_timeout: int=None, **kwargs) -> None:
super(HDInsightHiveActivity, self).__init__(additional_properties=additional_properties, name=name, description=description, depends_on=depends_on, user_properties=user_properties, linked_service_name=linked_service_name, policy=policy, **kwargs)
self.storage_linked_services = storage_linked_services
self.arguments = arguments
self.get_debug_info = get_debug_info
self.script_path = script_path
self.script_linked_service = script_linked_service
self.defines = defines
self.variables = variables
self.query_timeout = query_timeout
self.type = 'HDInsightHive'
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,9 @@ class HDInsightLinkedService(LinkedService):
authentication. Credentials are encrypted using the integration runtime
credential manager. Type: string (or Expression with resultType string).
:type encrypted_credential: object
:param is_esp_enabled: Specify if the HDInsight is created with ESP
(Enterprise Security Package). Type: Boolean.
:type is_esp_enabled: object
"""

_validation = {
Expand All @@ -72,6 +75,7 @@ class HDInsightLinkedService(LinkedService):
'linked_service_name': {'key': 'typeProperties.linkedServiceName', 'type': 'LinkedServiceReference'},
'hcatalog_linked_service_name': {'key': 'typeProperties.hcatalogLinkedServiceName', 'type': 'LinkedServiceReference'},
'encrypted_credential': {'key': 'typeProperties.encryptedCredential', 'type': 'object'},
'is_esp_enabled': {'key': 'typeProperties.isEspEnabled', 'type': 'object'},
}

def __init__(self, **kwargs):
Expand All @@ -82,4 +86,5 @@ def __init__(self, **kwargs):
self.linked_service_name = kwargs.get('linked_service_name', None)
self.hcatalog_linked_service_name = kwargs.get('hcatalog_linked_service_name', None)
self.encrypted_credential = kwargs.get('encrypted_credential', None)
self.is_esp_enabled = kwargs.get('is_esp_enabled', None)
self.type = 'HDInsight'
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,9 @@ class HDInsightLinkedService(LinkedService):
authentication. Credentials are encrypted using the integration runtime
credential manager. Type: string (or Expression with resultType string).
:type encrypted_credential: object
:param is_esp_enabled: Specify if the HDInsight is created with ESP
(Enterprise Security Package). Type: Boolean.
:type is_esp_enabled: object
"""

_validation = {
Expand All @@ -72,14 +75,16 @@ class HDInsightLinkedService(LinkedService):
'linked_service_name': {'key': 'typeProperties.linkedServiceName', 'type': 'LinkedServiceReference'},
'hcatalog_linked_service_name': {'key': 'typeProperties.hcatalogLinkedServiceName', 'type': 'LinkedServiceReference'},
'encrypted_credential': {'key': 'typeProperties.encryptedCredential', 'type': 'object'},
'is_esp_enabled': {'key': 'typeProperties.isEspEnabled', 'type': 'object'},
}

def __init__(self, *, cluster_uri, additional_properties=None, connect_via=None, description: str=None, parameters=None, annotations=None, user_name=None, password=None, linked_service_name=None, hcatalog_linked_service_name=None, encrypted_credential=None, **kwargs) -> None:
def __init__(self, *, cluster_uri, additional_properties=None, connect_via=None, description: str=None, parameters=None, annotations=None, user_name=None, password=None, linked_service_name=None, hcatalog_linked_service_name=None, encrypted_credential=None, is_esp_enabled=None, **kwargs) -> None:
super(HDInsightLinkedService, self).__init__(additional_properties=additional_properties, connect_via=connect_via, description=description, parameters=parameters, annotations=annotations, **kwargs)
self.cluster_uri = cluster_uri
self.user_name = user_name
self.password = password
self.linked_service_name = linked_service_name
self.hcatalog_linked_service_name = hcatalog_linked_service_name
self.encrypted_credential = encrypted_credential
self.is_esp_enabled = is_esp_enabled
self.type = 'HDInsight'

0 comments on commit 6a480c4

Please sign in to comment.