diff --git a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/__init__.py b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/__init__.py
index 4b6dd4bed3de..a99d4b7ecd87 100644
--- a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/__init__.py
+++ b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/__init__.py
@@ -24,6 +24,7 @@
     from .compute_profile_py3 import ComputeProfile
     from .storage_account_py3 import StorageAccount
     from .storage_profile_py3 import StorageProfile
+    from .disk_encryption_properties_py3 import DiskEncryptionProperties
     from .cluster_create_properties_py3 import ClusterCreateProperties
     from .cluster_identity_user_assigned_identities_value_py3 import ClusterIdentityUserAssignedIdentitiesValue
     from .cluster_identity_py3 import ClusterIdentity
@@ -41,6 +42,7 @@
     from .runtime_script_action_detail_py3 import RuntimeScriptActionDetail
     from .cluster_list_runtime_script_action_detail_result_py3 import ClusterListRuntimeScriptActionDetailResult
     from .cluster_resize_parameters_py3 import ClusterResizeParameters
+    from .cluster_disk_encryption_parameters_py3 import ClusterDiskEncryptionParameters
     from .operation_resource_py3 import OperationResource
     from .resource_py3 import Resource
     from .tracked_resource_py3 import TrackedResource
@@ -74,6 +76,7 @@
     from .compute_profile import ComputeProfile
     from .storage_account import StorageAccount
     from .storage_profile import StorageProfile
+    from .disk_encryption_properties import DiskEncryptionProperties
     from .cluster_create_properties import ClusterCreateProperties
     from .cluster_identity_user_assigned_identities_value import ClusterIdentityUserAssignedIdentitiesValue
     from .cluster_identity import ClusterIdentity
@@ -91,6 +94,7 @@
     from .runtime_script_action_detail import RuntimeScriptActionDetail
     from .cluster_list_runtime_script_action_detail_result import ClusterListRuntimeScriptActionDetailResult
     from .cluster_resize_parameters import ClusterResizeParameters
+    from .cluster_disk_encryption_parameters import ClusterDiskEncryptionParameters
     from .operation_resource import OperationResource
     from .resource import Resource
     from .tracked_resource import TrackedResource
@@ -117,6 +121,7 @@
     DirectoryType,
     OSType,
     Tier,
+    JsonWebKeyEncryptionAlgorithm,
     ResourceIdentityType,
     HDInsightClusterProvisioningState,
     AsyncOperationState,
@@ -137,6 +142,7 @@
     'ComputeProfile',
     'StorageAccount',
     'StorageProfile',
+    'DiskEncryptionProperties',
     'ClusterCreateProperties',
     'ClusterIdentityUserAssignedIdentitiesValue',
     'ClusterIdentity',
@@ -154,6 +160,7 @@
     'RuntimeScriptActionDetail',
     'ClusterListRuntimeScriptActionDetailResult',
     'ClusterResizeParameters',
+    'ClusterDiskEncryptionParameters',
     'OperationResource',
     'Resource',
     'TrackedResource',
@@ -179,6 +186,7 @@
     'DirectoryType',
     'OSType',
     'Tier',
+    'JsonWebKeyEncryptionAlgorithm',
     'ResourceIdentityType',
     'HDInsightClusterProvisioningState',
     'AsyncOperationState',
diff --git a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_create_properties.py b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_create_properties.py
index 2a3d9d82b770..1c8ded609314 100644
--- a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_create_properties.py
+++ b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_create_properties.py
@@ -31,6 +31,9 @@ class ClusterCreateProperties(Model):
     :type compute_profile: ~azure.mgmt.hdinsight.models.ComputeProfile
     :param storage_profile: The storage profile.
     :type storage_profile: ~azure.mgmt.hdinsight.models.StorageProfile
