diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/kusto_management_client.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/kusto_management_client.py
index 1002ed1481dc..181270fbf6af 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/kusto_management_client.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/kusto_management_client.py
@@ -86,7 +86,7 @@ def __init__(
         super(KustoManagementClient, self).__init__(self.config.credentials, self.config)
 
         client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)}
-        self.api_version = '2019-01-21'
+        self.api_version = '2019-05-15'
         self._serialize = Serializer(client_models)
         self._deserialize = Deserializer(client_models)
 
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/__init__.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/__init__.py
index 609dec3cb394..6b7484bf190c 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/__init__.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/__init__.py
@@ -11,9 +11,13 @@
 
 try:
     from .trusted_external_tenant_py3 import TrustedExternalTenant
+    from .optimized_autoscale_py3 import OptimizedAutoscale
+    from .virtual_network_configuration_py3 import VirtualNetworkConfiguration
     from .azure_sku_py3 import AzureSku
     from .azure_capacity_py3 import AzureCapacity
     from .azure_resource_sku_py3 import AzureResourceSku
+    from .sku_location_info_item_py3 import SkuLocationInfoItem
+    from .sku_description_py3 import SkuDescription
     from .database_statistics_py3 import DatabaseStatistics
     from .cluster_py3 import Cluster
     from .cluster_update_py3 import ClusterUpdate
@@ -26,10 +30,12 @@
     from .database_principal_list_request_py3 import DatabasePrincipalListRequest
     from .data_connection_validation_py3 import DataConnectionValidation
     from .event_hub_data_connection_py3 import EventHubDataConnection
+    from .iot_hub_data_connection_py3 import IotHubDataConnection
     from .event_grid_data_connection_py3 import EventGridDataConnection
     from .data_connection_validation_list_result_py3 import DataConnectionValidationListResult
     from .cluster_check_name_request_py3 import ClusterCheckNameRequest
     from .database_check_name_request_py3 import DatabaseCheckNameRequest
+    from .data_connection_check_name_request_py3 import DataConnectionCheckNameRequest
     from .check_name_result_py3 import CheckNameResult
     from .operation_display_py3 import OperationDisplay
     from .operation_py3 import Operation
@@ -39,9 +45,13 @@
     from .proxy_resource_py3 import ProxyResource
 except (SyntaxError, ImportError):
     from .trusted_external_tenant import TrustedExternalTenant
+    from .optimized_autoscale import OptimizedAutoscale
+    from .virtual_network_configuration import VirtualNetworkConfiguration
     from .azure_sku import AzureSku
     from .azure_capacity import AzureCapacity
     from .azure_resource_sku import AzureResourceSku
+    from .sku_location_info_item import SkuLocationInfoItem
+    from .sku_description import SkuDescription
     from .database_statistics import DatabaseStatistics
     from .cluster import Cluster
     from .cluster_update import ClusterUpdate
@@ -54,10 +64,12 @@
     from .database_principal_list_request import DatabasePrincipalListRequest
     from .data_connection_validation import DataConnectionValidation
     from .event_hub_data_connection import EventHubDataConnection
+    from .iot_hub_data_connection import IotHubDataConnection
     from .event_grid_data_connection import EventGridDataConnection
     from .data_connection_validation_list_result import DataConnectionValidationListResult
     from .cluster_check_name_request import ClusterCheckNameRequest
     from .database_check_name_request import DatabaseCheckNameRequest
+    from .data_connection_check_name_request import DataConnectionCheckNameRequest
     from .check_name_result import CheckNameResult
     from .operation_display import OperationDisplay
     from .operation import Operation
@@ -66,7 +78,7 @@
     from .resource import Resource
     from .proxy_resource import ProxyResource
 from .cluster_paged import ClusterPaged
-from .azure_sku_paged import AzureSkuPaged
+from .sku_description_paged import SkuDescriptionPaged
 from .azure_resource_sku_paged import AzureResourceSkuPaged
 from .database_paged import DatabasePaged
 from .database_principal_paged import DatabasePrincipalPaged
@@ -76,17 +88,23 @@
     State,
     ProvisioningState,
     AzureSkuName,
+    AzureSkuTier,
     AzureScaleType,
     DataFormat,
     DatabasePrincipalRole,
     DatabasePrincipalType,
+    Reason,
 )
 
 __all__ = [
     'TrustedExternalTenant',
+    'OptimizedAutoscale',
+    'VirtualNetworkConfiguration',
     'AzureSku',
     'AzureCapacity',
     'AzureResourceSku',
+    'SkuLocationInfoItem',
+    'SkuDescription',
     'DatabaseStatistics',
     'Cluster',
     'ClusterUpdate',
@@ -99,10 +117,12 @@
     'DatabasePrincipalListRequest',
     'DataConnectionValidation',
     'EventHubDataConnection',
+    'IotHubDataConnection',
     'EventGridDataConnection',
     'DataConnectionValidationListResult',
     'ClusterCheckNameRequest',
     'DatabaseCheckNameRequest',
+    'DataConnectionCheckNameRequest',
     'CheckNameResult',
     'OperationDisplay',
     'Operation',
@@ -111,7 +131,7 @@
     'Resource',
     'ProxyResource',
     'ClusterPaged',
-    'AzureSkuPaged',
+    'SkuDescriptionPaged',
     'AzureResourceSkuPaged',
     'DatabasePaged',
     'DatabasePrincipalPaged',
@@ -120,8 +140,10 @@
     'State',
     'ProvisioningState',
     'AzureSkuName',
+    'AzureSkuTier',
     'AzureScaleType',
     'DataFormat',
     'DatabasePrincipalRole',
     'DatabasePrincipalType',
+    'Reason',
 ]
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_resource_sku.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_resource_sku.py
index d56bc39e1551..5a401ae43ab3 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_resource_sku.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_resource_sku.py
@@ -19,7 +19,7 @@ class AzureResourceSku(Model):
     :type resource_type: str
     :param sku: The SKU details.
     :type sku: ~azure.mgmt.kusto.models.AzureSku
-    :param capacity: The SKU capacity.
+    :param capacity: The number of instances of the cluster.
     :type capacity: ~azure.mgmt.kusto.models.AzureCapacity
     """
 
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_resource_sku_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_resource_sku_py3.py
index 2eb83500c01f..eba21f974697 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_resource_sku_py3.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_resource_sku_py3.py
@@ -19,7 +19,7 @@ class AzureResourceSku(Model):
     :type resource_type: str
     :param sku: The SKU details.
     :type sku: ~azure.mgmt.kusto.models.AzureSku
-    :param capacity: The SKU capacity.
+    :param capacity: The number of instances of the cluster.
     :type capacity: ~azure.mgmt.kusto.models.AzureCapacity
     """
 
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku.py
index 49faa9f82911..3ff1ef6eeba5 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku.py
@@ -15,23 +15,24 @@
 class AzureSku(Model):
     """Azure SKU definition.
 
-    Variables are only populated by the server, and will be ignored when
-    sending a request.
-
     All required parameters must be populated in order to send to Azure.
 
-    :param name: Required. SKU name. Possible values include: 'D13_v2',
-     'D14_v2', 'L8', 'L16', 'D11_v2', 'D12_v2', 'L4'
+    :param name: Required. SKU name. Possible values include:
+     'Standard_DS13_v2+1TB_PS', 'Standard_DS13_v2+2TB_PS',
+     'Standard_DS14_v2+3TB_PS', 'Standard_DS14_v2+4TB_PS', 'Standard_D13_v2',
+     'Standard_D14_v2', 'Standard_L8s', 'Standard_L16s', 'Standard_D11_v2',
+     'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2'
     :type name: str or ~azure.mgmt.kusto.models.AzureSkuName
-    :param capacity: SKU capacity.
+    :param capacity: The number of instances of the cluster.
     :type capacity: int
-    :ivar tier: Required. SKU tier. Default value: "Standard" .
-    :vartype tier: str
+    :param tier: Required. SKU tier. Possible values include: 'Basic',
+     'Standard'
+    :type tier: str or ~azure.mgmt.kusto.models.AzureSkuTier
     """
 
     _validation = {
         'name': {'required': True},
-        'tier': {'required': True, 'constant': True},
+        'tier': {'required': True},
     }
 
     _attribute_map = {
@@ -40,9 +41,8 @@ class AzureSku(Model):
         'tier': {'key': 'tier', 'type': 'str'},
     }
 
-    tier = "Standard"
-
     def __init__(self, **kwargs):
         super(AzureSku, self).__init__(**kwargs)
         self.name = kwargs.get('name', None)
         self.capacity = kwargs.get('capacity', None)