+    :param disk_encryption_properties: The disk encryption properties.
+    :type disk_encryption_properties:
+     ~azure.mgmt.hdinsight.models.DiskEncryptionProperties
     """
 
     _attribute_map = {
@@ -41,6 +44,7 @@ class ClusterCreateProperties(Model):
         'security_profile': {'key': 'securityProfile', 'type': 'SecurityProfile'},
         'compute_profile': {'key': 'computeProfile', 'type': 'ComputeProfile'},
         'storage_profile': {'key': 'storageProfile', 'type': 'StorageProfile'},
+        'disk_encryption_properties': {'key': 'diskEncryptionProperties', 'type': 'DiskEncryptionProperties'},
     }
 
     def __init__(self, **kwargs):
@@ -52,3 +56,4 @@ def __init__(self, **kwargs):
         self.security_profile = kwargs.get('security_profile', None)
         self.compute_profile = kwargs.get('compute_profile', None)
         self.storage_profile = kwargs.get('storage_profile', None)
+        self.disk_encryption_properties = kwargs.get('disk_encryption_properties', None)
diff --git a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_create_properties_py3.py b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_create_properties_py3.py
index 116d6af0eb95..4a20afc19233 100644
--- a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_create_properties_py3.py
+++ b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_create_properties_py3.py
@@ -31,6 +31,9 @@ class ClusterCreateProperties(Model):
     :type compute_profile: ~azure.mgmt.hdinsight.models.ComputeProfile
     :param storage_profile: The storage profile.
     :type storage_profile: ~azure.mgmt.hdinsight.models.StorageProfile
+    :param disk_encryption_properties: The disk encryption properties.
+    :type disk_encryption_properties:
+     ~azure.mgmt.hdinsight.models.DiskEncryptionProperties
     """
 
     _attribute_map = {
@@ -41,9 +44,10 @@ class ClusterCreateProperties(Model):
         'security_profile': {'key': 'securityProfile', 'type': 'SecurityProfile'},
         'compute_profile': {'key': 'computeProfile', 'type': 'ComputeProfile'},
         'storage_profile': {'key': 'storageProfile', 'type': 'StorageProfile'},
+        'disk_encryption_properties': {'key': 'diskEncryptionProperties', 'type': 'DiskEncryptionProperties'},
     }
 
-    def __init__(self, *, cluster_version: str=None, os_type=None, tier=None, cluster_definition=None, security_profile=None, compute_profile=None, storage_profile=None, **kwargs) -> None:
+    def __init__(self, *, cluster_version: str=None, os_type=None, tier=None, cluster_definition=None, security_profile=None, compute_profile=None, storage_profile=None, disk_encryption_properties=None, **kwargs) -> None:
         super(ClusterCreateProperties, self).__init__(**kwargs)
         self.cluster_version = cluster_version
         self.os_type = os_type
@@ -52,3 +56,4 @@ def __init__(self, *, cluster_version: str=None, os_type=None, tier=None, cluste
         self.security_profile = security_profile
         self.compute_profile = compute_profile
         self.storage_profile = storage_profile
+        self.disk_encryption_properties = disk_encryption_properties
diff --git a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_disk_encryption_parameters.py b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_disk_encryption_parameters.py
new file mode 100644
index 000000000000..5be4b8a8baf4
--- /dev/null
+++ b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_disk_encryption_parameters.py
@@ -0,0 +1,38 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+#
+# Code generated by Microsoft (R) AutoRest Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is
+# regenerated.
+# --------------------------------------------------------------------------
+
+from msrest.serialization import Model
+
+
+class ClusterDiskEncryptionParameters(Model):
+    """The Disk Encryption Cluster request parameters.
+
+    :param vault_uri: Base key vault URI where the customers key is located
+     eg. https://myvault.vault.azure.net
+    :type vault_uri: str
+    :param key_name: Key name that is used for enabling disk encryption.
+    :type key_name: str
+    :param key_version: Specific key version that is used for enabling disk
+     encryption.
+    :type key_version: str
+    """
+
+    _attribute_map = {
+        'vault_uri': {'key': 'vaultUri', 'type': 'str'},
+        'key_name': {'key': 'keyName', 'type': 'str'},
+        'key_version': {'key': 'keyVersion', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(ClusterDiskEncryptionParameters, self).__init__(**kwargs)
+        self.vault_uri = kwargs.get('vault_uri', None)
+        self.key_name = kwargs.get('key_name', None)
+        self.key_version = kwargs.get('key_version', None)
diff --git a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_disk_encryption_parameters_py3.py b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_disk_encryption_parameters_py3.py
new file mode 100644
index 000000000000..daca29d0db38
--- /dev/null
+++ b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_disk_encryption_parameters_py3.py
@@ -0,0 +1,38 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+#
+# Code generated by Microsoft (R) AutoRest Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is
+# regenerated.
+# --------------------------------------------------------------------------
+
+from msrest.serialization import Model
+
+
+class ClusterDiskEncryptionParameters(Model):
+    """The Disk Encryption Cluster request parameters.
+
+    :param vault_uri: Base key vault URI where the customers key is located
+     eg. https://myvault.vault.azure.net
+    :type vault_uri: str
+    :param key_name: Key name that is used for enabling disk encryption.
+    :type key_name: str
+    :param key_version: Specific key version that is used for enabling disk
+     encryption.
+    :type key_version: str
+    """
+
+    _attribute_map = {
+        'vault_uri': {'key': 'vaultUri', 'type': 'str'},
+        'key_name': {'key': 'keyName', 'type': 'str'},
+        'key_version': {'key': 'keyVersion', 'type': 'str'},
+    }
+
+    def __init__(self, *, vault_uri: str=None, key_name: str=None, key_version: str=None, **kwargs) -> None:
+        super(ClusterDiskEncryptionParameters, self).__init__(**kwargs)
+        self.vault_uri = vault_uri
+        self.key_name = key_name
+        self.key_version = key_version
diff --git a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_get_properties.py b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_get_properties.py
index 988d03dbf1a7..09d5d4e34216 100644
--- a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_get_properties.py
+++ b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_get_properties.py
@@ -47,6 +47,9 @@ class ClusterGetProperties(Model):
     :param connectivity_endpoints: The list of connectivity endpoints.
     :type connectivity_endpoints:
      list[~azure.mgmt.hdinsight.models.ConnectivityEndpoint]
+    :param disk_encryption_properties: The disk encryption properties.
+    :type disk_encryption_properties:
+     ~azure.mgmt.hdinsight.models.DiskEncryptionProperties
     """
 
     _validation = {
@@ -66,6 +69,7 @@ class ClusterGetProperties(Model):
         'quota_info': {'key': 'quotaInfo', 'type': 'QuotaInfo'},
         'errors': {'key': 'errors', 'type': '[Errors]'},
         'connectivity_endpoints': {'key': 'connectivityEndpoints', 'type': '[ConnectivityEndpoint]'},
+        'disk_encryption_properties': {'key': 'diskEncryptionProperties', 'type': 'DiskEncryptionProperties'},
     }
 
     def __init__(self, **kwargs):
@@ -82,3 +86,4 @@ def __init__(self, **kwargs):
         self.quota_info = kwargs.get('quota_info', None)
         self.errors = kwargs.get('errors', None)
         self.connectivity_endpoints = kwargs.get('connectivity_endpoints', None)
+        self.disk_encryption_properties = kwargs.get('disk_encryption_properties', None)
diff --git a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_get_properties_py3.py b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_get_properties_py3.py
index 1c9024117dab..0709f53630c7 100644
--- a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_get_properties_py3.py
+++ b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/cluster_get_properties_py3.py
@@ -47,6 +47,9 @@ class ClusterGetProperties(Model):
     :param connectivity_endpoints: The list of connectivity endpoints.
     :type connectivity_endpoints:
      list[~azure.mgmt.hdinsight.models.ConnectivityEndpoint]
+    :param disk_encryption_properties: The disk encryption properties.
+    :type disk_encryption_properties:
+     ~azure.mgmt.hdinsight.models.DiskEncryptionProperties
     """
 
     _validation = {
@@ -66,9 +69,10 @@ class ClusterGetProperties(Model):
         'quota_info': {'key': 'quotaInfo', 'type': 'QuotaInfo'},
         'errors': {'key': 'errors', 'type': '[Errors]'},
         'connectivity_endpoints': {'key': 'connectivityEndpoints', 'type': '[ConnectivityEndpoint]'},
+        'disk_encryption_properties': {'key': 'diskEncryptionProperties', 'type': 'DiskEncryptionProperties'},
     }
 
-    def __init__(self, *, cluster_definition, cluster_version: str=None, os_type=None, tier=None, security_profile=None, compute_profile=None, provisioning_state=None, created_date: str=None, cluster_state: str=None, quota_info=None, errors=None, connectivity_endpoints=None, **kwargs) -> None:
+    def __init__(self, *, cluster_definition, cluster_version: str=None, os_type=None, tier=None, security_profile=None, compute_profile=None, provisioning_state=None, created_date: str=None, cluster_state: str=None, quota_info=None, errors=None, connectivity_endpoints=None, disk_encryption_properties=None, **kwargs) -> None:
         super(ClusterGetProperties, self).__init__(**kwargs)
         self.cluster_version = cluster_version
         self.os_type = os_type
@@ -82,3 +86,4 @@ def __init__(self, *, cluster_definition, cluster_version: str=None, os_type=Non
         self.quota_info = quota_info
         self.errors = errors
         self.connectivity_endpoints = connectivity_endpoints
+        self.disk_encryption_properties = disk_encryption_properties
diff --git a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/disk_encryption_properties.py b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/disk_encryption_properties.py
new file mode 100644
index 000000000000..1a18762417b0
--- /dev/null
+++ b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/disk_encryption_properties.py
@@ -0,0 +1,49 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+#
+# Code generated by Microsoft (R) AutoRest Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is
+# regenerated.
+# --------------------------------------------------------------------------
+
+from msrest.serialization import Model
+
+
+class DiskEncryptionProperties(Model):
+    """The disk encryption properties.
+
+    :param vault_uri: Base key vault URI where the customers key is located
+     eg. https://myvault.vault.azure.net
+    :type vault_uri: str
+    :param key_name: Key name that is used for enabling disk encryption.
+    :type key_name: str
+    :param key_version: Specific key version that is used for enabling disk
+     encryption.
+    :type key_version: str
+    :param encryption_algorithm: Algorithm identifier for encryption, default
+     RSA-OAEP. Possible values include: 'RSA-OAEP', 'RSA-OAEP-256', 'RSA1_5'
+    :type encryption_algorithm: str or
+     ~azure.mgmt.hdinsight.models.JsonWebKeyEncryptionAlgorithm
+    :param msi_resource_id: Resource ID of Managed Identity that is used to
+     access the key vault.
+    :type msi_resource_id: str
+    """
+
+    _attribute_map = {
+        'vault_uri': {'key': 'vaultUri', 'type': 'str'},
+        'key_name': {'key': 'keyName', 'type': 'str'},
+        'key_version': {'key': 'keyVersion', 'type': 'str'},
+        'encryption_algorithm': {'key': 'encryptionAlgorithm', 'type': 'str'},
+        'msi_resource_id': {'key': 'msiResourceId', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(DiskEncryptionProperties, self).__init__(**kwargs)
+        self.vault_uri = kwargs.get('vault_uri', None)
+        self.key_name = kwargs.get('key_name', None)
+        self.key_version = kwargs.get('key_version', None)
+        self.encryption_algorithm = kwargs.get('encryption_algorithm', None)
+        self.msi_resource_id = kwargs.get('msi_resource_id', None)
diff --git a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/disk_encryption_properties_py3.py b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/disk_encryption_properties_py3.py
new file mode 100644
index 000000000000..f95aa5550a6b
--- /dev/null
+++ b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/disk_encryption_properties_py3.py
@@ -0,0 +1,49 @@
+# coding=utf-8
+# --------------------------------------------------------------------------
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License. See License.txt in the project root for
+# license information.
+#
+# Code generated by Microsoft (R) AutoRest Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is
+# regenerated.
+# --------------------------------------------------------------------------
+
+from msrest.serialization import Model
+
+
+class DiskEncryptionProperties(Model):
+    """The disk encryption properties.
+
+    :param vault_uri: Base key vault URI where the customers key is located
+     eg. https://myvault.vault.azure.net
+    :type vault_uri: str
+    :param key_name: Key name that is used for enabling disk encryption.
+    :type key_name: str
+    :param key_version: Specific key version that is used for enabling disk
+     encryption.
+    :type key_version: str
+    :param encryption_algorithm: Algorithm identifier for encryption, default
+     RSA-OAEP. Possible values include: 'RSA-OAEP', 'RSA-OAEP-256', 'RSA1_5'
+    :type encryption_algorithm: str or
+     ~azure.mgmt.hdinsight.models.JsonWebKeyEncryptionAlgorithm
+    :param msi_resource_id: Resource ID of Managed Identity that is used to
+     access the key vault.
+    :type msi_resource_id: str
+    """
+
+    _attribute_map = {
+        'vault_uri': {'key': 'vaultUri', 'type': 'str'},
+        'key_name': {'key': 'keyName', 'type': 'str'},
+        'key_version': {'key': 'keyVersion', 'type': 'str'},
+        'encryption_algorithm': {'key': 'encryptionAlgorithm', 'type': 'str'},
+        'msi_resource_id': {'key': 'msiResourceId', 'type': 'str'},
+    }
+
+    def __init__(self, *, vault_uri: str=None, key_name: str=None, key_version: str=None, encryption_algorithm=None, msi_resource_id: str=None, **kwargs) -> None:
+        super(DiskEncryptionProperties, self).__init__(**kwargs)
+        self.vault_uri = vault_uri
+        self.key_name = key_name
+        self.key_version = key_version
+        self.encryption_algorithm = encryption_algorithm
+        self.msi_resource_id = msi_resource_id
diff --git a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/hd_insight_management_client_enums.py b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/hd_insight_management_client_enums.py
index d4988723eada..34fee1d526d2 100644
--- a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/hd_insight_management_client_enums.py
+++ b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/models/hd_insight_management_client_enums.py
@@ -29,6 +29,13 @@ class Tier(str, Enum):
     premium = "Premium"
 
 
+class JsonWebKeyEncryptionAlgorithm(str, Enum):
+
+    rsa_oaep = "RSA-OAEP"
+    rsa_oaep_256 = "RSA-OAEP-256"
+    rsa1_5 = "RSA1_5"
+
+
 class ResourceIdentityType(str, Enum):
 
     system_assigned = "SystemAssigned"
diff --git a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/operations/clusters_operations.py b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/operations/clusters_operations.py
index fddb64f9c5c2..7b8df20b343d 100644
--- a/azure-mgmt-hdinsight/azure/mgmt/hdinsight/operations/clusters_operations.py
+++ b/azure-mgmt-hdinsight/azure/mgmt/hdinsight/operations/clusters_operations.py
@@ -567,6 +567,92 @@ def internal_paging(next_link=None, raw=False):
     list.metadata = {'url': '/subscriptions/{subscriptionId}/providers/Microsoft.HDInsight/clusters'}
 
 
+    def _rotate_disk_encryption_key_initial(
+            self, resource_group_name, cluster_name, parameters, custom_headers=None, raw=False, **operation_config):
+        # Construct URL
+        url = self.rotate_disk_encryption_key.metadata['url']
+        path_format_arguments = {
+            'subscriptionId': self._serialize.url("self.config.subscription_id", self.config.subscription_id, 'str'),
+            'resourceGroupName': self._serialize.url("resource_group_name", resource_group_name, 'str'),
+            'clusterName': self._serialize.url("cluster_name", cluster_name, 'str')
+        }
+        url = self._client.format_url(url, **path_format_arguments)
+
+        # Construct parameters
+        query_parameters = {}
+        query_parameters['api-version'] = self._serialize.query("self.api_version", self.api_version, 'str')
+
+        # Construct headers
+        header_parameters = {}
+        header_parameters['Content-Type'] = 'application/json; charset=utf-8'
+        if self.config.generate_client_request_id:
+            header_parameters['x-ms-client-request-id'] = str(uuid.uuid1())
+        if custom_headers:
+            header_parameters.update(custom_headers)
+        if self.config.accept_language is not None:
+            header_parameters['accept-language'] = self._serialize.header("self.config.accept_language", self.config.accept_language, 'str')
+
+        # Construct body
+        body_content = self._serialize.body(parameters, 'ClusterDiskEncryptionParameters')
+
+        # Construct and send request
+        request = self._client.post(url, query_parameters, header_parameters, body_content)
+        response = self._client.send(request, stream=False, **operation_config)
+
+        if response.status_code not in [200, 202]:
+            raise models.ErrorResponseException(self._deserialize, response)
+
+        if raw:
+            client_raw_response = ClientRawResponse(None, response)
+            return client_raw_response
+
+    def rotate_disk_encryption_key(
+            self, resource_group_name, cluster_name, parameters, custom_headers=None, raw=False, polling=True, **operation_config):
+        """Rotate disk encryption key of the specified HDInsight cluster.
+
+        :param resource_group_name: The name of the resource group.
+        :type resource_group_name: str
+        :param cluster_name: The name of the cluster.
+        :type cluster_name: str
+        :param parameters: The parameters for the disk encryption operation.
+        :type parameters:
+         ~azure.mgmt.hdinsight.models.ClusterDiskEncryptionParameters
+        :param dict custom_headers: headers that will be added to the request
+        :param bool raw: The poller return type is ClientRawResponse, the
+         direct response alongside the deserialized response
+        :param polling: True for ARMPolling, False for no polling, or a
+         polling object for personal polling strategy
+        :return: An instance of LROPoller that returns None or
+         ClientRawResponse<None> if raw==True
+        :rtype: ~msrestazure.azure_operation.AzureOperationPoller[None] or
+         ~msrestazure.azure_operation.AzureOperationPoller[~msrest.pipeline.ClientRawResponse[None]]
+        :raises:
+         :class:`ErrorResponseException<azure.mgmt.hdinsight.models.ErrorResponseException>`
+        """
+        raw_result = self._rotate_disk_encryption_key_initial(
+            resource_group_name=resource_group_name,
+            cluster_name=cluster_name,
+            parameters=parameters,
+            custom_headers=custom_headers,
+            raw=True,
+            **operation_config
+        )
+
+        def get_long_running_output(response):
+            if raw:
+                client_raw_response = ClientRawResponse(None, response)
+                return client_raw_response
+
+        lro_delay = operation_config.get(
+            'long_running_operation_timeout',
+            self.config.long_running_operation_timeout)
+        if polling is True: polling_method = ARMPolling(lro_delay, **operation_config)
+        elif polling is False: polling_method = NoPolling()
+        else: polling_method = polling
+        return LROPoller(self._client, raw_result, get_long_running_output, polling_method)
+    rotate_disk_encryption_key.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.HDInsight/clusters/{clusterName}/rotatediskencryptionkey'}
+
+
     def _execute_script_actions_initial(
             self, resource_group_name, cluster_name, persist_on_success, script_actions=None, custom_headers=None, raw=False, **operation_config):
         parameters = models.ExecuteScriptActionParameters(script_actions=script_actions, persist_on_success=persist_on_success)