+        self.tier = kwargs.get('tier', None)
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku_py3.py
index a5fe5ac0bdd0..142f6ce6e175 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku_py3.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku_py3.py
@@ -15,23 +15,24 @@
 class AzureSku(Model):
     """Azure SKU definition.
 
-    Variables are only populated by the server, and will be ignored when
-    sending a request.
-
     All required parameters must be populated in order to send to Azure.
 
-    :param name: Required. SKU name. Possible values include: 'D13_v2',
-     'D14_v2', 'L8', 'L16', 'D11_v2', 'D12_v2', 'L4'
+    :param name: Required. SKU name. Possible values include:
+     'Standard_DS13_v2+1TB_PS', 'Standard_DS13_v2+2TB_PS',
+     'Standard_DS14_v2+3TB_PS', 'Standard_DS14_v2+4TB_PS', 'Standard_D13_v2',
+     'Standard_D14_v2', 'Standard_L8s', 'Standard_L16s', 'Standard_D11_v2',
+     'Standard_D12_v2', 'Standard_L4s', 'Dev(No SLA)_Standard_D11_v2'
     :type name: str or ~azure.mgmt.kusto.models.AzureSkuName
-    :param capacity: SKU capacity.
+    :param capacity: The number of instances of the cluster.
     :type capacity: int
-    :ivar tier: Required. SKU tier. Default value: "Standard" .
-    :vartype tier: str
+    :param tier: Required. SKU tier. Possible values include: 'Basic',
+     'Standard'
+    :type tier: str or ~azure.mgmt.kusto.models.AzureSkuTier
     """
 
     _validation = {
         'name': {'required': True},
-        'tier': {'required': True, 'constant': True},
+        'tier': {'required': True},
     }
 
     _attribute_map = {
@@ -40,9 +41,8 @@ class AzureSku(Model):
         'tier': {'key': 'tier', 'type': 'str'},
     }
 
-    tier = "Standard"
-
-    def __init__(self, *, name, capacity: int=None, **kwargs) -> None:
+    def __init__(self, *, name, tier, capacity: int=None, **kwargs) -> None:
         super(AzureSku, self).__init__(**kwargs)
         self.name = name
         self.capacity = capacity
+        self.tier = tier
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/check_name_result.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/check_name_result.py
index 035e47b11bc7..28c9a31746ae 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/check_name_result.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/check_name_result.py
@@ -23,12 +23,16 @@ class CheckNameResult(Model):
     :param message: Message indicating an unavailable name due to a conflict,
      or a description of the naming rules that are violated.
     :type message: str
+    :param reason: Message providing the reason why the given name is invalid.
+     Possible values include: 'Invalid', 'AlreadyExists'
+    :type reason: str or ~azure.mgmt.kusto.models.Reason
     """
 
     _attribute_map = {
         'name_available': {'key': 'nameAvailable', 'type': 'bool'},
         'name': {'key': 'name', 'type': 'str'},
         'message': {'key': 'message', 'type': 'str'},
+        'reason': {'key': 'reason', 'type': 'str'},
     }
 
     def __init__(self, **kwargs):
@@ -36,3 +40,4 @@ def __init__(self, **kwargs):
         self.name_available = kwargs.get('name_available', None)
         self.name = kwargs.get('name', None)
         self.message = kwargs.get('message', None)
+        self.reason = kwargs.get('reason', None)
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/check_name_result_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/check_name_result_py3.py
index 56f03c29ee41..91edde6bcb30 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/check_name_result_py3.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/check_name_result_py3.py
@@ -23,16 +23,21 @@ class CheckNameResult(Model):
     :param message: Message indicating an unavailable name due to a conflict,
      or a description of the naming rules that are violated.
     :type message: str
+    :param reason: Message providing the reason why the given name is invalid.
+     Possible values include: 'Invalid', 'AlreadyExists'
+    :type reason: str or ~azure.mgmt.kusto.models.Reason
     """
 
     _attribute_map = {
         'name_available': {'key': 'nameAvailable', 'type': 'bool'},
         'name': {'key': 'name', 'type': 'str'},
         'message': {'key': 'message', 'type': 'str'},
+        'reason': {'key': 'reason', 'type': 'str'},
     }
 
-    def __init__(self, *, name_available: bool=None, name: str=None, message: str=None, **kwargs) -> None:
+    def __init__(self, *, name_available: bool=None, name: str=None, message: str=None, reason=None, **kwargs) -> None:
         super(CheckNameResult, self).__init__(**kwargs)
         self.name_available = name_available
         self.name = name
         self.message = message
+        self.reason = reason
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster.py
index 0a18502acad6..931d305300b0 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster.py
@@ -34,12 +34,15 @@ class Cluster(TrackedResource):
     :type location: str
     :param sku: Required. The SKU of the cluster.
     :type sku: ~azure.mgmt.kusto.models.AzureSku
+    :param zones: The availability zones of the cluster.
+    :type zones: list[str]
     :ivar state: The state of the resource. Possible values include:
      'Creating', 'Unavailable', 'Running', 'Deleting', 'Deleted', 'Stopping',
      'Stopped', 'Starting', 'Updating'
     :vartype state: str or ~azure.mgmt.kusto.models.State
     :ivar provisioning_state: The provisioned state of the resource. Possible
-     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed'
+     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
+     'Moving'
     :vartype provisioning_state: str or
      ~azure.mgmt.kusto.models.ProvisioningState
     :ivar uri: The cluster URI.
@@ -49,6 +52,17 @@ class Cluster(TrackedResource):
     :param trusted_external_tenants: The cluster's external tenants.
     :type trusted_external_tenants:
      list[~azure.mgmt.kusto.models.TrustedExternalTenant]
+    :param optimized_autoscale: Optimized auto scale definition.
+    :type optimized_autoscale: ~azure.mgmt.kusto.models.OptimizedAutoscale
+    :param enable_disk_encryption: A boolean value that indicates if the
+     cluster's disks are encrypted.
+    :type enable_disk_encryption: bool
+    :param enable_streaming_ingest: A boolean value that indicates if the
+     streaming ingest is enabled. Default value: False .
+    :type enable_streaming_ingest: bool
+    :param virtual_network_configuration: Virtual network definition.
+    :type virtual_network_configuration:
+     ~azure.mgmt.kusto.models.VirtualNetworkConfiguration
     """
 
     _validation = {
@@ -70,18 +84,28 @@ class Cluster(TrackedResource):
         'tags': {'key': 'tags', 'type': '{str}'},
         'location': {'key': 'location', 'type': 'str'},
         'sku': {'key': 'sku', 'type': 'AzureSku'},
+        'zones': {'key': 'zones', 'type': '[str]'},
         'state': {'key': 'properties.state', 'type': 'str'},
         'provisioning_state': {'key': 'properties.provisioningState', 'type': 'str'},
         'uri': {'key': 'properties.uri', 'type': 'str'},
         'data_ingestion_uri': {'key': 'properties.dataIngestionUri', 'type': 'str'},
         'trusted_external_tenants': {'key': 'properties.trustedExternalTenants', 'type': '[TrustedExternalTenant]'},
+        'optimized_autoscale': {'key': 'properties.optimizedAutoscale', 'type': 'OptimizedAutoscale'},
+        'enable_disk_encryption': {'key': 'properties.enableDiskEncryption', 'type': 'bool'},
+        'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'},
+        'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'},
     }
 
     def __init__(self, **kwargs):
         super(Cluster, self).__init__(**kwargs)
         self.sku = kwargs.get('sku', None)
+        self.zones = kwargs.get('zones', None)
         self.state = None
         self.provisioning_state = None
         self.uri = None
         self.data_ingestion_uri = None
         self.trusted_external_tenants = kwargs.get('trusted_external_tenants', None)
+        self.optimized_autoscale = kwargs.get('optimized_autoscale', None)
+        self.enable_disk_encryption = kwargs.get('enable_disk_encryption', None)
+        self.enable_streaming_ingest = kwargs.get('enable_streaming_ingest', False)
+        self.virtual_network_configuration = kwargs.get('virtual_network_configuration', None)
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_py3.py
index 317d5c5f5205..049ee5eff5a1 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_py3.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_py3.py
@@ -34,12 +34,15 @@ class Cluster(TrackedResource):
     :type location: str
     :param sku: Required. The SKU of the cluster.
     :type sku: ~azure.mgmt.kusto.models.AzureSku
+    :param zones: The availability zones of the cluster.
+    :type zones: list[str]
     :ivar state: The state of the resource. Possible values include:
      'Creating', 'Unavailable', 'Running', 'Deleting', 'Deleted', 'Stopping',
      'Stopped', 'Starting', 'Updating'
     :vartype state: str or ~azure.mgmt.kusto.models.State
     :ivar provisioning_state: The provisioned state of the resource. Possible
-     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed'
+     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
+     'Moving'
     :vartype provisioning_state: str or
      ~azure.mgmt.kusto.models.ProvisioningState
     :ivar uri: The cluster URI.
@@ -49,6 +52,17 @@ class Cluster(TrackedResource):
     :param trusted_external_tenants: The cluster's external tenants.
     :type trusted_external_tenants:
      list[~azure.mgmt.kusto.models.TrustedExternalTenant]
+    :param optimized_autoscale: Optimized auto scale definition.
+    :type optimized_autoscale: ~azure.mgmt.kusto.models.OptimizedAutoscale
+    :param enable_disk_encryption: A boolean value that indicates if the
+     cluster's disks are encrypted.
+    :type enable_disk_encryption: bool
+    :param enable_streaming_ingest: A boolean value that indicates if the
+     streaming ingest is enabled. Default value: False .
+    :type enable_streaming_ingest: bool
+    :param virtual_network_configuration: Virtual network definition.
+    :type virtual_network_configuration:
+     ~azure.mgmt.kusto.models.VirtualNetworkConfiguration
     """
 
     _validation = {
@@ -70,18 +84,28 @@ class Cluster(TrackedResource):
         'tags': {'key': 'tags', 'type': '{str}'},
         'location': {'key': 'location', 'type': 'str'},
         'sku': {'key': 'sku', 'type': 'AzureSku'},
+        'zones': {'key': 'zones', 'type': '[str]'},
         'state': {'key': 'properties.state', 'type': 'str'},
         'provisioning_state': {'key': 'properties.provisioningState', 'type': 'str'},
         'uri': {'key': 'properties.uri', 'type': 'str'},
         'data_ingestion_uri': {'key': 'properties.dataIngestionUri', 'type': 'str'},
         'trusted_external_tenants': {'key': 'properties.trustedExternalTenants', 'type': '[TrustedExternalTenant]'},
+        'optimized_autoscale': {'key': 'properties.optimizedAutoscale', 'type': 'OptimizedAutoscale'},
+        'enable_disk_encryption': {'key': 'properties.enableDiskEncryption', 'type': 'bool'},
+        'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'},
+        'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'},
     }
 
-    def __init__(self, *, location: str, sku, tags=None, trusted_external_tenants=None, **kwargs) -> None:
+    def __init__(self, *, location: str, sku, tags=None, zones=None, trusted_external_tenants=None, optimized_autoscale=None, enable_disk_encryption: bool=None, enable_streaming_ingest: bool=False, virtual_network_configuration=None, **kwargs) -> None:
         super(Cluster, self).__init__(tags=tags, location=location, **kwargs)
         self.sku = sku
+        self.zones = zones
         self.state = None
         self.provisioning_state = None
         self.uri = None
         self.data_ingestion_uri = None
         self.trusted_external_tenants = trusted_external_tenants
+        self.optimized_autoscale = optimized_autoscale
+        self.enable_disk_encryption = enable_disk_encryption
+        self.enable_streaming_ingest = enable_streaming_ingest
+        self.virtual_network_configuration = virtual_network_configuration
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_update.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_update.py
index bd5296d80137..7da093733c85 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_update.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_update.py
@@ -37,7 +37,8 @@ class ClusterUpdate(Resource):
      'Stopped', 'Starting', 'Updating'
     :vartype state: str or ~azure.mgmt.kusto.models.State
     :ivar provisioning_state: The provisioned state of the resource. Possible
-     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed'
+     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
+     'Moving'
     :vartype provisioning_state: str or
      ~azure.mgmt.kusto.models.ProvisioningState
     :ivar uri: The cluster URI.
@@ -47,6 +48,17 @@ class ClusterUpdate(Resource):
     :param trusted_external_tenants: The cluster's external tenants.
     :type trusted_external_tenants:
      list[~azure.mgmt.kusto.models.TrustedExternalTenant]
+    :param optimized_autoscale: Optimized auto scale definition.
+    :type optimized_autoscale: ~azure.mgmt.kusto.models.OptimizedAutoscale
+    :param enable_disk_encryption: A boolean value that indicates if the
+     cluster's disks are encrypted.
+    :type enable_disk_encryption: bool
+    :param enable_streaming_ingest: A boolean value that indicates if the
+     streaming ingest is enabled. Default value: False .
+    :type enable_streaming_ingest: bool
+    :param virtual_network_configuration: Virtual network definition.
+    :type virtual_network_configuration:
+     ~azure.mgmt.kusto.models.VirtualNetworkConfiguration
     """
 
     _validation = {
@@ -71,6 +83,10 @@ class ClusterUpdate(Resource):
         'uri': {'key': 'properties.uri', 'type': 'str'},
         'data_ingestion_uri': {'key': 'properties.dataIngestionUri', 'type': 'str'},
         'trusted_external_tenants': {'key': 'properties.trustedExternalTenants', 'type': '[TrustedExternalTenant]'},
+        'optimized_autoscale': {'key': 'properties.optimizedAutoscale', 'type': 'OptimizedAutoscale'},
+        'enable_disk_encryption': {'key': 'properties.enableDiskEncryption', 'type': 'bool'},
+        'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'},
+        'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'},
     }
 
     def __init__(self, **kwargs):
@@ -83,3 +99,7 @@ def __init__(self, **kwargs):
         self.uri = None
         self.data_ingestion_uri = None
         self.trusted_external_tenants = kwargs.get('trusted_external_tenants', None)
+        self.optimized_autoscale = kwargs.get('optimized_autoscale', None)
+        self.enable_disk_encryption = kwargs.get('enable_disk_encryption', None)
+        self.enable_streaming_ingest = kwargs.get('enable_streaming_ingest', False)
+        self.virtual_network_configuration = kwargs.get('virtual_network_configuration', None)
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_update_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_update_py3.py
index ffc45cdb3fe0..dfe89cb49b14 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_update_py3.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/cluster_update_py3.py
@@ -37,7 +37,8 @@ class ClusterUpdate(Resource):
      'Stopped', 'Starting', 'Updating'
     :vartype state: str or ~azure.mgmt.kusto.models.State
     :ivar provisioning_state: The provisioned state of the resource. Possible
-     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed'
+     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
+     'Moving'
     :vartype provisioning_state: str or
      ~azure.mgmt.kusto.models.ProvisioningState
     :ivar uri: The cluster URI.
@@ -47,6 +48,17 @@ class ClusterUpdate(Resource):
     :param trusted_external_tenants: The cluster's external tenants.
     :type trusted_external_tenants:
      list[~azure.mgmt.kusto.models.TrustedExternalTenant]
+    :param optimized_autoscale: Optimized auto scale definition.
+    :type optimized_autoscale: ~azure.mgmt.kusto.models.OptimizedAutoscale
+    :param enable_disk_encryption: A boolean value that indicates if the
+     cluster's disks are encrypted.
+    :type enable_disk_encryption: bool
+    :param enable_streaming_ingest: A boolean value that indicates if the
+     streaming ingest is enabled. Default value: False .
+    :type enable_streaming_ingest: bool
+    :param virtual_network_configuration: Virtual network definition.
+    :type virtual_network_configuration:
+     ~azure.mgmt.kusto.models.VirtualNetworkConfiguration
     """
 
     _validation = {
@@ -71,9 +83,13 @@ class ClusterUpdate(Resource):
         'uri': {'key': 'properties.uri', 'type': 'str'},
         'data_ingestion_uri': {'key': 'properties.dataIngestionUri', 'type': 'str'},
         'trusted_external_tenants': {'key': 'properties.trustedExternalTenants', 'type': '[TrustedExternalTenant]'},
+        'optimized_autoscale': {'key': 'properties.optimizedAutoscale', 'type': 'OptimizedAutoscale'},
+        'enable_disk_encryption': {'key': 'properties.enableDiskEncryption', 'type': 'bool'},
+        'enable_streaming_ingest': {'key': 'properties.enableStreamingIngest', 'type': 'bool'},
+        'virtual_network_configuration': {'key': 'properties.virtualNetworkConfiguration', 'type': 'VirtualNetworkConfiguration'},
     }
 
-    def __init__(self, *, tags=None, location: str=None, sku=None, trusted_external_tenants=None, **kwargs) -> None:
+    def __init__(self, *, tags=None, location: str=None, sku=None, trusted_external_tenants=None, optimized_autoscale=None, enable_disk_encryption: bool=None, enable_streaming_ingest: bool=False, virtual_network_configuration=None, **kwargs) -> None:
         super(ClusterUpdate, self).__init__(**kwargs)
         self.tags = tags
         self.location = location
@@ -83,3 +99,7 @@ def __init__(self, *, tags=None, location: str=None, sku=None, trusted_external_
         self.uri = None
         self.data_ingestion_uri = None
         self.trusted_external_tenants = trusted_external_tenants
+        self.optimized_autoscale = optimized_autoscale
+        self.enable_disk_encryption = enable_disk_encryption
+        self.enable_streaming_ingest = enable_streaming_ingest
+        self.virtual_network_configuration = virtual_network_configuration
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection.py
index 896b2d7a3ca1..96c1c0f2d5e7 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection.py
@@ -16,7 +16,8 @@ class DataConnection(ProxyResource):
     """Class representing an data connection.
 
     You probably want to use the sub-classes and not this class directly. Known
-    sub-classes are: EventHubDataConnection, EventGridDataConnection
+    sub-classes are: EventHubDataConnection, IotHubDataConnection,
+    EventGridDataConnection
 
     Variables are only populated by the server, and will be ignored when
     sending a request.
@@ -53,7 +54,7 @@ class DataConnection(ProxyResource):
     }
 
     _subtype_map = {
-        'kind': {'EventHub': 'EventHubDataConnection', 'EventGrid': 'EventGridDataConnection'}
+        'kind': {'EventHub': 'EventHubDataConnection', 'IotHub': 'IotHubDataConnection', 'EventGrid': 'EventGridDataConnection'}
     }
 
     def __init__(self, **kwargs):
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection_check_name_request.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection_check_name_request.py
new file mode 100644
index 000000000000..2c31aa72d291
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection_check_name_request.py
@@ -0,0 +1,46 @@
+# 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 DataConnectionCheckNameRequest(Model):
+    """The result returned from a data connections check name availability
+    request.
+
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param name: Required. Data Connection name.
+    :type name: str
+    :ivar type: Required. The type of resource,
+     Microsoft.Kusto/clusters/databases/dataConnections. Default value:
+     "Microsoft.Kusto/clusters/databases/dataConnections" .
+    :vartype type: str
+    """
+
+    _validation = {
+        'name': {'required': True},
+        'type': {'required': True, 'constant': True},
+    }
+
+    _attribute_map = {
+        'name': {'key': 'name', 'type': 'str'},
+        'type': {'key': 'type', 'type': 'str'},
+    }
+
+    type = "Microsoft.Kusto/clusters/databases/dataConnections"
+
+    def __init__(self, **kwargs):
+        super(DataConnectionCheckNameRequest, self).__init__(**kwargs)
+        self.name = kwargs.get('name', None)
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection_check_name_request_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection_check_name_request_py3.py
new file mode 100644
index 000000000000..7398e92e5ad5
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection_check_name_request_py3.py
@@ -0,0 +1,46 @@
+# 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 DataConnectionCheckNameRequest(Model):
+    """The result returned from a data connections check name availability
+    request.
+
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param name: Required. Data Connection name.
+    :type name: str
+    :ivar type: Required. The type of resource,
+     Microsoft.Kusto/clusters/databases/dataConnections. Default value:
+     "Microsoft.Kusto/clusters/databases/dataConnections" .
+    :vartype type: str
+    """
+
+    _validation = {
+        'name': {'required': True},
+        'type': {'required': True, 'constant': True},
+    }
+
+    _attribute_map = {
+        'name': {'key': 'name', 'type': 'str'},
+        'type': {'key': 'type', 'type': 'str'},
+    }
+
+    type = "Microsoft.Kusto/clusters/databases/dataConnections"
+
+    def __init__(self, *, name: str, **kwargs) -> None:
+        super(DataConnectionCheckNameRequest, self).__init__(**kwargs)
+        self.name = name
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection_py3.py
index 3783107e8407..cdda8c82385f 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection_py3.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/data_connection_py3.py
@@ -16,7 +16,8 @@ class DataConnection(ProxyResource):
     """Class representing an data connection.
 
     You probably want to use the sub-classes and not this class directly. Known
-    sub-classes are: EventHubDataConnection, EventGridDataConnection
+    sub-classes are: EventHubDataConnection, IotHubDataConnection,
+    EventGridDataConnection
 
     Variables are only populated by the server, and will be ignored when
     sending a request.
@@ -53,7 +54,7 @@ class DataConnection(ProxyResource):
     }
 
     _subtype_map = {
-        'kind': {'EventHub': 'EventHubDataConnection', 'EventGrid': 'EventGridDataConnection'}
+        'kind': {'EventHub': 'EventHubDataConnection', 'IotHub': 'IotHubDataConnection', 'EventGrid': 'EventGridDataConnection'}
     }
 
     def __init__(self, *, location: str=None, **kwargs) -> None:
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database.py
index 3b441b079983..13de5f917464 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database.py
@@ -29,14 +29,15 @@ class Database(ProxyResource):
     :param location: Resource location.
     :type location: str
     :ivar provisioning_state: The provisioned state of the resource. Possible
-     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed'
+     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
+     'Moving'
     :vartype provisioning_state: str or
      ~azure.mgmt.kusto.models.ProvisioningState
     :param soft_delete_period: The time the data should be kept before it
      stops being accessible to queries in TimeSpan.
     :type soft_delete_period: timedelta
-    :param hot_cache_period: The time the data that should be kept in cache
-     for fast queries in TimeSpan.
+    :param hot_cache_period: The time the data should be kept in cache for
+     fast queries in TimeSpan.
     :type hot_cache_period: timedelta
     :param statistics: The statistics of the database.
     :type statistics: ~azure.mgmt.kusto.models.DatabaseStatistics
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_principal.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_principal.py
index 25006c75f921..3c324071d3b8 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_principal.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_principal.py
@@ -15,6 +15,9 @@
 class DatabasePrincipal(Model):
     """A class representing database principal entity.
 
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
     All required parameters must be populated in order to send to Azure.
 
     :param role: Required. Database principal role. Possible values include:
@@ -32,12 +35,15 @@ class DatabasePrincipal(Model):
     :param app_id: Application id - relevant only for application principal
      type.
     :type app_id: str
+    :ivar tenant_name: The tenant name of the principal
+    :vartype tenant_name: str
     """
 
     _validation = {
         'role': {'required': True},
         'name': {'required': True},
         'type': {'required': True},
+        'tenant_name': {'readonly': True},
     }
 
     _attribute_map = {
@@ -47,6 +53,7 @@ class DatabasePrincipal(Model):
         'fqn': {'key': 'fqn', 'type': 'str'},
         'email': {'key': 'email', 'type': 'str'},
         'app_id': {'key': 'appId', 'type': 'str'},
+        'tenant_name': {'key': 'tenantName', 'type': 'str'},
     }
 
     def __init__(self, **kwargs):
@@ -57,3 +64,4 @@ def __init__(self, **kwargs):
         self.fqn = kwargs.get('fqn', None)
         self.email = kwargs.get('email', None)
         self.app_id = kwargs.get('app_id', None)
+        self.tenant_name = None
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_principal_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_principal_py3.py
index 32ae3e74b832..17f8f4f0571a 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_principal_py3.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_principal_py3.py
@@ -15,6 +15,9 @@
 class DatabasePrincipal(Model):
     """A class representing database principal entity.
 
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
     All required parameters must be populated in order to send to Azure.
 
     :param role: Required. Database principal role. Possible values include:
@@ -32,12 +35,15 @@ class DatabasePrincipal(Model):
     :param app_id: Application id - relevant only for application principal
      type.
     :type app_id: str
+    :ivar tenant_name: The tenant name of the principal
+    :vartype tenant_name: str
     """
 
     _validation = {
         'role': {'required': True},
         'name': {'required': True},
         'type': {'required': True},
+        'tenant_name': {'readonly': True},
     }
 
     _attribute_map = {
@@ -47,6 +53,7 @@ class DatabasePrincipal(Model):
         'fqn': {'key': 'fqn', 'type': 'str'},
         'email': {'key': 'email', 'type': 'str'},
         'app_id': {'key': 'appId', 'type': 'str'},
+        'tenant_name': {'key': 'tenantName', 'type': 'str'},
     }
 
     def __init__(self, *, role, name: str, type, fqn: str=None, email: str=None, app_id: str=None, **kwargs) -> None:
@@ -57,3 +64,4 @@ def __init__(self, *, role, name: str, type, fqn: str=None, email: str=None, app
         self.fqn = fqn
         self.email = email
         self.app_id = app_id
+        self.tenant_name = None
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_py3.py
index 6d5ae504ce1b..42ad35d6d195 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_py3.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_py3.py
@@ -29,14 +29,15 @@ class Database(ProxyResource):
     :param location: Resource location.
     :type location: str
     :ivar provisioning_state: The provisioned state of the resource. Possible
-     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed'
+     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
+     'Moving'
     :vartype provisioning_state: str or
      ~azure.mgmt.kusto.models.ProvisioningState
     :param soft_delete_period: The time the data should be kept before it
      stops being accessible to queries in TimeSpan.
     :type soft_delete_period: timedelta
-    :param hot_cache_period: The time the data that should be kept in cache
-     for fast queries in TimeSpan.
+    :param hot_cache_period: The time the data should be kept in cache for
+     fast queries in TimeSpan.
     :type hot_cache_period: timedelta
     :param statistics: The statistics of the database.
     :type statistics: ~azure.mgmt.kusto.models.DatabaseStatistics
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_update.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_update.py
index cdae04a66d87..0e5fde225125 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_update.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_update.py
@@ -29,14 +29,15 @@ class DatabaseUpdate(Resource):
     :param location: Resource location.
     :type location: str
     :ivar provisioning_state: The provisioned state of the resource. Possible
-     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed'
+     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
+     'Moving'
     :vartype provisioning_state: str or
      ~azure.mgmt.kusto.models.ProvisioningState
     :param soft_delete_period: The time the data should be kept before it
      stops being accessible to queries in TimeSpan.
     :type soft_delete_period: timedelta
-    :param hot_cache_period: The time the data that should be kept in cache
-     for fast queries in TimeSpan.
+    :param hot_cache_period: The time the data should be kept in cache for
+     fast queries in TimeSpan.
     :type hot_cache_period: timedelta
     :param statistics: The statistics of the database.
     :type statistics: ~azure.mgmt.kusto.models.DatabaseStatistics
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_update_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_update_py3.py
index 6955740924e3..c447bd2c79b1 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_update_py3.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/database_update_py3.py
@@ -29,14 +29,15 @@ class DatabaseUpdate(Resource):
     :param location: Resource location.
     :type location: str
     :ivar provisioning_state: The provisioned state of the resource. Possible
-     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed'
+     values include: 'Running', 'Creating', 'Deleting', 'Succeeded', 'Failed',
+     'Moving'
     :vartype provisioning_state: str or
      ~azure.mgmt.kusto.models.ProvisioningState
     :param soft_delete_period: The time the data should be kept before it
      stops being accessible to queries in TimeSpan.
     :type soft_delete_period: timedelta
-    :param hot_cache_period: The time the data that should be kept in cache
-     for fast queries in TimeSpan.
+    :param hot_cache_period: The time the data should be kept in cache for
+     fast queries in TimeSpan.
     :type hot_cache_period: timedelta
     :param statistics: The statistics of the database.
     :type statistics: ~azure.mgmt.kusto.models.DatabaseStatistics
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/event_hub_data_connection.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/event_hub_data_connection.py
index ac4e3424e520..f2cff9e432d6 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/event_hub_data_connection.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/event_hub_data_connection.py
@@ -48,6 +48,8 @@ class EventHubDataConnection(DataConnection):
      'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON',
      'AVRO'
     :type data_format: str or ~azure.mgmt.kusto.models.DataFormat
+    :param event_system_properties: System properties of the event hub
+    :type event_system_properties: list[str]
     """
 
     _validation = {
@@ -70,6 +72,7 @@ class EventHubDataConnection(DataConnection):
         'table_name': {'key': 'properties.tableName', 'type': 'str'},
         'mapping_rule_name': {'key': 'properties.mappingRuleName', 'type': 'str'},
         'data_format': {'key': 'properties.dataFormat', 'type': 'str'},
+        'event_system_properties': {'key': 'properties.eventSystemProperties', 'type': '[str]'},
     }
 
     def __init__(self, **kwargs):
@@ -79,4 +82,5 @@ def __init__(self, **kwargs):
         self.table_name = kwargs.get('table_name', None)
         self.mapping_rule_name = kwargs.get('mapping_rule_name', None)
         self.data_format = kwargs.get('data_format', None)
+        self.event_system_properties = kwargs.get('event_system_properties', None)
         self.kind = 'EventHub'
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/event_hub_data_connection_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/event_hub_data_connection_py3.py
index ded495f116c4..5455ab59b06a 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/event_hub_data_connection_py3.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/event_hub_data_connection_py3.py
@@ -48,6 +48,8 @@ class EventHubDataConnection(DataConnection):
      'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON',
      'AVRO'
     :type data_format: str or ~azure.mgmt.kusto.models.DataFormat
+    :param event_system_properties: System properties of the event hub
+    :type event_system_properties: list[str]
     """
 
     _validation = {
@@ -70,13 +72,15 @@ class EventHubDataConnection(DataConnection):
         'table_name': {'key': 'properties.tableName', 'type': 'str'},
         'mapping_rule_name': {'key': 'properties.mappingRuleName', 'type': 'str'},
         'data_format': {'key': 'properties.dataFormat', 'type': 'str'},
+        'event_system_properties': {'key': 'properties.eventSystemProperties', 'type': '[str]'},
     }
 
-    def __init__(self, *, event_hub_resource_id: str, consumer_group: str, location: str=None, table_name: str=None, mapping_rule_name: str=None, data_format=None, **kwargs) -> None:
+    def __init__(self, *, event_hub_resource_id: str, consumer_group: str, location: str=None, table_name: str=None, mapping_rule_name: str=None, data_format=None, event_system_properties=None, **kwargs) -> None:
         super(EventHubDataConnection, self).__init__(location=location, **kwargs)
         self.event_hub_resource_id = event_hub_resource_id
         self.consumer_group = consumer_group
         self.table_name = table_name
         self.mapping_rule_name = mapping_rule_name
         self.data_format = data_format
+        self.event_system_properties = event_system_properties
         self.kind = 'EventHub'
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/iot_hub_data_connection.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/iot_hub_data_connection.py
new file mode 100644
index 000000000000..8dd4d1f87c5a
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/iot_hub_data_connection.py
@@ -0,0 +1,92 @@
+# 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 .data_connection import DataConnection
+
+
+class IotHubDataConnection(DataConnection):
+    """Class representing an iot hub data connection.
+
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :ivar id: Fully qualified resource Id for the resource. Ex -
+     /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
+    :vartype id: str
+    :ivar name: The name of the resource
+    :vartype name: str
+    :ivar type: The type of the resource. Ex-
+     Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts.
+    :vartype type: str
+    :param location: Resource location.
+    :type location: str
+    :param kind: Required. Constant filled by server.
+    :type kind: str
+    :param iot_hub_resource_id: Required. The resource ID of the Iot hub to be
+     used to create a data connection.
+    :type iot_hub_resource_id: str
+    :param consumer_group: Required. The iot hub consumer group.
+    :type consumer_group: str
+    :param table_name: The table where the data should be ingested. Optionally
+     the table information can be added to each message.
+    :type table_name: str
+    :param mapping_rule_name: The mapping rule to be used to ingest the data.
+     Optionally the mapping information can be added to each message.
+    :type mapping_rule_name: str
+    :param data_format: The data format of the message. Optionally the data
+     format can be added to each message. Possible values include: 'MULTIJSON',
+     'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON',
+     'AVRO'
+    :type data_format: str or ~azure.mgmt.kusto.models.DataFormat
+    :param event_system_properties: System properties of the iot hub
+    :type event_system_properties: list[str]
+    :param shared_access_policy_name: Required. The name of the share access
+     policy name
+    :type shared_access_policy_name: str
+    """
+
+    _validation = {
+        'id': {'readonly': True},
+        'name': {'readonly': True},
+        'type': {'readonly': True},
+        'kind': {'required': True},
+        'iot_hub_resource_id': {'required': True},
+        'consumer_group': {'required': True},
+        'shared_access_policy_name': {'required': True},
+    }
+
+    _attribute_map = {
+        'id': {'key': 'id', 'type': 'str'},
+        'name': {'key': 'name', 'type': 'str'},
+        'type': {'key': 'type', 'type': 'str'},
+        'location': {'key': 'location', 'type': 'str'},
+        'kind': {'key': 'kind', 'type': 'str'},
+        'iot_hub_resource_id': {'key': 'properties.iotHubResourceId', 'type': 'str'},
+        'consumer_group': {'key': 'properties.consumerGroup', 'type': 'str'},
+        'table_name': {'key': 'properties.tableName', 'type': 'str'},
+        'mapping_rule_name': {'key': 'properties.mappingRuleName', 'type': 'str'},
+        'data_format': {'key': 'properties.dataFormat', 'type': 'str'},
+        'event_system_properties': {'key': 'properties.eventSystemProperties', 'type': '[str]'},
+        'shared_access_policy_name': {'key': 'properties.sharedAccessPolicyName', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(IotHubDataConnection, self).__init__(**kwargs)
+        self.iot_hub_resource_id = kwargs.get('iot_hub_resource_id', None)
+        self.consumer_group = kwargs.get('consumer_group', None)
+        self.table_name = kwargs.get('table_name', None)
+        self.mapping_rule_name = kwargs.get('mapping_rule_name', None)
+        self.data_format = kwargs.get('data_format', None)
+        self.event_system_properties = kwargs.get('event_system_properties', None)
+        self.shared_access_policy_name = kwargs.get('shared_access_policy_name', None)
+        self.kind = 'IotHub'
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/iot_hub_data_connection_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/iot_hub_data_connection_py3.py
new file mode 100644
index 000000000000..b8729a728bd0
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/iot_hub_data_connection_py3.py
@@ -0,0 +1,92 @@
+# 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 .data_connection_py3 import DataConnection
+
+
+class IotHubDataConnection(DataConnection):
+    """Class representing an iot hub data connection.
+
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :ivar id: Fully qualified resource Id for the resource. Ex -
+     /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
+    :vartype id: str
+    :ivar name: The name of the resource
+    :vartype name: str
+    :ivar type: The type of the resource. Ex-
+     Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts.
+    :vartype type: str
+    :param location: Resource location.
+    :type location: str
+    :param kind: Required. Constant filled by server.
+    :type kind: str
+    :param iot_hub_resource_id: Required. The resource ID of the Iot hub to be
+     used to create a data connection.
+    :type iot_hub_resource_id: str
+    :param consumer_group: Required. The iot hub consumer group.
+    :type consumer_group: str
+    :param table_name: The table where the data should be ingested. Optionally
+     the table information can be added to each message.
+    :type table_name: str
+    :param mapping_rule_name: The mapping rule to be used to ingest the data.
+     Optionally the mapping information can be added to each message.
+    :type mapping_rule_name: str
+    :param data_format: The data format of the message. Optionally the data
+     format can be added to each message. Possible values include: 'MULTIJSON',
+     'JSON', 'CSV', 'TSV', 'SCSV', 'SOHSV', 'PSV', 'TXT', 'RAW', 'SINGLEJSON',
+     'AVRO'
+    :type data_format: str or ~azure.mgmt.kusto.models.DataFormat
+    :param event_system_properties: System properties of the iot hub
+    :type event_system_properties: list[str]
+    :param shared_access_policy_name: Required. The name of the share access
+     policy name
+    :type shared_access_policy_name: str
+    """
+
+    _validation = {
+        'id': {'readonly': True},
+        'name': {'readonly': True},
+        'type': {'readonly': True},
+        'kind': {'required': True},
+        'iot_hub_resource_id': {'required': True},
+        'consumer_group': {'required': True},
+        'shared_access_policy_name': {'required': True},
+    }
+
+    _attribute_map = {
+        'id': {'key': 'id', 'type': 'str'},
+        'name': {'key': 'name', 'type': 'str'},
+        'type': {'key': 'type', 'type': 'str'},
+        'location': {'key': 'location', 'type': 'str'},
+        'kind': {'key': 'kind', 'type': 'str'},
+        'iot_hub_resource_id': {'key': 'properties.iotHubResourceId', 'type': 'str'},
+        'consumer_group': {'key': 'properties.consumerGroup', 'type': 'str'},
+        'table_name': {'key': 'properties.tableName', 'type': 'str'},
+        'mapping_rule_name': {'key': 'properties.mappingRuleName', 'type': 'str'},
+        'data_format': {'key': 'properties.dataFormat', 'type': 'str'},
+        'event_system_properties': {'key': 'properties.eventSystemProperties', 'type': '[str]'},
+        'shared_access_policy_name': {'key': 'properties.sharedAccessPolicyName', 'type': 'str'},
+    }
+
+    def __init__(self, *, iot_hub_resource_id: str, consumer_group: str, shared_access_policy_name: str, location: str=None, table_name: str=None, mapping_rule_name: str=None, data_format=None, event_system_properties=None, **kwargs) -> None:
+        super(IotHubDataConnection, self).__init__(location=location, **kwargs)
+        self.iot_hub_resource_id = iot_hub_resource_id
+        self.consumer_group = consumer_group
+        self.table_name = table_name
+        self.mapping_rule_name = mapping_rule_name
+        self.data_format = data_format
+        self.event_system_properties = event_system_properties
+        self.shared_access_policy_name = shared_access_policy_name
+        self.kind = 'IotHub'
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/kusto_management_client_enums.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/kusto_management_client_enums.py
index e990cf23367b..20490930677a 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/kusto_management_client_enums.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/kusto_management_client_enums.py
@@ -32,17 +32,29 @@ class ProvisioningState(str, Enum):
     deleting = "Deleting"
     succeeded = "Succeeded"
     failed = "Failed"
+    moving = "Moving"
 
 
 class AzureSkuName(str, Enum):
 
-    d13_v2 = "D13_v2"
-    d14_v2 = "D14_v2"
-    l8 = "L8"
-    l16 = "L16"
-    d11_v2 = "D11_v2"
-    d12_v2 = "D12_v2"
-    l4 = "L4"
+    standard_ds13_v21_tb_ps = "Standard_DS13_v2+1TB_PS"
+    standard_ds13_v22_tb_ps = "Standard_DS13_v2+2TB_PS"
+    standard_ds14_v23_tb_ps = "Standard_DS14_v2+3TB_PS"
+    standard_ds14_v24_tb_ps = "Standard_DS14_v2+4TB_PS"
+    standard_d13_v2 = "Standard_D13_v2"
+    standard_d14_v2 = "Standard_D14_v2"
+    standard_l8s = "Standard_L8s"
+    standard_l16s = "Standard_L16s"
+    standard_d11_v2 = "Standard_D11_v2"
+    standard_d12_v2 = "Standard_D12_v2"
+    standard_l4s = "Standard_L4s"
+    dev_no_sla_standard_d11_v2 = "Dev(No SLA)_Standard_D11_v2"
+
+
+class AzureSkuTier(str, Enum):
+
+    basic = "Basic"
+    standard = "Standard"
 
 
 class AzureScaleType(str, Enum):
@@ -82,3 +94,9 @@ class DatabasePrincipalType(str, Enum):
     app = "App"
     group = "Group"
     user = "User"
+
+
+class Reason(str, Enum):
+
+    invalid = "Invalid"
+    already_exists = "AlreadyExists"
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/optimized_autoscale.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/optimized_autoscale.py
new file mode 100644
index 000000000000..838c9c4a887e
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/optimized_autoscale.py
@@ -0,0 +1,51 @@
+# 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 OptimizedAutoscale(Model):
+    """A class that contains the optimized auto scale definition.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param version: Required. The version of the template defined, for
+     instance 1.
+    :type version: int
+    :param is_enabled: Required. A boolean value that indicate if the
+     optimized autoscale feature is enabled or not.
+    :type is_enabled: bool
+    :param minimum: Required. Minimum allowed instances count.
+    :type minimum: int
+    :param maximum: Required. Maximum allowed instances count.
+    :type maximum: int
+    """
+
+    _validation = {
+        'version': {'required': True},
+        'is_enabled': {'required': True},
+        'minimum': {'required': True},
+        'maximum': {'required': True},
+    }
+
+    _attribute_map = {
+        'version': {'key': 'version', 'type': 'int'},
+        'is_enabled': {'key': 'isEnabled', 'type': 'bool'},
+        'minimum': {'key': 'minimum', 'type': 'int'},
+        'maximum': {'key': 'maximum', 'type': 'int'},
+    }
+
+    def __init__(self, **kwargs):
+        super(OptimizedAutoscale, self).__init__(**kwargs)
+        self.version = kwargs.get('version', None)
+        self.is_enabled = kwargs.get('is_enabled', None)
+        self.minimum = kwargs.get('minimum', None)
+        self.maximum = kwargs.get('maximum', None)
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/optimized_autoscale_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/optimized_autoscale_py3.py
new file mode 100644
index 000000000000..3979dca90efc
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/optimized_autoscale_py3.py
@@ -0,0 +1,51 @@
+# 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 OptimizedAutoscale(Model):
+    """A class that contains the optimized auto scale definition.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param version: Required. The version of the template defined, for
+     instance 1.
+    :type version: int
+    :param is_enabled: Required. A boolean value that indicate if the
+     optimized autoscale feature is enabled or not.
+    :type is_enabled: bool
+    :param minimum: Required. Minimum allowed instances count.
+    :type minimum: int
+    :param maximum: Required. Maximum allowed instances count.
+    :type maximum: int
+    """
+
+    _validation = {
+        'version': {'required': True},
+        'is_enabled': {'required': True},
+        'minimum': {'required': True},
+        'maximum': {'required': True},
+    }
+
+    _attribute_map = {
+        'version': {'key': 'version', 'type': 'int'},
+        'is_enabled': {'key': 'isEnabled', 'type': 'bool'},
+        'minimum': {'key': 'minimum', 'type': 'int'},
+        'maximum': {'key': 'maximum', 'type': 'int'},
+    }
+
+    def __init__(self, *, version: int, is_enabled: bool, minimum: int, maximum: int, **kwargs) -> None:
+        super(OptimizedAutoscale, self).__init__(**kwargs)
+        self.version = version
+        self.is_enabled = is_enabled
+        self.minimum = minimum
+        self.maximum = maximum
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_description.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_description.py
new file mode 100644
index 000000000000..6bb95626c627
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_description.py
@@ -0,0 +1,60 @@
+# 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 SkuDescription(Model):
+    """The Kusto SKU description of given resource type.
+
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
+    :ivar resource_type: The resource type
+    :vartype resource_type: str
+    :ivar name: The name of the SKU
+    :vartype name: str
+    :ivar tier: The tier of the SKU
+    :vartype tier: str
+    :ivar locations: The set of locations that the SKU is available
+    :vartype locations: list[str]
+    :ivar location_info: Locations and zones
+    :vartype location_info: list[~azure.mgmt.kusto.models.SkuLocationInfoItem]
+    :ivar restrictions: The restrictions because of which SKU cannot be used
+    :vartype restrictions: list[object]
+    """
+
+    _validation = {
+        'resource_type': {'readonly': True},
+        'name': {'readonly': True},
+        'tier': {'readonly': True},
+        'locations': {'readonly': True},
+        'location_info': {'readonly': True},
+        'restrictions': {'readonly': True},
+    }
+
+    _attribute_map = {
+        'resource_type': {'key': 'resourceType', 'type': 'str'},
+        'name': {'key': 'name', 'type': 'str'},
+        'tier': {'key': 'tier', 'type': 'str'},
+        'locations': {'key': 'locations', 'type': '[str]'},
+        'location_info': {'key': 'locationInfo', 'type': '[SkuLocationInfoItem]'},
+        'restrictions': {'key': 'restrictions', 'type': '[object]'},
+    }
+
+    def __init__(self, **kwargs):
+        super(SkuDescription, self).__init__(**kwargs)
+        self.resource_type = None
+        self.name = None
+        self.tier = None
+        self.locations = None
+        self.location_info = None
+        self.restrictions = None
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku_paged.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_description_paged.py
similarity index 68%
rename from sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku_paged.py
rename to sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_description_paged.py
index e98163c92ebd..1ebdebe372fe 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/azure_sku_paged.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_description_paged.py
@@ -12,16 +12,16 @@
 from msrest.paging import Paged
 
 
-class AzureSkuPaged(Paged):
+class SkuDescriptionPaged(Paged):
     """
-    A paging container for iterating over a list of :class:`AzureSku <azure.mgmt.kusto.models.AzureSku>` object
+    A paging container for iterating over a list of :class:`SkuDescription <azure.mgmt.kusto.models.SkuDescription>` object
     """
 
     _attribute_map = {
         'next_link': {'key': 'nextLink', 'type': 'str'},
-        'current_page': {'key': 'value', 'type': '[AzureSku]'}
+        'current_page': {'key': 'value', 'type': '[SkuDescription]'}
     }
 
     def __init__(self, *args, **kwargs):
 
-        super(AzureSkuPaged, self).__init__(*args, **kwargs)
+        super(SkuDescriptionPaged, self).__init__(*args, **kwargs)
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_description_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_description_py3.py
new file mode 100644
index 000000000000..156a526d333c
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_description_py3.py
@@ -0,0 +1,60 @@
+# 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 SkuDescription(Model):
+    """The Kusto SKU description of given resource type.
+
+    Variables are only populated by the server, and will be ignored when
+    sending a request.
+
+    :ivar resource_type: The resource type
+    :vartype resource_type: str
+    :ivar name: The name of the SKU
+    :vartype name: str
+    :ivar tier: The tier of the SKU
+    :vartype tier: str
+    :ivar locations: The set of locations that the SKU is available
+    :vartype locations: list[str]
+    :ivar location_info: Locations and zones
+    :vartype location_info: list[~azure.mgmt.kusto.models.SkuLocationInfoItem]
+    :ivar restrictions: The restrictions because of which SKU cannot be used
+    :vartype restrictions: list[object]
+    """
+
+    _validation = {
+        'resource_type': {'readonly': True},
+        'name': {'readonly': True},
+        'tier': {'readonly': True},
+        'locations': {'readonly': True},
+        'location_info': {'readonly': True},
+        'restrictions': {'readonly': True},
+    }
+
+    _attribute_map = {
+        'resource_type': {'key': 'resourceType', 'type': 'str'},
+        'name': {'key': 'name', 'type': 'str'},
+        'tier': {'key': 'tier', 'type': 'str'},
+        'locations': {'key': 'locations', 'type': '[str]'},
+        'location_info': {'key': 'locationInfo', 'type': '[SkuLocationInfoItem]'},
+        'restrictions': {'key': 'restrictions', 'type': '[object]'},
+    }
+
+    def __init__(self, **kwargs) -> None:
+        super(SkuDescription, self).__init__(**kwargs)
+        self.resource_type = None
+        self.name = None
+        self.tier = None
+        self.locations = None
+        self.location_info = None
+        self.restrictions = None
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_location_info_item.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_location_info_item.py
new file mode 100644
index 000000000000..89ef6bb1dfb3
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_location_info_item.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 SkuLocationInfoItem(Model):
+    """The locations and zones info for SKU.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param location: Required. The available location of the SKU.
+    :type location: str
+    :param zones: The available zone of the SKU.
+    :type zones: list[str]
+    """
+
+    _validation = {
+        'location': {'required': True},
+    }
+
+    _attribute_map = {
+        'location': {'key': 'location', 'type': 'str'},
+        'zones': {'key': 'zones', 'type': '[str]'},
+    }
+
+    def __init__(self, **kwargs):
+        super(SkuLocationInfoItem, self).__init__(**kwargs)
+        self.location = kwargs.get('location', None)
+        self.zones = kwargs.get('zones', None)
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_location_info_item_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_location_info_item_py3.py
new file mode 100644
index 000000000000..7e60b635e7d8
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/sku_location_info_item_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 SkuLocationInfoItem(Model):
+    """The locations and zones info for SKU.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param location: Required. The available location of the SKU.
+    :type location: str
+    :param zones: The available zone of the SKU.
+    :type zones: list[str]
+    """
+
+    _validation = {
+        'location': {'required': True},
+    }
+
+    _attribute_map = {
+        'location': {'key': 'location', 'type': 'str'},
+        'zones': {'key': 'zones', 'type': '[str]'},
+    }
+
+    def __init__(self, *, location: str, zones=None, **kwargs) -> None:
+        super(SkuLocationInfoItem, self).__init__(**kwargs)
+        self.location = location
+        self.zones = zones
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/virtual_network_configuration.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/virtual_network_configuration.py
new file mode 100644
index 000000000000..f6e4c0db84a4
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/virtual_network_configuration.py
@@ -0,0 +1,46 @@
+# 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 VirtualNetworkConfiguration(Model):
+    """A class that contains virtual network definition.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param subnet_id: Required. The subnet resource id.
+    :type subnet_id: str
+    :param engine_public_ip_id: Required. Engine service's public IP address
+     resource id.
+    :type engine_public_ip_id: str
+    :param data_management_public_ip_id: Required. Data management's service
+     public IP address resource id.
+    :type data_management_public_ip_id: str
+    """
+
+    _validation = {
+        'subnet_id': {'required': True},
+        'engine_public_ip_id': {'required': True},
+        'data_management_public_ip_id': {'required': True},
+    }
+
+    _attribute_map = {
+        'subnet_id': {'key': 'subnetId', 'type': 'str'},
+        'engine_public_ip_id': {'key': 'enginePublicIpId', 'type': 'str'},
+        'data_management_public_ip_id': {'key': 'dataManagementPublicIpId', 'type': 'str'},
+    }
+
+    def __init__(self, **kwargs):
+        super(VirtualNetworkConfiguration, self).__init__(**kwargs)
+        self.subnet_id = kwargs.get('subnet_id', None)
+        self.engine_public_ip_id = kwargs.get('engine_public_ip_id', None)
+        self.data_management_public_ip_id = kwargs.get('data_management_public_ip_id', None)
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/virtual_network_configuration_py3.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/virtual_network_configuration_py3.py
new file mode 100644
index 000000000000..ddebdffc6f10
--- /dev/null
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/models/virtual_network_configuration_py3.py
@@ -0,0 +1,46 @@
+# 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 VirtualNetworkConfiguration(Model):
+    """A class that contains virtual network definition.
+
+    All required parameters must be populated in order to send to Azure.
+
+    :param subnet_id: Required. The subnet resource id.
+    :type subnet_id: str
+    :param engine_public_ip_id: Required. Engine service's public IP address
+     resource id.
+    :type engine_public_ip_id: str
+    :param data_management_public_ip_id: Required. Data management's service
+     public IP address resource id.
+    :type data_management_public_ip_id: str
+    """
+
+    _validation = {
+        'subnet_id': {'required': True},
+        'engine_public_ip_id': {'required': True},
+        'data_management_public_ip_id': {'required': True},
+    }
+
+    _attribute_map = {
+        'subnet_id': {'key': 'subnetId', 'type': 'str'},
+        'engine_public_ip_id': {'key': 'enginePublicIpId', 'type': 'str'},
+        'data_management_public_ip_id': {'key': 'dataManagementPublicIpId', 'type': 'str'},
+    }
+
+    def __init__(self, *, subnet_id: str, engine_public_ip_id: str, data_management_public_ip_id: str, **kwargs) -> None:
+        super(VirtualNetworkConfiguration, self).__init__(**kwargs)
+        self.subnet_id = subnet_id
+        self.engine_public_ip_id = engine_public_ip_id
+        self.data_management_public_ip_id = data_management_public_ip_id
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/clusters_operations.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/clusters_operations.py
index cc6cc68cba10..98f499a62640 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/clusters_operations.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/clusters_operations.py
@@ -25,7 +25,7 @@ class ClustersOperations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: Client API Version. Constant value: "2019-01-21".
+    :ivar api_version: Client API Version. Constant value: "2019-05-15".
     """
 
     models = models
@@ -35,7 +35,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2019-01-21"
+        self.api_version = "2019-05-15"
 
         self.config = config
 
@@ -691,9 +691,9 @@ def list_skus(
          deserialized response
         :param operation_config: :ref:`Operation configuration
          overrides<msrest:optionsforoperations>`.
-        :return: An iterator like instance of AzureSku
+        :return: An iterator like instance of SkuDescription
         :rtype:
-         ~azure.mgmt.kusto.models.AzureSkuPaged[~azure.mgmt.kusto.models.AzureSku]
+         ~azure.mgmt.kusto.models.SkuDescriptionPaged[~azure.mgmt.kusto.models.SkuDescription]
         :raises: :class:`CloudError<msrestazure.azure_exceptions.CloudError>`
         """
         def internal_paging(next_link=None, raw=False):
@@ -736,11 +736,11 @@ def internal_paging(next_link=None, raw=False):
             return response
 
         # Deserialize response
-        deserialized = models.AzureSkuPaged(internal_paging, self._deserialize.dependencies)
+        deserialized = models.SkuDescriptionPaged(internal_paging, self._deserialize.dependencies)
 
         if raw:
             header_dict = {}
-            client_raw_response = models.AzureSkuPaged(internal_paging, self._deserialize.dependencies, header_dict)
+            client_raw_response = models.SkuDescriptionPaged(internal_paging, self._deserialize.dependencies, header_dict)
             return client_raw_response
 
         return deserialized
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/data_connections_operations.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/data_connections_operations.py
index 17e0bce9bdca..1a3762cb8dc0 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/data_connections_operations.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/data_connections_operations.py
@@ -25,7 +25,7 @@ class DataConnectionsOperations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: Client API Version. Constant value: "2019-01-21".
+    :ivar api_version: Client API Version. Constant value: "2019-05-15".
     """
 
     models = models
@@ -35,7 +35,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2019-01-21"
+        self.api_version = "2019-05-15"
 
         self.config = config
 
@@ -190,6 +190,81 @@ def data_connection_validation_method(
         return deserialized
     data_connection_validation_method.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Kusto/clusters/{clusterName}/databases/{databaseName}/dataConnectionValidation'}
 
+    def check_name_availability(
+            self, resource_group_name, cluster_name, database_name, name, custom_headers=None, raw=False, **operation_config):
+        """Checks that the data connection name is valid and is not already in
+        use.
+
+        :param resource_group_name: The name of the resource group containing
+         the Kusto cluster.
+        :type resource_group_name: str
+        :param cluster_name: The name of the Kusto cluster.
+        :type cluster_name: str
+        :param database_name: The name of the database in the Kusto cluster.
+        :type database_name: str
+        :param name: Data Connection name.
+        :type name: str
+        :param dict custom_headers: headers that will be added to the request
+        :param bool raw: returns the direct response alongside the
+         deserialized response
+        :param operation_config: :ref:`Operation configuration
+         overrides<msrest:optionsforoperations>`.
+        :return: CheckNameResult or ClientRawResponse if raw=true
+        :rtype: ~azure.mgmt.kusto.models.CheckNameResult or
+         ~msrest.pipeline.ClientRawResponse
+        :raises: :class:`CloudError<msrestazure.azure_exceptions.CloudError>`
+        """
+        data_connection_name = models.DataConnectionCheckNameRequest(name=name)
+
+        # Construct URL
+        url = self.check_name_availability.metadata['url']
+        path_format_arguments = {
+            'resourceGroupName': self._serialize.url("resource_group_name", resource_group_name, 'str'),
+            'clusterName': self._serialize.url("cluster_name", cluster_name, 'str'),
+            'databaseName': self._serialize.url("database_name", database_name, 'str'),
+            'subscriptionId': self._serialize.url("self.config.subscription_id", self.config.subscription_id, '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['Accept'] = 'application/json'
+        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(data_connection_name, 'DataConnectionCheckNameRequest')
+
+        # 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]:
+            exp = CloudError(response)
+            exp.request_id = response.headers.get('x-ms-request-id')
+            raise exp
+
+        deserialized = None
+
+        if response.status_code == 200:
+            deserialized = self._deserialize('CheckNameResult', response)
+
+        if raw:
+            client_raw_response = ClientRawResponse(deserialized, response)
+            return client_raw_response
+
+        return deserialized
+    check_name_availability.metadata = {'url': '/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.Kusto/clusters/{clusterName}/databases/{databaseName}/checkNameAvailability'}
+
     def get(
             self, resource_group_name, cluster_name, database_name, data_connection_name, custom_headers=None, raw=False, **operation_config):
         """Returns a data connection.
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/databases_operations.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/databases_operations.py
index fa2fcb350575..d3d26db24225 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/databases_operations.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/databases_operations.py
@@ -25,7 +25,7 @@ class DatabasesOperations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: Client API Version. Constant value: "2019-01-21".
+    :ivar api_version: Client API Version. Constant value: "2019-05-15".
     """
 
     models = models
@@ -35,7 +35,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2019-01-21"
+        self.api_version = "2019-05-15"
 
         self.config = config
 
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/operations.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/operations.py
index 88bc178e823c..c9b73d07ac5f 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/operations.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/operations/operations.py
@@ -23,7 +23,7 @@ class Operations(object):
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
     :param deserializer: An object model deserializer.
-    :ivar api_version: Client API Version. Constant value: "2019-01-21".
+    :ivar api_version: Client API Version. Constant value: "2019-05-15".
     """
 
     models = models
@@ -33,7 +33,7 @@ def __init__(self, client, config, serializer, deserializer):
         self._client = client
         self._serialize = serializer
         self._deserialize = deserializer
-        self.api_version = "2019-01-21"
+        self.api_version = "2019-05-15"
 
         self.config = config
 
diff --git a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/version.py b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/version.py
index 3e682bbd5fb1..e0ec669828cb 100644
--- a/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/version.py
+++ b/sdk/kusto/azure-mgmt-kusto/azure/mgmt/kusto/version.py
@@ -9,5 +9,5 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-VERSION = "0.3.0"
+VERSION = "0.1.0"