diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/api/Azure.ResourceManager.StreamAnalytics.netstandard2.0.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/api/Azure.ResourceManager.StreamAnalytics.netstandard2.0.cs index 20e99ec9a361..b1d5a297d7b6 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/api/Azure.ResourceManager.StreamAnalytics.netstandard2.0.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/api/Azure.ResourceManager.StreamAnalytics.netstandard2.0.cs @@ -155,7 +155,8 @@ public StreamingJobData(Azure.Core.AzureLocation location) : base (default(Azure public Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputStartMode? OutputStartMode { get { throw null; } set { } } public System.DateTimeOffset? OutputStartOn { get { throw null; } set { } } public string ProvisioningState { get { throw null; } } - public Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSkuName? SkuName { get { throw null; } set { } } + public Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSku Sku { get { throw null; } set { } } + public Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSku SkuPropertiesSku { get { throw null; } set { } } public Azure.ResourceManager.StreamAnalytics.StreamingJobTransformationData Transformation { get { throw null; } set { } } } public partial class StreamingJobFunctionCollection : Azure.ResourceManager.ArmCollection, System.Collections.Generic.IAsyncEnumerable, System.Collections.Generic.IEnumerable, System.Collections.IEnumerable @@ -255,7 +256,7 @@ public StreamingJobOutputData() { } public Azure.ETag? ETag { get { throw null; } } public System.Collections.Generic.IReadOnlyList LastOutputEventTimestamps { get { throw null; } } public Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsDataSerialization Serialization { get { throw null; } set { } } - public float? SizeWindow { get { throw null; } set { } } + public int? SizeWindow { get { throw null; } set { } } public System.TimeSpan? TimeFrame { get { throw null; } set { } } [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)] [System.ObsoleteAttribute("This property is obsolete and will be removed in a future release. Please use TimeFrame instead.", false)] @@ -291,6 +292,8 @@ protected StreamingJobResource() { } public virtual System.Threading.Tasks.Task DeleteAsync(Azure.WaitUntil waitUntil, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public virtual Azure.Response Get(string expand = null, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public virtual System.Threading.Tasks.Task> GetAsync(string expand = null, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } + public virtual Azure.Pageable GetSkus(System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } + public virtual Azure.AsyncPageable GetSkusAsync(System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public virtual Azure.Response GetStreamingJobFunction(string functionName, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public virtual System.Threading.Tasks.Task> GetStreamingJobFunctionAsync(string functionName, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public virtual Azure.ResourceManager.StreamAnalytics.StreamingJobFunctionCollection GetStreamingJobFunctions() { throw null; } @@ -356,9 +359,11 @@ public AggregateFunctionProperties() { } public static partial class ArmStreamAnalyticsModelFactory { public static Azure.ResourceManager.StreamAnalytics.Models.AggregateFunctionProperties AggregateFunctionProperties(Azure.ETag? etag = default(Azure.ETag?), System.Collections.Generic.IEnumerable inputs = null, string outputDataType = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobFunctionBinding binding = null) { throw null; } + public static Azure.ResourceManager.StreamAnalytics.Models.GetStreamingJobSkuResult GetStreamingJobSkuResult(Azure.ResourceManager.StreamAnalytics.Models.ResourceType? resourceType = default(Azure.ResourceManager.StreamAnalytics.Models.ResourceType?), Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSkuName? skuName = default(Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSkuName?), Azure.ResourceManager.StreamAnalytics.Models.SkuCapacity capacity = null) { throw null; } public static Azure.ResourceManager.StreamAnalytics.Models.LastOutputEventTimestamp LastOutputEventTimestamp(System.DateTimeOffset? lastOutputEventOn = default(System.DateTimeOffset?), System.DateTimeOffset? lastUpdatedOn = default(System.DateTimeOffset?)) { throw null; } public static Azure.ResourceManager.StreamAnalytics.Models.ReferenceInputProperties ReferenceInputProperties(Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsDataSerialization serialization = null, System.Collections.Generic.IEnumerable diagnosticsConditions = null, Azure.ETag? etag = default(Azure.ETag?), Azure.ResourceManager.StreamAnalytics.Models.StreamingCompressionType? compressionType = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingCompressionType?), string partitionKey = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobInputWatermarkMode? watermarkMode = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobInputWatermarkMode?), Azure.ResourceManager.StreamAnalytics.Models.ReferenceInputDataSource datasource = null) { throw null; } public static Azure.ResourceManager.StreamAnalytics.Models.ScalarFunctionProperties ScalarFunctionProperties(Azure.ETag? etag = default(Azure.ETag?), System.Collections.Generic.IEnumerable inputs = null, string outputDataType = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobFunctionBinding binding = null) { throw null; } + public static Azure.ResourceManager.StreamAnalytics.Models.SkuCapacity SkuCapacity(int? minimum = default(int?), int? maximum = default(int?), int? @default = default(int?), Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType? scaleType = default(Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType?), System.Collections.Generic.IEnumerable allowedValues = null) { throw null; } public static Azure.ResourceManager.StreamAnalytics.StreamAnalyticsClusterData StreamAnalyticsClusterData(Azure.Core.ResourceIdentifier id = null, string name = null, Azure.Core.ResourceType resourceType = default(Azure.Core.ResourceType), Azure.ResourceManager.Models.SystemData systemData = null, System.Collections.Generic.IDictionary tags = null, Azure.Core.AzureLocation location = default(Azure.Core.AzureLocation), Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsClusterSku sku = null, Azure.ETag? etag = default(Azure.ETag?), Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsClusterProperties properties = null) { throw null; } public static Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsClusterJob StreamAnalyticsClusterJob(Azure.Core.ResourceIdentifier id = null, int? streamingUnits = default(int?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobState? jobState = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobState?)) { throw null; } public static Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsClusterProperties StreamAnalyticsClusterProperties(System.DateTimeOffset? createdOn = default(System.DateTimeOffset?), System.Guid? clusterId = default(System.Guid?), Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsClusterProvisioningState? provisioningState = default(Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsClusterProvisioningState?), int? capacityAllocated = default(int?), int? capacityAssigned = default(int?)) { throw null; } @@ -376,13 +381,13 @@ public static partial class ArmStreamAnalyticsModelFactory public static Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSubResource StreamAnalyticsSubResource(Azure.Core.ResourceIdentifier id = null, string name = null, Azure.Core.ResourceType? resourceType = default(Azure.Core.ResourceType?)) { throw null; } public static Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSubscriptionQuota StreamAnalyticsSubscriptionQuota(Azure.Core.ResourceIdentifier id = null, string name = null, Azure.Core.ResourceType? resourceType = default(Azure.Core.ResourceType?), int? maxCount = default(int?), int? currentCount = default(int?)) { throw null; } public static Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsTestDatasourceResult StreamAnalyticsTestDatasourceResult(string code = null, string message = null, string target = null, System.Collections.Generic.IEnumerable details = null, Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsTestDatasourceResultStatus? status = default(Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsTestDatasourceResultStatus?)) { throw null; } - public static Azure.ResourceManager.StreamAnalytics.StreamingJobData StreamingJobData(Azure.Core.ResourceIdentifier id = null, string name = null, Azure.Core.ResourceType resourceType = default(Azure.Core.ResourceType), Azure.ResourceManager.Models.SystemData systemData = null, System.Collections.Generic.IDictionary tags = null, Azure.Core.AzureLocation location = default(Azure.Core.AzureLocation), Azure.ResourceManager.Models.ManagedServiceIdentity identity = null, Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSkuName? skuName = default(Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSkuName?), System.Guid? jobId = default(System.Guid?), string provisioningState = null, string jobState = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobType? jobType = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobType?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputStartMode? outputStartMode = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputStartMode?), System.DateTimeOffset? outputStartOn = default(System.DateTimeOffset?), System.DateTimeOffset? lastOutputEventOn = default(System.DateTimeOffset?), Azure.ResourceManager.StreamAnalytics.Models.EventsOutOfOrderPolicy? eventsOutOfOrderPolicy = default(Azure.ResourceManager.StreamAnalytics.Models.EventsOutOfOrderPolicy?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputErrorPolicy? outputErrorPolicy = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputErrorPolicy?), int? eventsOutOfOrderMaxDelayInSeconds = default(int?), int? eventsLateArrivalMaxDelayInSeconds = default(int?), Azure.Core.AzureLocation? dataLocalion = default(Azure.Core.AzureLocation?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobCompatibilityLevel? compatibilityLevel = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobCompatibilityLevel?), System.DateTimeOffset? createdOn = default(System.DateTimeOffset?), System.Collections.Generic.IEnumerable inputs = null, Azure.ResourceManager.StreamAnalytics.StreamingJobTransformationData transformation = null, System.Collections.Generic.IEnumerable outputs = null, System.Collections.Generic.IEnumerable functions = null, Azure.ETag? etag = default(Azure.ETag?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobStorageAccount jobStorageAccount = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobContentStoragePolicy? contentStoragePolicy = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobContentStoragePolicy?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobExternal externals = null, Azure.Core.ResourceIdentifier clusterId = null) { throw null; } + public static Azure.ResourceManager.StreamAnalytics.StreamingJobData StreamingJobData(Azure.Core.ResourceIdentifier id = null, string name = null, Azure.Core.ResourceType resourceType = default(Azure.Core.ResourceType), Azure.ResourceManager.Models.SystemData systemData = null, System.Collections.Generic.IDictionary tags = null, Azure.Core.AzureLocation location = default(Azure.Core.AzureLocation), Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSku sku = null, Azure.ResourceManager.Models.ManagedServiceIdentity identity = null, Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSku skuPropertiesSku = null, System.Guid? jobId = default(System.Guid?), string provisioningState = null, string jobState = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobType? jobType = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobType?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputStartMode? outputStartMode = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputStartMode?), System.DateTimeOffset? outputStartOn = default(System.DateTimeOffset?), System.DateTimeOffset? lastOutputEventOn = default(System.DateTimeOffset?), Azure.ResourceManager.StreamAnalytics.Models.EventsOutOfOrderPolicy? eventsOutOfOrderPolicy = default(Azure.ResourceManager.StreamAnalytics.Models.EventsOutOfOrderPolicy?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputErrorPolicy? outputErrorPolicy = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputErrorPolicy?), int? eventsOutOfOrderMaxDelayInSeconds = default(int?), int? eventsLateArrivalMaxDelayInSeconds = default(int?), Azure.Core.AzureLocation? dataLocalion = default(Azure.Core.AzureLocation?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobCompatibilityLevel? compatibilityLevel = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobCompatibilityLevel?), System.DateTimeOffset? createdOn = default(System.DateTimeOffset?), System.Collections.Generic.IEnumerable inputs = null, Azure.ResourceManager.StreamAnalytics.StreamingJobTransformationData transformation = null, System.Collections.Generic.IEnumerable outputs = null, System.Collections.Generic.IEnumerable functions = null, Azure.ETag? etag = default(Azure.ETag?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobStorageAccount jobStorageAccount = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobContentStoragePolicy? contentStoragePolicy = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobContentStoragePolicy?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobExternal externals = null, Azure.Core.ResourceIdentifier clusterId = null) { throw null; } public static Azure.ResourceManager.StreamAnalytics.Models.StreamingJobDiagnosticCondition StreamingJobDiagnosticCondition(System.DateTimeOffset? since = default(System.DateTimeOffset?), string code = null, string message = null) { throw null; } public static Azure.ResourceManager.StreamAnalytics.StreamingJobFunctionData StreamingJobFunctionData(Azure.Core.ResourceIdentifier id = null, string name = null, Azure.Core.ResourceType? resourceType = default(Azure.Core.ResourceType?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobFunctionProperties properties = null) { throw null; } public static Azure.ResourceManager.StreamAnalytics.Models.StreamingJobFunctionProperties StreamingJobFunctionProperties(string functionPropertiesType = null, Azure.ETag? etag = default(Azure.ETag?), System.Collections.Generic.IEnumerable inputs = null, string outputDataType = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobFunctionBinding binding = null) { throw null; } public static Azure.ResourceManager.StreamAnalytics.StreamingJobInputData StreamingJobInputData(Azure.Core.ResourceIdentifier id = null, string name = null, Azure.Core.ResourceType? resourceType = default(Azure.Core.ResourceType?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobInputProperties properties = null) { throw null; } public static Azure.ResourceManager.StreamAnalytics.Models.StreamingJobInputProperties StreamingJobInputProperties(string inputPropertiesType = null, Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsDataSerialization serialization = null, System.Collections.Generic.IEnumerable diagnosticsConditions = null, Azure.ETag? etag = default(Azure.ETag?), Azure.ResourceManager.StreamAnalytics.Models.StreamingCompressionType? compressionType = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingCompressionType?), string partitionKey = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobInputWatermarkMode? watermarkMode = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobInputWatermarkMode?)) { throw null; } - public static Azure.ResourceManager.StreamAnalytics.StreamingJobOutputData StreamingJobOutputData(Azure.Core.ResourceIdentifier id = null, string name = null, Azure.Core.ResourceType? resourceType = default(Azure.Core.ResourceType?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputDataSource datasource = null, System.TimeSpan? timeFrame = default(System.TimeSpan?), float? sizeWindow = default(float?), Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsDataSerialization serialization = null, System.Collections.Generic.IEnumerable diagnosticsConditions = null, Azure.ETag? etag = default(Azure.ETag?), System.Collections.Generic.IEnumerable lastOutputEventTimestamps = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputWatermarkProperties watermarkSettings = null) { throw null; } + public static Azure.ResourceManager.StreamAnalytics.StreamingJobOutputData StreamingJobOutputData(Azure.Core.ResourceIdentifier id = null, string name = null, Azure.Core.ResourceType? resourceType = default(Azure.Core.ResourceType?), Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputDataSource datasource = null, System.TimeSpan? timeFrame = default(System.TimeSpan?), int? sizeWindow = default(int?), Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsDataSerialization serialization = null, System.Collections.Generic.IEnumerable diagnosticsConditions = null, Azure.ETag? etag = default(Azure.ETag?), System.Collections.Generic.IEnumerable lastOutputEventTimestamps = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputWatermarkProperties watermarkSettings = null) { throw null; } public static Azure.ResourceManager.StreamAnalytics.StreamingJobTransformationData StreamingJobTransformationData(Azure.Core.ResourceIdentifier id = null, string name = null, Azure.Core.ResourceType? resourceType = default(Azure.Core.ResourceType?), int? streamingUnits = default(int?), System.Collections.Generic.IEnumerable validStreamingUnits = null, string query = null, Azure.ETag? etag = default(Azure.ETag?)) { throw null; } public static Azure.ResourceManager.StreamAnalytics.Models.StreamInputProperties StreamInputProperties(Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsDataSerialization serialization = null, System.Collections.Generic.IEnumerable diagnosticsConditions = null, Azure.ETag? etag = default(Azure.ETag?), Azure.ResourceManager.StreamAnalytics.Models.StreamingCompressionType? compressionType = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingCompressionType?), string partitionKey = null, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobInputWatermarkMode? watermarkMode = default(Azure.ResourceManager.StreamAnalytics.Models.StreamingJobInputWatermarkMode?), Azure.ResourceManager.StreamAnalytics.Models.StreamInputDataSource datasource = null) { throw null; } } @@ -391,6 +396,14 @@ public partial class AvroFormatSerialization : Azure.ResourceManager.StreamAnaly public AvroFormatSerialization() { } public System.BinaryData Properties { get { throw null; } set { } } } + public partial class AzureDataExplorerOutputDataSource : Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputDataSource + { + public AzureDataExplorerOutputDataSource() { } + public Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsAuthenticationMode? AuthenticationMode { get { throw null; } set { } } + public string Cluster { get { throw null; } set { } } + public string Database { get { throw null; } set { } } + public string Table { get { throw null; } set { } } + } public partial class BlobOutputDataSource : Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputDataSource { public BlobOutputDataSource() { } @@ -498,8 +511,6 @@ public DataLakeStoreOutputDataSource() { } private readonly object _dummy; private readonly int _dummyPrimitive; public DataRefreshType(string value) { throw null; } - public static Azure.ResourceManager.StreamAnalytics.Models.DataRefreshType Blocking { get { throw null; } } - public static Azure.ResourceManager.StreamAnalytics.Models.DataRefreshType Nonblocking { get { throw null; } } public static Azure.ResourceManager.StreamAnalytics.Models.DataRefreshType RefreshPeriodicallyWithDelta { get { throw null; } } public static Azure.ResourceManager.StreamAnalytics.Models.DataRefreshType RefreshPeriodicallyWithFull { get { throw null; } } public static Azure.ResourceManager.StreamAnalytics.Models.DataRefreshType Static { get { throw null; } } @@ -513,6 +524,12 @@ public DataLakeStoreOutputDataSource() { } public static bool operator !=(Azure.ResourceManager.StreamAnalytics.Models.DataRefreshType left, Azure.ResourceManager.StreamAnalytics.Models.DataRefreshType right) { throw null; } public override string ToString() { throw null; } } + public partial class DeltaSerialization : Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsDataSerialization + { + public DeltaSerialization() { } + public string DeltaTablePath { get { throw null; } set { } } + public System.Collections.Generic.IList PartitionColumns { get { throw null; } } + } public partial class DocumentDbOutputDataSource : Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputDataSource { public DocumentDbOutputDataSource() { } @@ -625,6 +642,11 @@ public EventHubV2StreamInputDataSource() { } public static bool operator !=(Azure.ResourceManager.StreamAnalytics.Models.EventsOutOfOrderPolicy left, Azure.ResourceManager.StreamAnalytics.Models.EventsOutOfOrderPolicy right) { throw null; } public override string ToString() { throw null; } } + public partial class FileReferenceInputDataSource : Azure.ResourceManager.StreamAnalytics.Models.ReferenceInputDataSource + { + public FileReferenceInputDataSource() { } + public string Path { get { throw null; } set { } } + } public partial class FunctionOutputDataSource : Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputDataSource { public FunctionOutputDataSource() { } @@ -648,6 +670,13 @@ public partial class GatewayMessageBusStreamInputDataSource : Azure.ResourceMana public GatewayMessageBusStreamInputDataSource() { } public string Topic { get { throw null; } set { } } } + public partial class GetStreamingJobSkuResult + { + internal GetStreamingJobSkuResult() { } + public Azure.ResourceManager.StreamAnalytics.Models.SkuCapacity Capacity { get { throw null; } } + public Azure.ResourceManager.StreamAnalytics.Models.ResourceType? ResourceType { get { throw null; } } + public Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSkuName? SkuName { get { throw null; } } + } public partial class IoTHubStreamInputDataSource : Azure.ResourceManager.StreamAnalytics.Models.StreamInputDataSource { public IoTHubStreamInputDataSource() { } @@ -809,6 +838,23 @@ public partial class ReferenceInputProperties : Azure.ResourceManager.StreamAnal public ReferenceInputProperties() { } public Azure.ResourceManager.StreamAnalytics.Models.ReferenceInputDataSource Datasource { get { throw null; } set { } } } + [System.Runtime.InteropServices.StructLayoutAttribute(System.Runtime.InteropServices.LayoutKind.Sequential)] + public readonly partial struct ResourceType : System.IEquatable + { + private readonly object _dummy; + private readonly int _dummyPrimitive; + public ResourceType(string value) { throw null; } + public static Azure.ResourceManager.StreamAnalytics.Models.ResourceType MicrosoftStreamAnalyticsStreamingjobs { get { throw null; } } + public bool Equals(Azure.ResourceManager.StreamAnalytics.Models.ResourceType other) { throw null; } + [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)] + public override bool Equals(object obj) { throw null; } + [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)] + public override int GetHashCode() { throw null; } + public static bool operator ==(Azure.ResourceManager.StreamAnalytics.Models.ResourceType left, Azure.ResourceManager.StreamAnalytics.Models.ResourceType right) { throw null; } + public static implicit operator Azure.ResourceManager.StreamAnalytics.Models.ResourceType (string value) { throw null; } + public static bool operator !=(Azure.ResourceManager.StreamAnalytics.Models.ResourceType left, Azure.ResourceManager.StreamAnalytics.Models.ResourceType right) { throw null; } + public override string ToString() { throw null; } + } public partial class ScalarFunctionProperties : Azure.ResourceManager.StreamAnalytics.Models.StreamingJobFunctionProperties { public ScalarFunctionProperties() { } @@ -840,6 +886,34 @@ public ServiceBusTopicOutputDataSource() { } public System.Collections.Generic.IDictionary SystemPropertyColumns { get { throw null; } } public string TopicName { get { throw null; } set { } } } + public partial class SkuCapacity + { + internal SkuCapacity() { } + public System.Collections.Generic.IReadOnlyList AllowedValues { get { throw null; } } + public int? Default { get { throw null; } } + public int? Maximum { get { throw null; } } + public int? Minimum { get { throw null; } } + public Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType? ScaleType { get { throw null; } } + } + [System.Runtime.InteropServices.StructLayoutAttribute(System.Runtime.InteropServices.LayoutKind.Sequential)] + public readonly partial struct SkuCapacityScaleType : System.IEquatable + { + private readonly object _dummy; + private readonly int _dummyPrimitive; + public SkuCapacityScaleType(string value) { throw null; } + public static Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType Automatic { get { throw null; } } + public static Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType Manual { get { throw null; } } + public static Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType None { get { throw null; } } + public bool Equals(Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType other) { throw null; } + [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)] + public override bool Equals(object obj) { throw null; } + [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)] + public override int GetHashCode() { throw null; } + public static bool operator ==(Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType left, Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType right) { throw null; } + public static implicit operator Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType (string value) { throw null; } + public static bool operator !=(Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType left, Azure.ResourceManager.StreamAnalytics.Models.SkuCapacityScaleType right) { throw null; } + public override string ToString() { throw null; } + } public partial class SqlDatabaseOutputDataSource : Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputDataSource { public SqlDatabaseOutputDataSource() { } @@ -1122,6 +1196,12 @@ internal StreamAnalyticsSampleInputResult() { } public static bool operator !=(Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSampleInputResultStatus left, Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSampleInputResultStatus right) { throw null; } public override string ToString() { throw null; } } + public partial class StreamAnalyticsSku + { + public StreamAnalyticsSku() { } + public int? Capacity { get { throw null; } set { } } + public Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSkuName? Name { get { throw null; } set { } } + } [System.Runtime.InteropServices.StructLayoutAttribute(System.Runtime.InteropServices.LayoutKind.Sequential)] public readonly partial struct StreamAnalyticsSkuName : System.IEquatable { @@ -1427,7 +1507,7 @@ public StreamingJobRefreshConfiguration() { } public string DateFormat { get { throw null; } set { } } public string PathPattern { get { throw null; } set { } } public string RefreshInterval { get { throw null; } set { } } - public Azure.ResourceManager.StreamAnalytics.Models.DataRefreshType? RefreshType { get { throw null; } set { } } + public Azure.ResourceManager.StreamAnalytics.Models.UpdatableUdfRefreshType? RefreshType { get { throw null; } set { } } public string TimeFormat { get { throw null; } set { } } } [System.Runtime.InteropServices.StructLayoutAttribute(System.Runtime.InteropServices.LayoutKind.Sequential)] @@ -1508,4 +1588,22 @@ public TableOutputDataSource() { } public string RowKey { get { throw null; } set { } } public string Table { get { throw null; } set { } } } + [System.Runtime.InteropServices.StructLayoutAttribute(System.Runtime.InteropServices.LayoutKind.Sequential)] + public readonly partial struct UpdatableUdfRefreshType : System.IEquatable + { + private readonly object _dummy; + private readonly int _dummyPrimitive; + public UpdatableUdfRefreshType(string value) { throw null; } + public static Azure.ResourceManager.StreamAnalytics.Models.UpdatableUdfRefreshType Blocking { get { throw null; } } + public static Azure.ResourceManager.StreamAnalytics.Models.UpdatableUdfRefreshType Nonblocking { get { throw null; } } + public bool Equals(Azure.ResourceManager.StreamAnalytics.Models.UpdatableUdfRefreshType other) { throw null; } + [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)] + public override bool Equals(object obj) { throw null; } + [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)] + public override int GetHashCode() { throw null; } + public static bool operator ==(Azure.ResourceManager.StreamAnalytics.Models.UpdatableUdfRefreshType left, Azure.ResourceManager.StreamAnalytics.Models.UpdatableUdfRefreshType right) { throw null; } + public static implicit operator Azure.ResourceManager.StreamAnalytics.Models.UpdatableUdfRefreshType (string value) { throw null; } + public static bool operator !=(Azure.ResourceManager.StreamAnalytics.Models.UpdatableUdfRefreshType left, Azure.ResourceManager.StreamAnalytics.Models.UpdatableUdfRefreshType right) { throw null; } + public override string ToString() { throw null; } + } } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/ArmStreamAnalyticsModelFactory.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/ArmStreamAnalyticsModelFactory.cs index 98e10a1efce2..484373d5d6eb 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/ArmStreamAnalyticsModelFactory.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/ArmStreamAnalyticsModelFactory.cs @@ -28,7 +28,7 @@ public static partial class ArmStreamAnalyticsModelFactory /// The available derived classes include and . /// /// A new instance for mocking. - public static StreamingJobFunctionData StreamingJobFunctionData(ResourceIdentifier id = null, string name = null, ResourceType? resourceType = null, StreamingJobFunctionProperties properties = null) + public static StreamingJobFunctionData StreamingJobFunctionData(ResourceIdentifier id = null, string name = null, Core.ResourceType? resourceType = null, StreamingJobFunctionProperties properties = null) { return new StreamingJobFunctionData(id, name, resourceType, properties); } @@ -56,7 +56,7 @@ public static StreamingJobFunctionProperties StreamingJobFunctionProperties(stri /// Resource name. /// Resource type. /// A new instance for mocking. - public static StreamAnalyticsSubResource StreamAnalyticsSubResource(ResourceIdentifier id = null, string name = null, ResourceType? resourceType = null) + public static StreamAnalyticsSubResource StreamAnalyticsSubResource(ResourceIdentifier id = null, string name = null, Core.ResourceType? resourceType = null) { return new StreamAnalyticsSubResource(id, name, resourceType); } @@ -104,7 +104,7 @@ public static StreamAnalyticsResourceTestStatus StreamAnalyticsResourceTestStatu /// The available derived classes include and . /// /// A new instance for mocking. - public static StreamingJobInputData StreamingJobInputData(ResourceIdentifier id = null, string name = null, ResourceType? resourceType = null, StreamingJobInputProperties properties = null) + public static StreamingJobInputData StreamingJobInputData(ResourceIdentifier id = null, string name = null, Core.ResourceType? resourceType = null, StreamingJobInputProperties properties = null) { return new StreamingJobInputData(id, name, resourceType, properties); } @@ -114,7 +114,7 @@ public static StreamingJobInputData StreamingJobInputData(ResourceIdentifier id /// /// Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// /// Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention. /// The current entity tag for the input. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. @@ -146,21 +146,21 @@ public static StreamingJobDiagnosticCondition StreamingJobDiagnosticCondition(Da /// /// Describes the data source that output will be written to. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , , , , , , , , , , , and . + /// The available derived classes include , , , , , , , , , , , , , , and . /// /// The time frame for filtering Stream Analytics job outputs. /// The size window to constrain a Stream Analytics output to. /// /// Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// /// Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention. /// The current entity tag for the output. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. /// A list of the last output event times for each output partition. The index of the array corresponds to the partition number. /// Settings which determine whether to send watermarks to downstream. /// A new instance for mocking. - public static StreamingJobOutputData StreamingJobOutputData(ResourceIdentifier id = null, string name = null, ResourceType? resourceType = null, StreamingJobOutputDataSource datasource = null, TimeSpan? timeFrame = null, float? sizeWindow = null, StreamAnalyticsDataSerialization serialization = null, IEnumerable diagnosticsConditions = null, ETag? etag = null, IEnumerable lastOutputEventTimestamps = null, StreamingJobOutputWatermarkProperties watermarkSettings = null) + public static StreamingJobOutputData StreamingJobOutputData(ResourceIdentifier id = null, string name = null, Core.ResourceType? resourceType = null, StreamingJobOutputDataSource datasource = null, TimeSpan? timeFrame = null, int? sizeWindow = null, StreamAnalyticsDataSerialization serialization = null, IEnumerable diagnosticsConditions = null, ETag? etag = null, IEnumerable lastOutputEventTimestamps = null, StreamingJobOutputWatermarkProperties watermarkSettings = null) { diagnosticsConditions ??= new List(); lastOutputEventTimestamps ??= new List(); @@ -184,8 +184,9 @@ public static LastOutputEventTimestamp LastOutputEventTimestamp(DateTimeOffset? /// The systemData. /// The tags. /// The location. + /// Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests. /// Describes the managed identity assigned to this job that can be used to authenticate with inputs and outputs. Current supported identity types: SystemAssigned, UserAssigned, SystemAssigned,UserAssigned. - /// Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests. + /// Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests. /// A GUID uniquely identifying the streaming job. This GUID is generated upon creation of the streaming job. /// Describes the provisioning status of the streaming job. /// Describes the state of the streaming job. @@ -210,14 +211,14 @@ public static LastOutputEventTimestamp LastOutputEventTimestamp(DateTimeOffset? /// The storage account where the custom code artifacts are located. /// The cluster which streaming jobs will run on. /// A new instance for mocking. - public static StreamingJobData StreamingJobData(ResourceIdentifier id = null, string name = null, ResourceType resourceType = default, SystemData systemData = null, IDictionary tags = null, AzureLocation location = default, ManagedServiceIdentity identity = null, StreamAnalyticsSkuName? skuName = null, Guid? jobId = null, string provisioningState = null, string jobState = null, StreamingJobType? jobType = null, StreamingJobOutputStartMode? outputStartMode = null, DateTimeOffset? outputStartOn = null, DateTimeOffset? lastOutputEventOn = null, EventsOutOfOrderPolicy? eventsOutOfOrderPolicy = null, StreamingJobOutputErrorPolicy? outputErrorPolicy = null, int? eventsOutOfOrderMaxDelayInSeconds = null, int? eventsLateArrivalMaxDelayInSeconds = null, AzureLocation? dataLocalion = null, StreamingJobCompatibilityLevel? compatibilityLevel = null, DateTimeOffset? createdOn = null, IEnumerable inputs = null, StreamingJobTransformationData transformation = null, IEnumerable outputs = null, IEnumerable functions = null, ETag? etag = null, StreamingJobStorageAccount jobStorageAccount = null, StreamingJobContentStoragePolicy? contentStoragePolicy = null, StreamingJobExternal externals = null, ResourceIdentifier clusterId = null) + public static StreamingJobData StreamingJobData(ResourceIdentifier id = null, string name = null, Core.ResourceType resourceType = default, SystemData systemData = null, IDictionary tags = null, AzureLocation location = default, StreamAnalyticsSku sku = null, ManagedServiceIdentity identity = null, StreamAnalyticsSku skuPropertiesSku = null, Guid? jobId = null, string provisioningState = null, string jobState = null, StreamingJobType? jobType = null, StreamingJobOutputStartMode? outputStartMode = null, DateTimeOffset? outputStartOn = null, DateTimeOffset? lastOutputEventOn = null, EventsOutOfOrderPolicy? eventsOutOfOrderPolicy = null, StreamingJobOutputErrorPolicy? outputErrorPolicy = null, int? eventsOutOfOrderMaxDelayInSeconds = null, int? eventsLateArrivalMaxDelayInSeconds = null, AzureLocation? dataLocalion = null, StreamingJobCompatibilityLevel? compatibilityLevel = null, DateTimeOffset? createdOn = null, IEnumerable inputs = null, StreamingJobTransformationData transformation = null, IEnumerable outputs = null, IEnumerable functions = null, ETag? etag = null, StreamingJobStorageAccount jobStorageAccount = null, StreamingJobContentStoragePolicy? contentStoragePolicy = null, StreamingJobExternal externals = null, ResourceIdentifier clusterId = null) { tags ??= new Dictionary(); inputs ??= new List(); outputs ??= new List(); functions ??= new List(); - return new StreamingJobData(id, name, resourceType, systemData, tags, location, identity, skuName != null ? new StreamAnalyticsSku(skuName) : null, jobId, provisioningState, jobState, jobType, outputStartMode, outputStartOn, lastOutputEventOn, eventsOutOfOrderPolicy, outputErrorPolicy, eventsOutOfOrderMaxDelayInSeconds, eventsLateArrivalMaxDelayInSeconds, dataLocalion, compatibilityLevel, createdOn, inputs?.ToList(), transformation, outputs?.ToList(), functions?.ToList(), etag, jobStorageAccount, contentStoragePolicy, externals, clusterId != null ? new ClusterInfo(clusterId) : null); + return new StreamingJobData(id, name, resourceType, systemData, tags, location, sku, identity, skuPropertiesSku, jobId, provisioningState, jobState, jobType, outputStartMode, outputStartOn, lastOutputEventOn, eventsOutOfOrderPolicy, outputErrorPolicy, eventsOutOfOrderMaxDelayInSeconds, eventsLateArrivalMaxDelayInSeconds, dataLocalion, compatibilityLevel, createdOn, inputs?.ToList(), transformation, outputs?.ToList(), functions?.ToList(), etag, jobStorageAccount, contentStoragePolicy, externals, clusterId != null ? new ClusterInfo(clusterId) : null); } /// Initializes a new instance of StreamingJobTransformationData. @@ -229,13 +230,37 @@ public static StreamingJobData StreamingJobData(ResourceIdentifier id = null, st /// Specifies the query that will be run in the streaming job. You can learn more about the Stream Analytics Query Language (SAQL) here: https://msdn.microsoft.com/library/azure/dn834998 . Required on PUT (CreateOrReplace) requests. /// The current entity tag for the transformation. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. /// A new instance for mocking. - public static StreamingJobTransformationData StreamingJobTransformationData(ResourceIdentifier id = null, string name = null, ResourceType? resourceType = null, int? streamingUnits = null, IEnumerable validStreamingUnits = null, string query = null, ETag? etag = null) + public static StreamingJobTransformationData StreamingJobTransformationData(ResourceIdentifier id = null, string name = null, Core.ResourceType? resourceType = null, int? streamingUnits = null, IEnumerable validStreamingUnits = null, string query = null, ETag? etag = null) { validStreamingUnits ??= new List(); return new StreamingJobTransformationData(id, name, resourceType, streamingUnits, validStreamingUnits?.ToList(), query, etag); } + /// Initializes a new instance of GetStreamingJobSkuResult. + /// The type of resource the SKU applies to. + /// The properties that are associated with a SKU. + /// Describes scaling information of a SKU. + /// A new instance for mocking. + public static GetStreamingJobSkuResult GetStreamingJobSkuResult(ResourceType? resourceType = null, StreamAnalyticsSkuName? skuName = null, SkuCapacity capacity = null) + { + return new GetStreamingJobSkuResult(resourceType, skuName != null ? new GetStreamingJobSkuResultSku(skuName) : null, capacity); + } + + /// Initializes a new instance of SkuCapacity. + /// Specifies the minimum streaming units that the streaming job can use. + /// Specifies the maximum streaming units that the streaming job can use. + /// Specifies the default streaming units that the streaming job can use. + /// The scale type applicable to the SKU. + /// Specifies the valid streaming units a streaming job can scale to. + /// A new instance for mocking. + public static SkuCapacity SkuCapacity(int? minimum = null, int? maximum = null, int? @default = null, SkuCapacityScaleType? scaleType = null, IEnumerable allowedValues = null) + { + allowedValues ??= new List(); + + return new SkuCapacity(minimum, maximum, @default, scaleType, allowedValues?.ToList()); + } + /// Initializes a new instance of StreamAnalyticsSubscriptionQuota. /// Resource Id. /// Resource name. @@ -243,7 +268,7 @@ public static StreamingJobTransformationData StreamingJobTransformationData(Reso /// The max permitted usage of this resource. /// The current usage of this resource. /// A new instance for mocking. - public static StreamAnalyticsSubscriptionQuota StreamAnalyticsSubscriptionQuota(ResourceIdentifier id = null, string name = null, ResourceType? resourceType = null, int? maxCount = null, int? currentCount = null) + public static StreamAnalyticsSubscriptionQuota StreamAnalyticsSubscriptionQuota(ResourceIdentifier id = null, string name = null, Core.ResourceType? resourceType = null, int? maxCount = null, int? currentCount = null) { return new StreamAnalyticsSubscriptionQuota(id, name, resourceType, maxCount, currentCount); } @@ -337,7 +362,7 @@ public static StreamAnalyticsTestDatasourceResult StreamAnalyticsTestDatasourceR /// The current entity tag for the cluster. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. /// The properties associated with a Stream Analytics cluster. /// A new instance for mocking. - public static StreamAnalyticsClusterData StreamAnalyticsClusterData(ResourceIdentifier id = null, string name = null, ResourceType resourceType = default, SystemData systemData = null, IDictionary tags = null, AzureLocation location = default, StreamAnalyticsClusterSku sku = null, ETag? etag = null, StreamAnalyticsClusterProperties properties = null) + public static StreamAnalyticsClusterData StreamAnalyticsClusterData(ResourceIdentifier id = null, string name = null, Core.ResourceType resourceType = default, SystemData systemData = null, IDictionary tags = null, AzureLocation location = default, StreamAnalyticsClusterSku sku = null, ETag? etag = null, StreamAnalyticsClusterProperties properties = null) { tags ??= new Dictionary(); @@ -374,7 +399,7 @@ public static StreamAnalyticsClusterJob StreamAnalyticsClusterJob(ResourceIdenti /// The properties associated with a private endpoint. /// Unique opaque string (generally a GUID) that represents the metadata state of the resource (private endpoint) and changes whenever the resource is updated. Required on PUT (CreateOrUpdate) requests. /// A new instance for mocking. - public static StreamAnalyticsPrivateEndpointData StreamAnalyticsPrivateEndpointData(ResourceIdentifier id = null, string name = null, ResourceType resourceType = default, SystemData systemData = null, StreamAnalyticsPrivateEndpointProperties properties = null, ETag? etag = null) + public static StreamAnalyticsPrivateEndpointData StreamAnalyticsPrivateEndpointData(ResourceIdentifier id = null, string name = null, Core.ResourceType resourceType = default, SystemData systemData = null, StreamAnalyticsPrivateEndpointProperties properties = null, ETag? etag = null) { return new StreamAnalyticsPrivateEndpointData(id, name, resourceType, systemData, properties, etag); } @@ -451,7 +476,7 @@ public static AggregateFunctionProperties AggregateFunctionProperties(ETag? etag /// /// Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// /// Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention. /// The current entity tag for the input. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. @@ -475,7 +500,7 @@ public static StreamInputProperties StreamInputProperties(StreamAnalyticsDataSer /// /// Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// /// Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention. /// The current entity tag for the input. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. @@ -485,7 +510,7 @@ public static StreamInputProperties StreamInputProperties(StreamAnalyticsDataSer /// /// Describes an input data source that contains reference data. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , and . + /// The available derived classes include , , and . /// /// A new instance for mocking. public static ReferenceInputProperties ReferenceInputProperties(StreamAnalyticsDataSerialization serialization = null, IEnumerable diagnosticsConditions = null, ETag? etag = null, StreamingCompressionType? compressionType = null, string partitionKey = null, StreamingJobInputWatermarkMode? watermarkMode = null, ReferenceInputDataSource datasource = null) diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Extensions/SubscriptionResourceExtensionClient.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Extensions/SubscriptionResourceExtensionClient.cs index 79474e5d154d..456331a15e82 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Extensions/SubscriptionResourceExtensionClient.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Extensions/SubscriptionResourceExtensionClient.cs @@ -45,7 +45,7 @@ internal SubscriptionResourceExtensionClient(ArmClient client, ResourceIdentifie private ClientDiagnostics StreamAnalyticsClusterClustersClientDiagnostics => _streamAnalyticsClusterClustersClientDiagnostics ??= new ClientDiagnostics("Azure.ResourceManager.StreamAnalytics", StreamAnalyticsClusterResource.ResourceType.Namespace, Diagnostics); private ClustersRestOperations StreamAnalyticsClusterClustersRestClient => _streamAnalyticsClusterClustersRestClient ??= new ClustersRestOperations(Pipeline, Diagnostics.ApplicationId, Endpoint, GetApiVersionOrNull(StreamAnalyticsClusterResource.ResourceType)); - private string GetApiVersionOrNull(ResourceType resourceType) + private string GetApiVersionOrNull(Core.ResourceType resourceType) { TryGetApiVersion(resourceType, out string apiVersion); return apiVersion; diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/AzureDataExplorerOutputDataSource.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/AzureDataExplorerOutputDataSource.Serialization.cs new file mode 100644 index 000000000000..06c64740dc33 --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/AzureDataExplorerOutputDataSource.Serialization.cs @@ -0,0 +1,104 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System.Text.Json; +using Azure.Core; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + public partial class AzureDataExplorerOutputDataSource : IUtf8JsonSerializable + { + void IUtf8JsonSerializable.Write(Utf8JsonWriter writer) + { + writer.WriteStartObject(); + writer.WritePropertyName("type"u8); + writer.WriteStringValue(OutputDataSourceType); + writer.WritePropertyName("properties"u8); + writer.WriteStartObject(); + if (Optional.IsDefined(Cluster)) + { + writer.WritePropertyName("cluster"u8); + writer.WriteStringValue(Cluster); + } + if (Optional.IsDefined(Database)) + { + writer.WritePropertyName("database"u8); + writer.WriteStringValue(Database); + } + if (Optional.IsDefined(Table)) + { + writer.WritePropertyName("table"u8); + writer.WriteStringValue(Table); + } + if (Optional.IsDefined(AuthenticationMode)) + { + writer.WritePropertyName("authenticationMode"u8); + writer.WriteStringValue(AuthenticationMode.Value.ToString()); + } + writer.WriteEndObject(); + writer.WriteEndObject(); + } + + internal static AzureDataExplorerOutputDataSource DeserializeAzureDataExplorerOutputDataSource(JsonElement element) + { + if (element.ValueKind == JsonValueKind.Null) + { + return null; + } + string type = default; + Optional cluster = default; + Optional database = default; + Optional table = default; + Optional authenticationMode = default; + foreach (var property in element.EnumerateObject()) + { + if (property.NameEquals("type"u8)) + { + type = property.Value.GetString(); + continue; + } + if (property.NameEquals("properties"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + property.ThrowNonNullablePropertyIsNull(); + continue; + } + foreach (var property0 in property.Value.EnumerateObject()) + { + if (property0.NameEquals("cluster"u8)) + { + cluster = property0.Value.GetString(); + continue; + } + if (property0.NameEquals("database"u8)) + { + database = property0.Value.GetString(); + continue; + } + if (property0.NameEquals("table"u8)) + { + table = property0.Value.GetString(); + continue; + } + if (property0.NameEquals("authenticationMode"u8)) + { + if (property0.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + authenticationMode = new StreamAnalyticsAuthenticationMode(property0.Value.GetString()); + continue; + } + } + continue; + } + } + return new AzureDataExplorerOutputDataSource(type, cluster.Value, database.Value, table.Value, Optional.ToNullable(authenticationMode)); + } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/AzureDataExplorerOutputDataSource.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/AzureDataExplorerOutputDataSource.cs new file mode 100644 index 000000000000..1e3634a4428e --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/AzureDataExplorerOutputDataSource.cs @@ -0,0 +1,43 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + /// Describes an Azure Data Explorer output data source. + public partial class AzureDataExplorerOutputDataSource : StreamingJobOutputDataSource + { + /// Initializes a new instance of AzureDataExplorerOutputDataSource. + public AzureDataExplorerOutputDataSource() + { + OutputDataSourceType = "Microsoft.Kusto/clusters/databases"; + } + + /// Initializes a new instance of AzureDataExplorerOutputDataSource. + /// Indicates the type of data source output will be written to. Required on PUT (CreateOrReplace) requests. + /// The name of the Azure Data Explorer cluster. Required on PUT (CreateOrReplace) requests. + /// The name of the Azure Data Explorer database. Required on PUT (CreateOrReplace) requests. + /// The name of the Azure Table. Required on PUT (CreateOrReplace) requests. + /// Authentication Mode. + internal AzureDataExplorerOutputDataSource(string outputDataSourceType, string cluster, string database, string table, StreamAnalyticsAuthenticationMode? authenticationMode) : base(outputDataSourceType) + { + Cluster = cluster; + Database = database; + Table = table; + AuthenticationMode = authenticationMode; + OutputDataSourceType = outputDataSourceType ?? "Microsoft.Kusto/clusters/databases"; + } + + /// The name of the Azure Data Explorer cluster. Required on PUT (CreateOrReplace) requests. + public string Cluster { get; set; } + /// The name of the Azure Data Explorer database. Required on PUT (CreateOrReplace) requests. + public string Database { get; set; } + /// The name of the Azure Table. Required on PUT (CreateOrReplace) requests. + public string Table { get; set; } + /// Authentication Mode. + public StreamAnalyticsAuthenticationMode? AuthenticationMode { get; set; } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/DataRefreshType.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/DataRefreshType.cs index 2189e878fb96..073952f1a220 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/DataRefreshType.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/DataRefreshType.cs @@ -25,8 +25,6 @@ public DataRefreshType(string value) private const string StaticValue = "Static"; private const string RefreshPeriodicallyWithFullValue = "RefreshPeriodicallyWithFull"; private const string RefreshPeriodicallyWithDeltaValue = "RefreshPeriodicallyWithDelta"; - private const string BlockingValue = "Blocking"; - private const string NonblockingValue = "Nonblocking"; /// Static. public static DataRefreshType Static { get; } = new DataRefreshType(StaticValue); @@ -34,10 +32,6 @@ public DataRefreshType(string value) public static DataRefreshType RefreshPeriodicallyWithFull { get; } = new DataRefreshType(RefreshPeriodicallyWithFullValue); /// RefreshPeriodicallyWithDelta. public static DataRefreshType RefreshPeriodicallyWithDelta { get; } = new DataRefreshType(RefreshPeriodicallyWithDeltaValue); - /// Blocking. - public static DataRefreshType Blocking { get; } = new DataRefreshType(BlockingValue); - /// Nonblocking. - public static DataRefreshType Nonblocking { get; } = new DataRefreshType(NonblockingValue); /// Determines if two values are the same. public static bool operator ==(DataRefreshType left, DataRefreshType right) => left.Equals(right); /// Determines if two values are not the same. diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/DeltaSerialization.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/DeltaSerialization.Serialization.cs new file mode 100644 index 000000000000..99a129c60608 --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/DeltaSerialization.Serialization.cs @@ -0,0 +1,93 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System.Collections.Generic; +using System.Text.Json; +using Azure.Core; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + public partial class DeltaSerialization : IUtf8JsonSerializable + { + void IUtf8JsonSerializable.Write(Utf8JsonWriter writer) + { + writer.WriteStartObject(); + writer.WritePropertyName("type"u8); + writer.WriteStringValue(EventSerializationType.ToString()); + writer.WritePropertyName("properties"u8); + writer.WriteStartObject(); + if (Optional.IsDefined(DeltaTablePath)) + { + writer.WritePropertyName("deltaTablePath"u8); + writer.WriteStringValue(DeltaTablePath); + } + if (Optional.IsCollectionDefined(PartitionColumns)) + { + writer.WritePropertyName("partitionColumns"u8); + writer.WriteStartArray(); + foreach (var item in PartitionColumns) + { + writer.WriteStringValue(item); + } + writer.WriteEndArray(); + } + writer.WriteEndObject(); + writer.WriteEndObject(); + } + + internal static DeltaSerialization DeserializeDeltaSerialization(JsonElement element) + { + if (element.ValueKind == JsonValueKind.Null) + { + return null; + } + EventSerializationType type = default; + Optional deltaTablePath = default; + Optional> partitionColumns = default; + foreach (var property in element.EnumerateObject()) + { + if (property.NameEquals("type"u8)) + { + type = new EventSerializationType(property.Value.GetString()); + continue; + } + if (property.NameEquals("properties"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + property.ThrowNonNullablePropertyIsNull(); + continue; + } + foreach (var property0 in property.Value.EnumerateObject()) + { + if (property0.NameEquals("deltaTablePath"u8)) + { + deltaTablePath = property0.Value.GetString(); + continue; + } + if (property0.NameEquals("partitionColumns"u8)) + { + if (property0.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + List array = new List(); + foreach (var item in property0.Value.EnumerateArray()) + { + array.Add(item.GetString()); + } + partitionColumns = array; + continue; + } + } + continue; + } + } + return new DeltaSerialization(type, deltaTablePath.Value, Optional.ToList(partitionColumns)); + } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/DeltaSerialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/DeltaSerialization.cs new file mode 100644 index 000000000000..588877ca766f --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/DeltaSerialization.cs @@ -0,0 +1,39 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System.Collections.Generic; +using Azure.Core; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + /// Describes how data from an input is serialized or how data is serialized when written to an output in Delta Lake format. + public partial class DeltaSerialization : StreamAnalyticsDataSerialization + { + /// Initializes a new instance of DeltaSerialization. + public DeltaSerialization() + { + PartitionColumns = new ChangeTrackingList(); + EventSerializationType = EventSerializationType.Delta; + } + + /// Initializes a new instance of DeltaSerialization. + /// Indicates the type of serialization that the input or output uses. Required on PUT (CreateOrReplace) requests. + /// Specifies the path of the Delta Lake table that the output will be written to. + /// Specifies the names of the columns for which the Delta Lake table will be partitioned. We are only supporting 1 partition column, but keeping it as an array for extensibility. + internal DeltaSerialization(EventSerializationType eventSerializationType, string deltaTablePath, IList partitionColumns) : base(eventSerializationType) + { + DeltaTablePath = deltaTablePath; + PartitionColumns = partitionColumns; + EventSerializationType = eventSerializationType; + } + + /// Specifies the path of the Delta Lake table that the output will be written to. + public string DeltaTablePath { get; set; } + /// Specifies the names of the columns for which the Delta Lake table will be partitioned. We are only supporting 1 partition column, but keeping it as an array for extensibility. + public IList PartitionColumns { get; } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/EventSerializationType.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/EventSerializationType.cs index 5df0952d0fe3..3782196ec568 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/EventSerializationType.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/EventSerializationType.cs @@ -27,6 +27,7 @@ public EventSerializationType(string value) private const string JsonValue = "Json"; private const string CustomClrValue = "CustomClr"; private const string ParquetValue = "Parquet"; + private const string DeltaValue = "Delta"; /// Csv. public static EventSerializationType Csv { get; } = new EventSerializationType(CsvValue); @@ -38,6 +39,8 @@ public EventSerializationType(string value) public static EventSerializationType CustomClr { get; } = new EventSerializationType(CustomClrValue); /// Parquet. public static EventSerializationType Parquet { get; } = new EventSerializationType(ParquetValue); + /// Delta. + public static EventSerializationType Delta { get; } = new EventSerializationType(DeltaValue); /// Determines if two values are the same. public static bool operator ==(EventSerializationType left, EventSerializationType right) => left.Equals(right); /// Determines if two values are not the same. diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/FileReferenceInputDataSource.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/FileReferenceInputDataSource.Serialization.cs new file mode 100644 index 000000000000..19fa70b7a9ff --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/FileReferenceInputDataSource.Serialization.cs @@ -0,0 +1,67 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System.Text.Json; +using Azure.Core; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + public partial class FileReferenceInputDataSource : IUtf8JsonSerializable + { + void IUtf8JsonSerializable.Write(Utf8JsonWriter writer) + { + writer.WriteStartObject(); + writer.WritePropertyName("type"u8); + writer.WriteStringValue(ReferenceInputDataSourceType); + writer.WritePropertyName("properties"u8); + writer.WriteStartObject(); + if (Optional.IsDefined(Path)) + { + writer.WritePropertyName("path"u8); + writer.WriteStringValue(Path); + } + writer.WriteEndObject(); + writer.WriteEndObject(); + } + + internal static FileReferenceInputDataSource DeserializeFileReferenceInputDataSource(JsonElement element) + { + if (element.ValueKind == JsonValueKind.Null) + { + return null; + } + string type = default; + Optional path = default; + foreach (var property in element.EnumerateObject()) + { + if (property.NameEquals("type"u8)) + { + type = property.Value.GetString(); + continue; + } + if (property.NameEquals("properties"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + property.ThrowNonNullablePropertyIsNull(); + continue; + } + foreach (var property0 in property.Value.EnumerateObject()) + { + if (property0.NameEquals("path"u8)) + { + path = property0.Value.GetString(); + continue; + } + } + continue; + } + } + return new FileReferenceInputDataSource(type, path.Value); + } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/FileReferenceInputDataSource.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/FileReferenceInputDataSource.cs new file mode 100644 index 000000000000..c987e86f8529 --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/FileReferenceInputDataSource.cs @@ -0,0 +1,31 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + /// Describes a file input data source that contains reference data. + public partial class FileReferenceInputDataSource : ReferenceInputDataSource + { + /// Initializes a new instance of FileReferenceInputDataSource. + public FileReferenceInputDataSource() + { + ReferenceInputDataSourceType = "File"; + } + + /// Initializes a new instance of FileReferenceInputDataSource. + /// Indicates the type of input data source containing reference data. Required on PUT (CreateOrReplace) requests. + /// The path of the file. + internal FileReferenceInputDataSource(string referenceInputDataSourceType, string path) : base(referenceInputDataSourceType) + { + Path = path; + ReferenceInputDataSourceType = referenceInputDataSourceType ?? "File"; + } + + /// The path of the file. + public string Path { get; set; } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResult.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResult.Serialization.cs new file mode 100644 index 000000000000..2dc97b2004ec --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResult.Serialization.cs @@ -0,0 +1,57 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System.Text.Json; +using Azure.Core; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + public partial class GetStreamingJobSkuResult + { + internal static GetStreamingJobSkuResult DeserializeGetStreamingJobSkuResult(JsonElement element) + { + if (element.ValueKind == JsonValueKind.Null) + { + return null; + } + Optional resourceType = default; + Optional sku = default; + Optional capacity = default; + foreach (var property in element.EnumerateObject()) + { + if (property.NameEquals("resourceType"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + resourceType = new ResourceType(property.Value.GetString()); + continue; + } + if (property.NameEquals("sku"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + sku = GetStreamingJobSkuResultSku.DeserializeGetStreamingJobSkuResultSku(property.Value); + continue; + } + if (property.NameEquals("capacity"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + capacity = SkuCapacity.DeserializeSkuCapacity(property.Value); + continue; + } + } + return new GetStreamingJobSkuResult(Optional.ToNullable(resourceType), sku.Value, capacity.Value); + } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResult.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResult.cs new file mode 100644 index 000000000000..5eac502ff9b2 --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResult.cs @@ -0,0 +1,42 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + /// Describes an available SKU information. + public partial class GetStreamingJobSkuResult + { + /// Initializes a new instance of GetStreamingJobSkuResult. + internal GetStreamingJobSkuResult() + { + } + + /// Initializes a new instance of GetStreamingJobSkuResult. + /// The type of resource the SKU applies to. + /// The properties that are associated with a SKU. + /// Describes scaling information of a SKU. + internal GetStreamingJobSkuResult(ResourceType? resourceType, GetStreamingJobSkuResultSku sku, SkuCapacity capacity) + { + ResourceType = resourceType; + Sku = sku; + Capacity = capacity; + } + + /// The type of resource the SKU applies to. + public ResourceType? ResourceType { get; } + /// The properties that are associated with a SKU. + internal GetStreamingJobSkuResultSku Sku { get; } + /// The name of the SKU. + public StreamAnalyticsSkuName? SkuName + { + get => Sku?.Name; + } + + /// Describes scaling information of a SKU. + public SkuCapacity Capacity { get; } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResultSku.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResultSku.Serialization.cs new file mode 100644 index 000000000000..705e2a46daea --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResultSku.Serialization.cs @@ -0,0 +1,37 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System.Text.Json; +using Azure.Core; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + internal partial class GetStreamingJobSkuResultSku + { + internal static GetStreamingJobSkuResultSku DeserializeGetStreamingJobSkuResultSku(JsonElement element) + { + if (element.ValueKind == JsonValueKind.Null) + { + return null; + } + Optional name = default; + foreach (var property in element.EnumerateObject()) + { + if (property.NameEquals("name"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + name = new StreamAnalyticsSkuName(property.Value.GetString()); + continue; + } + } + return new GetStreamingJobSkuResultSku(Optional.ToNullable(name)); + } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResultSku.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResultSku.cs new file mode 100644 index 000000000000..a93522b30bce --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResultSku.cs @@ -0,0 +1,28 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + /// The properties that are associated with a SKU. + internal partial class GetStreamingJobSkuResultSku + { + /// Initializes a new instance of GetStreamingJobSkuResultSku. + internal GetStreamingJobSkuResultSku() + { + } + + /// Initializes a new instance of GetStreamingJobSkuResultSku. + /// The name of the SKU. + internal GetStreamingJobSkuResultSku(StreamAnalyticsSkuName? name) + { + Name = name; + } + + /// The name of the SKU. + public StreamAnalyticsSkuName? Name { get; } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResults.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResults.Serialization.cs new file mode 100644 index 000000000000..2252ed3e9897 --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResults.Serialization.cs @@ -0,0 +1,49 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System.Collections.Generic; +using System.Text.Json; +using Azure.Core; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + internal partial class GetStreamingJobSkuResults + { + internal static GetStreamingJobSkuResults DeserializeGetStreamingJobSkuResults(JsonElement element) + { + if (element.ValueKind == JsonValueKind.Null) + { + return null; + } + Optional> value = default; + Optional nextLink = default; + foreach (var property in element.EnumerateObject()) + { + if (property.NameEquals("value"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + List array = new List(); + foreach (var item in property.Value.EnumerateArray()) + { + array.Add(GetStreamingJobSkuResult.DeserializeGetStreamingJobSkuResult(item)); + } + value = array; + continue; + } + if (property.NameEquals("nextLink"u8)) + { + nextLink = property.Value.GetString(); + continue; + } + } + return new GetStreamingJobSkuResults(Optional.ToList(value), nextLink.Value); + } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResults.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResults.cs new file mode 100644 index 000000000000..8a0576c5fadb --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/GetStreamingJobSkuResults.cs @@ -0,0 +1,36 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System.Collections.Generic; +using Azure.Core; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + /// Result of the request to get streaming job SKUs. + internal partial class GetStreamingJobSkuResults + { + /// Initializes a new instance of GetStreamingJobSkuResults. + internal GetStreamingJobSkuResults() + { + Value = new ChangeTrackingList(); + } + + /// Initializes a new instance of GetStreamingJobSkuResults. + /// The list of available SKUs that the streaming job can use. + /// The link (url) to the next page of results. + internal GetStreamingJobSkuResults(IReadOnlyList value, string nextLink) + { + Value = value; + NextLink = nextLink; + } + + /// The list of available SKUs that the streaming job can use. + public IReadOnlyList Value { get; } + /// The link (url) to the next page of results. + public string NextLink { get; } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputDataSource.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputDataSource.Serialization.cs index bf1d0e277018..b424bfeee6ad 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputDataSource.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputDataSource.Serialization.cs @@ -30,6 +30,7 @@ internal static ReferenceInputDataSource DeserializeReferenceInputDataSource(Jso { switch (discriminator.GetString()) { + case "File": return FileReferenceInputDataSource.DeserializeFileReferenceInputDataSource(element); case "Microsoft.Sql/Server/Database": return SqlReferenceInputDataSource.DeserializeSqlReferenceInputDataSource(element); case "Microsoft.Storage/Blob": return BlobReferenceInputDataSource.DeserializeBlobReferenceInputDataSource(element); case "Raw": return RawReferenceInputDataSource.DeserializeRawReferenceInputDataSource(element); diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputDataSource.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputDataSource.cs index 8445a827d000..2eddf5f61394 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputDataSource.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputDataSource.cs @@ -10,7 +10,7 @@ namespace Azure.ResourceManager.StreamAnalytics.Models /// /// Describes an input data source that contains reference data. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , and . + /// The available derived classes include , , and . /// public abstract partial class ReferenceInputDataSource { diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputProperties.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputProperties.cs index c8c6da16dbdc..ed62b7bd1818 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputProperties.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ReferenceInputProperties.cs @@ -23,7 +23,7 @@ public ReferenceInputProperties() /// /// Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// /// Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention. /// The current entity tag for the input. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. @@ -33,7 +33,7 @@ public ReferenceInputProperties() /// /// Describes an input data source that contains reference data. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , and . + /// The available derived classes include , , and . /// internal ReferenceInputProperties(string inputPropertiesType, StreamAnalyticsDataSerialization serialization, StreamingJobDiagnostics diagnostics, ETag? etag, StreamingCompression compression, string partitionKey, StreamingJobInputWatermarkProperties watermarkSettings, ReferenceInputDataSource datasource) : base(inputPropertiesType, serialization, diagnostics, etag, compression, partitionKey, watermarkSettings) { @@ -44,7 +44,7 @@ internal ReferenceInputProperties(string inputPropertiesType, StreamAnalyticsDat /// /// Describes an input data source that contains reference data. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , and . + /// The available derived classes include , , and . /// public ReferenceInputDataSource Datasource { get; set; } } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ResourceType.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ResourceType.cs new file mode 100644 index 000000000000..b4989affc20a --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/ResourceType.cs @@ -0,0 +1,48 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System; +using System.ComponentModel; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + /// The type of resource the SKU applies to. + public readonly partial struct ResourceType : IEquatable + { + private readonly string _value; + + /// Initializes a new instance of . + /// is null. + public ResourceType(string value) + { + _value = value ?? throw new ArgumentNullException(nameof(value)); + } + + private const string MicrosoftStreamAnalyticsStreamingjobsValue = "Microsoft.StreamAnalytics/streamingjobs"; + + /// Microsoft.StreamAnalytics/streamingjobs. + public static ResourceType MicrosoftStreamAnalyticsStreamingjobs { get; } = new ResourceType(MicrosoftStreamAnalyticsStreamingjobsValue); + /// Determines if two values are the same. + public static bool operator ==(ResourceType left, ResourceType right) => left.Equals(right); + /// Determines if two values are not the same. + public static bool operator !=(ResourceType left, ResourceType right) => !left.Equals(right); + /// Converts a string to a . + public static implicit operator ResourceType(string value) => new ResourceType(value); + + /// + [EditorBrowsable(EditorBrowsableState.Never)] + public override bool Equals(object obj) => obj is ResourceType other && Equals(other); + /// + public bool Equals(ResourceType other) => string.Equals(_value, other._value, StringComparison.InvariantCultureIgnoreCase); + + /// + [EditorBrowsable(EditorBrowsableState.Never)] + public override int GetHashCode() => _value?.GetHashCode() ?? 0; + /// + public override string ToString() => _value; + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/SkuCapacity.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/SkuCapacity.Serialization.cs new file mode 100644 index 000000000000..922c894a943d --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/SkuCapacity.Serialization.cs @@ -0,0 +1,83 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System.Collections.Generic; +using System.Text.Json; +using Azure.Core; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + public partial class SkuCapacity + { + internal static SkuCapacity DeserializeSkuCapacity(JsonElement element) + { + if (element.ValueKind == JsonValueKind.Null) + { + return null; + } + Optional minimum = default; + Optional maximum = default; + Optional @default = default; + Optional scaleType = default; + Optional> allowedValues = default; + foreach (var property in element.EnumerateObject()) + { + if (property.NameEquals("minimum"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + minimum = property.Value.GetInt32(); + continue; + } + if (property.NameEquals("maximum"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + maximum = property.Value.GetInt32(); + continue; + } + if (property.NameEquals("default"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + @default = property.Value.GetInt32(); + continue; + } + if (property.NameEquals("scaleType"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + scaleType = new SkuCapacityScaleType(property.Value.GetString()); + continue; + } + if (property.NameEquals("allowedValues"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + List array = new List(); + foreach (var item in property.Value.EnumerateArray()) + { + array.Add(item.GetInt32()); + } + allowedValues = array; + continue; + } + } + return new SkuCapacity(Optional.ToNullable(minimum), Optional.ToNullable(maximum), Optional.ToNullable(@default), Optional.ToNullable(scaleType), Optional.ToList(allowedValues)); + } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/SkuCapacity.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/SkuCapacity.cs new file mode 100644 index 000000000000..8e8283e2cea2 --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/SkuCapacity.cs @@ -0,0 +1,48 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System.Collections.Generic; +using Azure.Core; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + /// Describes scaling information of a SKU. + public partial class SkuCapacity + { + /// Initializes a new instance of SkuCapacity. + internal SkuCapacity() + { + AllowedValues = new ChangeTrackingList(); + } + + /// Initializes a new instance of SkuCapacity. + /// Specifies the minimum streaming units that the streaming job can use. + /// Specifies the maximum streaming units that the streaming job can use. + /// Specifies the default streaming units that the streaming job can use. + /// The scale type applicable to the SKU. + /// Specifies the valid streaming units a streaming job can scale to. + internal SkuCapacity(int? minimum, int? maximum, int? @default, SkuCapacityScaleType? scaleType, IReadOnlyList allowedValues) + { + Minimum = minimum; + Maximum = maximum; + Default = @default; + ScaleType = scaleType; + AllowedValues = allowedValues; + } + + /// Specifies the minimum streaming units that the streaming job can use. + public int? Minimum { get; } + /// Specifies the maximum streaming units that the streaming job can use. + public int? Maximum { get; } + /// Specifies the default streaming units that the streaming job can use. + public int? Default { get; } + /// The scale type applicable to the SKU. + public SkuCapacityScaleType? ScaleType { get; } + /// Specifies the valid streaming units a streaming job can scale to. + public IReadOnlyList AllowedValues { get; } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/SkuCapacityScaleType.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/SkuCapacityScaleType.cs new file mode 100644 index 000000000000..b5b326bd120f --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/SkuCapacityScaleType.cs @@ -0,0 +1,54 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System; +using System.ComponentModel; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + /// The scale type applicable to the SKU. + public readonly partial struct SkuCapacityScaleType : IEquatable + { + private readonly string _value; + + /// Initializes a new instance of . + /// is null. + public SkuCapacityScaleType(string value) + { + _value = value ?? throw new ArgumentNullException(nameof(value)); + } + + private const string AutomaticValue = "automatic"; + private const string ManualValue = "manual"; + private const string NoneValue = "none"; + + /// Supported scale type automatic. + public static SkuCapacityScaleType Automatic { get; } = new SkuCapacityScaleType(AutomaticValue); + /// Supported scale type manual. + public static SkuCapacityScaleType Manual { get; } = new SkuCapacityScaleType(ManualValue); + /// Scaling not supported. + public static SkuCapacityScaleType None { get; } = new SkuCapacityScaleType(NoneValue); + /// Determines if two values are the same. + public static bool operator ==(SkuCapacityScaleType left, SkuCapacityScaleType right) => left.Equals(right); + /// Determines if two values are not the same. + public static bool operator !=(SkuCapacityScaleType left, SkuCapacityScaleType right) => !left.Equals(right); + /// Converts a string to a . + public static implicit operator SkuCapacityScaleType(string value) => new SkuCapacityScaleType(value); + + /// + [EditorBrowsable(EditorBrowsableState.Never)] + public override bool Equals(object obj) => obj is SkuCapacityScaleType other && Equals(other); + /// + public bool Equals(SkuCapacityScaleType other) => string.Equals(_value, other._value, StringComparison.InvariantCultureIgnoreCase); + + /// + [EditorBrowsable(EditorBrowsableState.Never)] + public override int GetHashCode() => _value?.GetHashCode() ?? 0; + /// + public override string ToString() => _value; + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsClusterData.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsClusterData.Serialization.cs index b9ad4b2f32f4..cb3dbf9339a8 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsClusterData.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsClusterData.Serialization.cs @@ -58,7 +58,7 @@ internal static StreamAnalyticsClusterData DeserializeStreamAnalyticsClusterData AzureLocation location = default; ResourceIdentifier id = default; string name = default; - ResourceType type = default; + Core.ResourceType type = default; Optional systemData = default; foreach (var property in element.EnumerateObject()) { @@ -120,7 +120,7 @@ internal static StreamAnalyticsClusterData DeserializeStreamAnalyticsClusterData } if (property.NameEquals("type"u8)) { - type = new ResourceType(property.Value.GetString()); + type = new Core.ResourceType(property.Value.GetString()); continue; } if (property.NameEquals("systemData"u8)) diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsDataSerialization.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsDataSerialization.Serialization.cs index 552e91b2e1d8..2b3befb51c63 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsDataSerialization.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsDataSerialization.Serialization.cs @@ -33,6 +33,7 @@ internal static StreamAnalyticsDataSerialization DeserializeStreamAnalyticsDataS case "Avro": return AvroFormatSerialization.DeserializeAvroFormatSerialization(element); case "Csv": return CsvFormatSerialization.DeserializeCsvFormatSerialization(element); case "CustomClr": return CustomClrFormatSerialization.DeserializeCustomClrFormatSerialization(element); + case "Delta": return DeltaSerialization.DeserializeDeltaSerialization(element); case "Json": return JsonFormatSerialization.DeserializeJsonFormatSerialization(element); case "Parquet": return ParquetFormatSerialization.DeserializeParquetFormatSerialization(element); } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsDataSerialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsDataSerialization.cs index 16a83620a286..c0c0aa589eb9 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsDataSerialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsDataSerialization.cs @@ -10,7 +10,7 @@ namespace Azure.ResourceManager.StreamAnalytics.Models /// /// Describes how data from an input is serialized or how data is serialized when written to an output. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// public abstract partial class StreamAnalyticsDataSerialization { diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsPrivateEndpointData.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsPrivateEndpointData.Serialization.cs index 52abe4e97e77..2f6a4fb7e3ed 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsPrivateEndpointData.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsPrivateEndpointData.Serialization.cs @@ -36,7 +36,7 @@ internal static StreamAnalyticsPrivateEndpointData DeserializeStreamAnalyticsPri Optional etag = default; ResourceIdentifier id = default; string name = default; - ResourceType type = default; + Core.ResourceType type = default; Optional systemData = default; foreach (var property in element.EnumerateObject()) { @@ -71,7 +71,7 @@ internal static StreamAnalyticsPrivateEndpointData DeserializeStreamAnalyticsPri } if (property.NameEquals("type"u8)) { - type = new ResourceType(property.Value.GetString()); + type = new Core.ResourceType(property.Value.GetString()); continue; } if (property.NameEquals("systemData"u8)) diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSku.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSku.Serialization.cs index b916e2e2e010..7e01e30c222f 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSku.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSku.Serialization.cs @@ -10,7 +10,7 @@ namespace Azure.ResourceManager.StreamAnalytics.Models { - internal partial class StreamAnalyticsSku : IUtf8JsonSerializable + public partial class StreamAnalyticsSku : IUtf8JsonSerializable { void IUtf8JsonSerializable.Write(Utf8JsonWriter writer) { @@ -20,6 +20,11 @@ void IUtf8JsonSerializable.Write(Utf8JsonWriter writer) writer.WritePropertyName("name"u8); writer.WriteStringValue(Name.Value.ToString()); } + if (Optional.IsDefined(Capacity)) + { + writer.WritePropertyName("capacity"u8); + writer.WriteNumberValue(Capacity.Value); + } writer.WriteEndObject(); } @@ -30,6 +35,7 @@ internal static StreamAnalyticsSku DeserializeStreamAnalyticsSku(JsonElement ele return null; } Optional name = default; + Optional capacity = default; foreach (var property in element.EnumerateObject()) { if (property.NameEquals("name"u8)) @@ -41,8 +47,17 @@ internal static StreamAnalyticsSku DeserializeStreamAnalyticsSku(JsonElement ele name = new StreamAnalyticsSkuName(property.Value.GetString()); continue; } + if (property.NameEquals("capacity"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + capacity = property.Value.GetInt32(); + continue; + } } - return new StreamAnalyticsSku(Optional.ToNullable(name)); + return new StreamAnalyticsSku(Optional.ToNullable(name), Optional.ToNullable(capacity)); } } } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSku.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSku.cs index 84cea4e8ccfc..229dd44fe76c 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSku.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSku.cs @@ -8,7 +8,7 @@ namespace Azure.ResourceManager.StreamAnalytics.Models { /// The properties that are associated with a SKU. - internal partial class StreamAnalyticsSku + public partial class StreamAnalyticsSku { /// Initializes a new instance of StreamAnalyticsSku. public StreamAnalyticsSku() @@ -17,12 +17,16 @@ public StreamAnalyticsSku() /// Initializes a new instance of StreamAnalyticsSku. /// The name of the SKU. Required on PUT (CreateOrReplace) requests. - internal StreamAnalyticsSku(StreamAnalyticsSkuName? name) + /// The capacity of the SKU. + internal StreamAnalyticsSku(StreamAnalyticsSkuName? name, int? capacity) { Name = name; + Capacity = capacity; } /// The name of the SKU. Required on PUT (CreateOrReplace) requests. public StreamAnalyticsSkuName? Name { get; set; } + /// The capacity of the SKU. + public int? Capacity { get; set; } } } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubResource.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubResource.Serialization.cs index d80ed65ec6d7..77887131a580 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubResource.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubResource.Serialization.cs @@ -31,7 +31,7 @@ internal static StreamAnalyticsSubResource DeserializeStreamAnalyticsSubResource } Optional id = default; Optional name = default; - Optional type = default; + Optional type = default; foreach (var property in element.EnumerateObject()) { if (property.NameEquals("id"u8)) @@ -54,7 +54,7 @@ internal static StreamAnalyticsSubResource DeserializeStreamAnalyticsSubResource { continue; } - type = new ResourceType(property.Value.GetString()); + type = new Core.ResourceType(property.Value.GetString()); continue; } } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubResource.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubResource.cs index 6ce9214d1504..debbad14ae67 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubResource.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubResource.cs @@ -21,7 +21,7 @@ public StreamAnalyticsSubResource() /// Resource Id. /// Resource name. /// Resource type. - internal StreamAnalyticsSubResource(ResourceIdentifier id, string name, ResourceType? resourceType) + internal StreamAnalyticsSubResource(ResourceIdentifier id, string name, Core.ResourceType? resourceType) { Id = id; Name = name; @@ -33,6 +33,6 @@ internal StreamAnalyticsSubResource(ResourceIdentifier id, string name, Resource /// Resource name. public string Name { get; set; } /// Resource type. - public ResourceType? ResourceType { get; } + public Core.ResourceType? ResourceType { get; } } } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubscriptionQuota.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubscriptionQuota.Serialization.cs index b7a842d14a4e..d136f33a6e4f 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubscriptionQuota.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubscriptionQuota.Serialization.cs @@ -34,7 +34,7 @@ internal static StreamAnalyticsSubscriptionQuota DeserializeStreamAnalyticsSubsc } Optional id = default; Optional name = default; - Optional type = default; + Optional type = default; Optional maxCount = default; Optional currentCount = default; foreach (var property in element.EnumerateObject()) @@ -59,7 +59,7 @@ internal static StreamAnalyticsSubscriptionQuota DeserializeStreamAnalyticsSubsc { continue; } - type = new ResourceType(property.Value.GetString()); + type = new Core.ResourceType(property.Value.GetString()); continue; } if (property.NameEquals("properties"u8)) diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubscriptionQuota.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubscriptionQuota.cs index 7f24df4b8377..d6bd07c37576 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubscriptionQuota.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamAnalyticsSubscriptionQuota.cs @@ -23,7 +23,7 @@ public StreamAnalyticsSubscriptionQuota() /// Resource type. /// The max permitted usage of this resource. /// The current usage of this resource. - internal StreamAnalyticsSubscriptionQuota(ResourceIdentifier id, string name, ResourceType? resourceType, int? maxCount, int? currentCount) : base(id, name, resourceType) + internal StreamAnalyticsSubscriptionQuota(ResourceIdentifier id, string name, Core.ResourceType? resourceType, int? maxCount, int? currentCount) : base(id, name, resourceType) { MaxCount = maxCount; CurrentCount = currentCount; diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamInputProperties.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamInputProperties.cs index f7721ff4e313..5117f2063f45 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamInputProperties.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamInputProperties.cs @@ -23,7 +23,7 @@ public StreamInputProperties() /// /// Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// /// Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention. /// The current entity tag for the input. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobData.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobData.Serialization.cs index a8f221b76947..0ef95399d56f 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobData.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobData.Serialization.cs @@ -20,6 +20,11 @@ public partial class StreamingJobData : IUtf8JsonSerializable void IUtf8JsonSerializable.Write(Utf8JsonWriter writer) { writer.WriteStartObject(); + if (Optional.IsDefined(Sku)) + { + writer.WritePropertyName("sku"u8); + writer.WriteObjectValue(Sku); + } if (Optional.IsDefined(Identity)) { writer.WritePropertyName("identity"u8); @@ -41,10 +46,10 @@ void IUtf8JsonSerializable.Write(Utf8JsonWriter writer) writer.WriteStringValue(Location); writer.WritePropertyName("properties"u8); writer.WriteStartObject(); - if (Optional.IsDefined(Sku)) + if (Optional.IsDefined(SkuPropertiesSku)) { writer.WritePropertyName("sku"u8); - writer.WriteObjectValue(Sku); + writer.WriteObjectValue(SkuPropertiesSku); } if (Optional.IsDefined(JobType)) { @@ -170,14 +175,15 @@ internal static StreamingJobData DeserializeStreamingJobData(JsonElement element { return null; } + Optional sku = default; Optional identity = default; Optional> tags = default; AzureLocation location = default; ResourceIdentifier id = default; string name = default; - ResourceType type = default; + Core.ResourceType type = default; Optional systemData = default; - Optional sku = default; + Optional sku0 = default; Optional jobId = default; Optional provisioningState = default; Optional jobState = default; @@ -203,6 +209,15 @@ internal static StreamingJobData DeserializeStreamingJobData(JsonElement element Optional cluster = default; foreach (var property in element.EnumerateObject()) { + if (property.NameEquals("sku"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + sku = StreamAnalyticsSku.DeserializeStreamAnalyticsSku(property.Value); + continue; + } if (property.NameEquals("identity"u8)) { if (property.Value.ValueKind == JsonValueKind.Null) @@ -244,7 +259,7 @@ internal static StreamingJobData DeserializeStreamingJobData(JsonElement element } if (property.NameEquals("type"u8)) { - type = new ResourceType(property.Value.GetString()); + type = new Core.ResourceType(property.Value.GetString()); continue; } if (property.NameEquals("systemData"u8)) @@ -271,7 +286,7 @@ internal static StreamingJobData DeserializeStreamingJobData(JsonElement element { continue; } - sku = StreamAnalyticsSku.DeserializeStreamAnalyticsSku(property0.Value); + sku0 = StreamAnalyticsSku.DeserializeStreamAnalyticsSku(property0.Value); continue; } if (property0.NameEquals("jobId"u8)) @@ -494,7 +509,7 @@ internal static StreamingJobData DeserializeStreamingJobData(JsonElement element continue; } } - return new StreamingJobData(id, name, type, systemData.Value, Optional.ToDictionary(tags), location, identity, sku.Value, Optional.ToNullable(jobId), provisioningState.Value, jobState.Value, Optional.ToNullable(jobType), Optional.ToNullable(outputStartMode), Optional.ToNullable(outputStartTime), Optional.ToNullable(lastOutputEventTime), Optional.ToNullable(eventsOutOfOrderPolicy), Optional.ToNullable(outputErrorPolicy), Optional.ToNullable(eventsOutOfOrderMaxDelayInSeconds), Optional.ToNullable(eventsLateArrivalMaxDelayInSeconds), Optional.ToNullable(dataLocale), Optional.ToNullable(compatibilityLevel), Optional.ToNullable(createdDate), Optional.ToList(inputs), transformation.Value, Optional.ToList(outputs), Optional.ToList(functions), Optional.ToNullable(etag), jobStorageAccount.Value, Optional.ToNullable(contentStoragePolicy), externals.Value, cluster.Value); + return new StreamingJobData(id, name, type, systemData.Value, Optional.ToDictionary(tags), location, sku.Value, identity, sku0.Value, Optional.ToNullable(jobId), provisioningState.Value, jobState.Value, Optional.ToNullable(jobType), Optional.ToNullable(outputStartMode), Optional.ToNullable(outputStartTime), Optional.ToNullable(lastOutputEventTime), Optional.ToNullable(eventsOutOfOrderPolicy), Optional.ToNullable(outputErrorPolicy), Optional.ToNullable(eventsOutOfOrderMaxDelayInSeconds), Optional.ToNullable(eventsLateArrivalMaxDelayInSeconds), Optional.ToNullable(dataLocale), Optional.ToNullable(compatibilityLevel), Optional.ToNullable(createdDate), Optional.ToList(inputs), transformation.Value, Optional.ToList(outputs), Optional.ToList(functions), Optional.ToNullable(etag), jobStorageAccount.Value, Optional.ToNullable(contentStoragePolicy), externals.Value, cluster.Value); } } } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobFunctionData.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobFunctionData.Serialization.cs index a9bc0dace005..4be15ed23cd6 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobFunctionData.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobFunctionData.Serialization.cs @@ -38,7 +38,7 @@ internal static StreamingJobFunctionData DeserializeStreamingJobFunctionData(Jso Optional properties = default; Optional id = default; Optional name = default; - Optional type = default; + Optional type = default; foreach (var property in element.EnumerateObject()) { if (property.NameEquals("properties"u8)) @@ -70,7 +70,7 @@ internal static StreamingJobFunctionData DeserializeStreamingJobFunctionData(Jso { continue; } - type = new ResourceType(property.Value.GetString()); + type = new Core.ResourceType(property.Value.GetString()); continue; } } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobInputData.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobInputData.Serialization.cs index 0d14a6928865..8a903dee57e6 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobInputData.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobInputData.Serialization.cs @@ -38,7 +38,7 @@ internal static StreamingJobInputData DeserializeStreamingJobInputData(JsonEleme Optional properties = default; Optional id = default; Optional name = default; - Optional type = default; + Optional type = default; foreach (var property in element.EnumerateObject()) { if (property.NameEquals("properties"u8)) @@ -70,7 +70,7 @@ internal static StreamingJobInputData DeserializeStreamingJobInputData(JsonEleme { continue; } - type = new ResourceType(property.Value.GetString()); + type = new Core.ResourceType(property.Value.GetString()); continue; } } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobInputProperties.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobInputProperties.cs index 657f52455b61..8491f95bab59 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobInputProperties.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobInputProperties.cs @@ -27,7 +27,7 @@ protected StreamingJobInputProperties() /// /// Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// /// Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention. /// The current entity tag for the input. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. @@ -50,7 +50,7 @@ internal StreamingJobInputProperties(string inputPropertiesType, StreamAnalytics /// /// Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// public StreamAnalyticsDataSerialization Serialization { get; set; } /// Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention. diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputData.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputData.Serialization.cs index 02818bb26fbc..74ca2ee538d1 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputData.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputData.Serialization.cs @@ -63,10 +63,10 @@ internal static StreamingJobOutputData DeserializeStreamingJobOutputData(JsonEle } Optional id = default; Optional name = default; - Optional type = default; + Optional type = default; Optional datasource = default; Optional timeWindow = default; - Optional sizeWindow = default; + Optional sizeWindow = default; Optional serialization = default; Optional diagnostics = default; Optional etag = default; @@ -94,7 +94,7 @@ internal static StreamingJobOutputData DeserializeStreamingJobOutputData(JsonEle { continue; } - type = new ResourceType(property.Value.GetString()); + type = new Core.ResourceType(property.Value.GetString()); continue; } if (property.NameEquals("properties"u8)) @@ -130,7 +130,7 @@ internal static StreamingJobOutputData DeserializeStreamingJobOutputData(JsonEle { continue; } - sizeWindow = property0.Value.GetSingle(); + sizeWindow = property0.Value.GetInt32(); continue; } if (property0.NameEquals("serialization"u8)) diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputDataSource.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputDataSource.Serialization.cs index 0f769a2b91f7..64f039db3a61 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputDataSource.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputDataSource.Serialization.cs @@ -35,6 +35,7 @@ internal static StreamingJobOutputDataSource DeserializeStreamingJobOutputDataSo case "Microsoft.DBForPostgreSQL/servers/databases": return PostgreSQLOutputDataSource.DeserializePostgreSQLOutputDataSource(element); case "Microsoft.DataLake/Accounts": return DataLakeStoreOutputDataSource.DeserializeDataLakeStoreOutputDataSource(element); case "Microsoft.EventHub/EventHub": return EventHubV2OutputDataSource.DeserializeEventHubV2OutputDataSource(element); + case "Microsoft.Kusto/clusters/databases": return AzureDataExplorerOutputDataSource.DeserializeAzureDataExplorerOutputDataSource(element); case "Microsoft.ServiceBus/EventHub": return EventHubOutputDataSource.DeserializeEventHubOutputDataSource(element); case "Microsoft.ServiceBus/Queue": return ServiceBusQueueOutputDataSource.DeserializeServiceBusQueueOutputDataSource(element); case "Microsoft.ServiceBus/Topic": return ServiceBusTopicOutputDataSource.DeserializeServiceBusTopicOutputDataSource(element); diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputDataSource.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputDataSource.cs index f17c0e7b1f0c..0c4530a7d6e1 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputDataSource.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobOutputDataSource.cs @@ -10,7 +10,7 @@ namespace Azure.ResourceManager.StreamAnalytics.Models /// /// Describes the data source that output will be written to. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , , , , , , , , , , , and . + /// The available derived classes include , , , , , , , , , , , , , , and . /// public abstract partial class StreamingJobOutputDataSource { diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobRefreshConfiguration.Serialization.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobRefreshConfiguration.Serialization.cs index ac5cb3eb78cf..9de2c622436a 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobRefreshConfiguration.Serialization.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobRefreshConfiguration.Serialization.cs @@ -53,7 +53,7 @@ internal static StreamingJobRefreshConfiguration DeserializeStreamingJobRefreshC Optional dateFormat = default; Optional timeFormat = default; Optional refreshInterval = default; - Optional refreshType = default; + Optional refreshType = default; foreach (var property in element.EnumerateObject()) { if (property.NameEquals("pathPattern"u8)) @@ -82,7 +82,7 @@ internal static StreamingJobRefreshConfiguration DeserializeStreamingJobRefreshC { continue; } - refreshType = new DataRefreshType(property.Value.GetString()); + refreshType = new UpdatableUdfRefreshType(property.Value.GetString()); continue; } } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobRefreshConfiguration.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobRefreshConfiguration.cs index fb3430e09755..9cd65cacbf37 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobRefreshConfiguration.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/StreamingJobRefreshConfiguration.cs @@ -21,7 +21,7 @@ public StreamingJobRefreshConfiguration() /// The time format. Wherever {time} appears in pathPattern, the value of this property is used as the time format instead. /// The refresh interval. /// This property indicates which data refresh option to use, Blocking or Nonblocking. - internal StreamingJobRefreshConfiguration(string pathPattern, string dateFormat, string timeFormat, string refreshInterval, DataRefreshType? refreshType) + internal StreamingJobRefreshConfiguration(string pathPattern, string dateFormat, string timeFormat, string refreshInterval, UpdatableUdfRefreshType? refreshType) { PathPattern = pathPattern; DateFormat = dateFormat; @@ -39,6 +39,6 @@ internal StreamingJobRefreshConfiguration(string pathPattern, string dateFormat, /// The refresh interval. public string RefreshInterval { get; set; } /// This property indicates which data refresh option to use, Blocking or Nonblocking. - public DataRefreshType? RefreshType { get; set; } + public UpdatableUdfRefreshType? RefreshType { get; set; } } } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/UnknownInputProperties.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/UnknownInputProperties.cs index 2620625b1154..a34b858aed0a 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/UnknownInputProperties.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/UnknownInputProperties.cs @@ -17,7 +17,7 @@ internal partial class UnknownInputProperties : StreamingJobInputProperties /// /// Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// /// Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention. /// The current entity tag for the input. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/UpdatableUdfRefreshType.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/UpdatableUdfRefreshType.cs new file mode 100644 index 000000000000..168ef2fd7ef3 --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/Models/UpdatableUdfRefreshType.cs @@ -0,0 +1,51 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System; +using System.ComponentModel; + +namespace Azure.ResourceManager.StreamAnalytics.Models +{ + /// This property indicates which data refresh option to use, Blocking or Nonblocking. + public readonly partial struct UpdatableUdfRefreshType : IEquatable + { + private readonly string _value; + + /// Initializes a new instance of . + /// is null. + public UpdatableUdfRefreshType(string value) + { + _value = value ?? throw new ArgumentNullException(nameof(value)); + } + + private const string BlockingValue = "Blocking"; + private const string NonblockingValue = "Nonblocking"; + + /// Blocking. + public static UpdatableUdfRefreshType Blocking { get; } = new UpdatableUdfRefreshType(BlockingValue); + /// Nonblocking. + public static UpdatableUdfRefreshType Nonblocking { get; } = new UpdatableUdfRefreshType(NonblockingValue); + /// Determines if two values are the same. + public static bool operator ==(UpdatableUdfRefreshType left, UpdatableUdfRefreshType right) => left.Equals(right); + /// Determines if two values are not the same. + public static bool operator !=(UpdatableUdfRefreshType left, UpdatableUdfRefreshType right) => !left.Equals(right); + /// Converts a string to a . + public static implicit operator UpdatableUdfRefreshType(string value) => new UpdatableUdfRefreshType(value); + + /// + [EditorBrowsable(EditorBrowsableState.Never)] + public override bool Equals(object obj) => obj is UpdatableUdfRefreshType other && Equals(other); + /// + public bool Equals(UpdatableUdfRefreshType other) => string.Equals(_value, other._value, StringComparison.InvariantCultureIgnoreCase); + + /// + [EditorBrowsable(EditorBrowsableState.Never)] + public override int GetHashCode() => _value?.GetHashCode() ?? 0; + /// + public override string ToString() => _value; + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/RestOperations/SkuRestOperations.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/RestOperations/SkuRestOperations.cs new file mode 100644 index 000000000000..c14737c834bf --- /dev/null +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/RestOperations/SkuRestOperations.cs @@ -0,0 +1,195 @@ +// Copyright (c) Microsoft Corporation. All rights reserved. +// Licensed under the MIT License. + +// + +#nullable disable + +using System; +using System.Text.Json; +using System.Threading; +using System.Threading.Tasks; +using Azure; +using Azure.Core; +using Azure.Core.Pipeline; +using Azure.ResourceManager.StreamAnalytics.Models; + +namespace Azure.ResourceManager.StreamAnalytics +{ + internal partial class SkuRestOperations + { + private readonly TelemetryDetails _userAgent; + private readonly HttpPipeline _pipeline; + private readonly Uri _endpoint; + private readonly string _apiVersion; + + /// Initializes a new instance of SkuRestOperations. + /// The HTTP pipeline for sending and receiving REST requests and responses. + /// The application id to use for user agent. + /// server parameter. + /// Api Version. + /// or is null. + public SkuRestOperations(HttpPipeline pipeline, string applicationId, Uri endpoint = null, string apiVersion = default) + { + _pipeline = pipeline ?? throw new ArgumentNullException(nameof(pipeline)); + _endpoint = endpoint ?? new Uri("https://management.azure.com"); + _apiVersion = apiVersion ?? "2021-10-01-preview"; + _userAgent = new TelemetryDetails(GetType().Assembly, applicationId); + } + + internal HttpMessage CreateListRequest(string subscriptionId, string resourceGroupName, string jobName) + { + var message = _pipeline.CreateMessage(); + var request = message.Request; + request.Method = RequestMethod.Get; + var uri = new RawRequestUriBuilder(); + uri.Reset(_endpoint); + uri.AppendPath("/subscriptions/", false); + uri.AppendPath(subscriptionId, true); + uri.AppendPath("/resourcegroups/", false); + uri.AppendPath(resourceGroupName, true); + uri.AppendPath("/providers/Microsoft.StreamAnalytics/streamingjobs/", false); + uri.AppendPath(jobName, true); + uri.AppendPath("/skus", false); + uri.AppendQuery("api-version", _apiVersion, true); + request.Uri = uri; + request.Headers.Add("Accept", "application/json"); + _userAgent.Apply(message); + return message; + } + + /// Gets a list of available SKUs about the specified streaming job. + /// The ID of the target subscription. + /// The name of the resource group. The name is case insensitive. + /// The name of the streaming job. + /// The cancellation token to use. + /// , or is null. + /// , or is an empty string, and was expected to be non-empty. + public async Task> ListAsync(string subscriptionId, string resourceGroupName, string jobName, CancellationToken cancellationToken = default) + { + Argument.AssertNotNullOrEmpty(subscriptionId, nameof(subscriptionId)); + Argument.AssertNotNullOrEmpty(resourceGroupName, nameof(resourceGroupName)); + Argument.AssertNotNullOrEmpty(jobName, nameof(jobName)); + + using var message = CreateListRequest(subscriptionId, resourceGroupName, jobName); + await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false); + switch (message.Response.Status) + { + case 200: + { + GetStreamingJobSkuResults value = default; + using var document = await JsonDocument.ParseAsync(message.Response.ContentStream, default, cancellationToken).ConfigureAwait(false); + value = GetStreamingJobSkuResults.DeserializeGetStreamingJobSkuResults(document.RootElement); + return Response.FromValue(value, message.Response); + } + default: + throw new RequestFailedException(message.Response); + } + } + + /// Gets a list of available SKUs about the specified streaming job. + /// The ID of the target subscription. + /// The name of the resource group. The name is case insensitive. + /// The name of the streaming job. + /// The cancellation token to use. + /// , or is null. + /// , or is an empty string, and was expected to be non-empty. + public Response List(string subscriptionId, string resourceGroupName, string jobName, CancellationToken cancellationToken = default) + { + Argument.AssertNotNullOrEmpty(subscriptionId, nameof(subscriptionId)); + Argument.AssertNotNullOrEmpty(resourceGroupName, nameof(resourceGroupName)); + Argument.AssertNotNullOrEmpty(jobName, nameof(jobName)); + + using var message = CreateListRequest(subscriptionId, resourceGroupName, jobName); + _pipeline.Send(message, cancellationToken); + switch (message.Response.Status) + { + case 200: + { + GetStreamingJobSkuResults value = default; + using var document = JsonDocument.Parse(message.Response.ContentStream); + value = GetStreamingJobSkuResults.DeserializeGetStreamingJobSkuResults(document.RootElement); + return Response.FromValue(value, message.Response); + } + default: + throw new RequestFailedException(message.Response); + } + } + + internal HttpMessage CreateListNextPageRequest(string nextLink, string subscriptionId, string resourceGroupName, string jobName) + { + var message = _pipeline.CreateMessage(); + var request = message.Request; + request.Method = RequestMethod.Get; + var uri = new RawRequestUriBuilder(); + uri.Reset(_endpoint); + uri.AppendRawNextLink(nextLink, false); + request.Uri = uri; + request.Headers.Add("Accept", "application/json"); + _userAgent.Apply(message); + return message; + } + + /// Gets a list of available SKUs about the specified streaming job. + /// The URL to the next page of results. + /// The ID of the target subscription. + /// The name of the resource group. The name is case insensitive. + /// The name of the streaming job. + /// The cancellation token to use. + /// , , or is null. + /// , or is an empty string, and was expected to be non-empty. + public async Task> ListNextPageAsync(string nextLink, string subscriptionId, string resourceGroupName, string jobName, CancellationToken cancellationToken = default) + { + Argument.AssertNotNull(nextLink, nameof(nextLink)); + Argument.AssertNotNullOrEmpty(subscriptionId, nameof(subscriptionId)); + Argument.AssertNotNullOrEmpty(resourceGroupName, nameof(resourceGroupName)); + Argument.AssertNotNullOrEmpty(jobName, nameof(jobName)); + + using var message = CreateListNextPageRequest(nextLink, subscriptionId, resourceGroupName, jobName); + await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false); + switch (message.Response.Status) + { + case 200: + { + GetStreamingJobSkuResults value = default; + using var document = await JsonDocument.ParseAsync(message.Response.ContentStream, default, cancellationToken).ConfigureAwait(false); + value = GetStreamingJobSkuResults.DeserializeGetStreamingJobSkuResults(document.RootElement); + return Response.FromValue(value, message.Response); + } + default: + throw new RequestFailedException(message.Response); + } + } + + /// Gets a list of available SKUs about the specified streaming job. + /// The URL to the next page of results. + /// The ID of the target subscription. + /// The name of the resource group. The name is case insensitive. + /// The name of the streaming job. + /// The cancellation token to use. + /// , , or is null. + /// , or is an empty string, and was expected to be non-empty. + public Response ListNextPage(string nextLink, string subscriptionId, string resourceGroupName, string jobName, CancellationToken cancellationToken = default) + { + Argument.AssertNotNull(nextLink, nameof(nextLink)); + Argument.AssertNotNullOrEmpty(subscriptionId, nameof(subscriptionId)); + Argument.AssertNotNullOrEmpty(resourceGroupName, nameof(resourceGroupName)); + Argument.AssertNotNullOrEmpty(jobName, nameof(jobName)); + + using var message = CreateListNextPageRequest(nextLink, subscriptionId, resourceGroupName, jobName); + _pipeline.Send(message, cancellationToken); + switch (message.Response.Status) + { + case 200: + { + GetStreamingJobSkuResults value = default; + using var document = JsonDocument.Parse(message.Response.ContentStream); + value = GetStreamingJobSkuResults.DeserializeGetStreamingJobSkuResults(document.RootElement); + return Response.FromValue(value, message.Response); + } + default: + throw new RequestFailedException(message.Response); + } + } + } +} diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/RestOperations/StreamingJobsRestOperations.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/RestOperations/StreamingJobsRestOperations.cs index c3afab2dd312..ab4691ca075e 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/RestOperations/StreamingJobsRestOperations.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/RestOperations/StreamingJobsRestOperations.cs @@ -728,6 +728,7 @@ public async Task ScaleAsync(string subscriptionId, string resourceGro await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false); switch (message.Response.Status) { + case 200: case 202: return message.Response; default: @@ -753,6 +754,7 @@ public Response Scale(string subscriptionId, string resourceGroupName, string jo _pipeline.Send(message, cancellationToken); switch (message.Response.Status) { + case 200: case 202: return message.Response; default: diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsClusterData.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsClusterData.cs index 5258429114ce..33c34bfbe1f2 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsClusterData.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsClusterData.cs @@ -35,7 +35,7 @@ public StreamAnalyticsClusterData(AzureLocation location) : base(location) /// The SKU of the cluster. This determines the size/capacity of the cluster. Required on PUT (CreateOrUpdate) requests. /// The current entity tag for the cluster. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. /// The properties associated with a Stream Analytics cluster. - internal StreamAnalyticsClusterData(ResourceIdentifier id, string name, ResourceType resourceType, SystemData systemData, IDictionary tags, AzureLocation location, StreamAnalyticsClusterSku sku, ETag? etag, StreamAnalyticsClusterProperties properties) : base(id, name, resourceType, systemData, tags, location) + internal StreamAnalyticsClusterData(ResourceIdentifier id, string name, Core.ResourceType resourceType, SystemData systemData, IDictionary tags, AzureLocation location, StreamAnalyticsClusterSku sku, ETag? etag, StreamAnalyticsClusterProperties properties) : base(id, name, resourceType, systemData, tags, location) { Sku = sku; ETag = etag; diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsClusterResource.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsClusterResource.cs index 61a5ae8ed0db..eda265f33918 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsClusterResource.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsClusterResource.cs @@ -66,7 +66,7 @@ internal StreamAnalyticsClusterResource(ArmClient client, ResourceIdentifier id) } /// Gets the resource type for the operations. - public static readonly ResourceType ResourceType = "Microsoft.StreamAnalytics/clusters"; + public static readonly Core.ResourceType ResourceType = "Microsoft.StreamAnalytics/clusters"; /// Gets whether or not the current instance has data. public virtual bool HasData { get; } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsPrivateEndpointData.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsPrivateEndpointData.cs index 7aee1007ab07..b78112501e74 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsPrivateEndpointData.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamAnalyticsPrivateEndpointData.cs @@ -30,7 +30,7 @@ public StreamAnalyticsPrivateEndpointData() /// The systemData. /// The properties associated with a private endpoint. /// Unique opaque string (generally a GUID) that represents the metadata state of the resource (private endpoint) and changes whenever the resource is updated. Required on PUT (CreateOrUpdate) requests. - internal StreamAnalyticsPrivateEndpointData(ResourceIdentifier id, string name, ResourceType resourceType, SystemData systemData, StreamAnalyticsPrivateEndpointProperties properties, ETag? etag) : base(id, name, resourceType, systemData) + internal StreamAnalyticsPrivateEndpointData(ResourceIdentifier id, string name, Core.ResourceType resourceType, SystemData systemData, StreamAnalyticsPrivateEndpointProperties properties, ETag? etag) : base(id, name, resourceType, systemData) { Properties = properties; ETag = etag; diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobData.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobData.cs index a73850d401a7..30453dd13160 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobData.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobData.cs @@ -36,8 +36,9 @@ public StreamingJobData(AzureLocation location) : base(location) /// The systemData. /// The tags. /// The location. - /// Describes the managed identity assigned to this job that can be used to authenticate with inputs and outputs. Current supported identity types: SystemAssigned, UserAssigned, SystemAssigned,UserAssigned. /// Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests. + /// Describes the managed identity assigned to this job that can be used to authenticate with inputs and outputs. Current supported identity types: SystemAssigned, UserAssigned, SystemAssigned,UserAssigned. + /// Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests. /// A GUID uniquely identifying the streaming job. This GUID is generated upon creation of the streaming job. /// Describes the provisioning status of the streaming job. /// Describes the state of the streaming job. @@ -61,10 +62,11 @@ public StreamingJobData(AzureLocation location) : base(location) /// Valid values are JobStorageAccount and SystemAccount. If set to JobStorageAccount, this requires the user to also specify jobStorageAccount property. . /// The storage account where the custom code artifacts are located. /// The cluster which streaming jobs will run on. - internal StreamingJobData(ResourceIdentifier id, string name, ResourceType resourceType, SystemData systemData, IDictionary tags, AzureLocation location, ManagedServiceIdentity identity, StreamAnalyticsSku sku, Guid? jobId, string provisioningState, string jobState, StreamingJobType? jobType, StreamingJobOutputStartMode? outputStartMode, DateTimeOffset? outputStartOn, DateTimeOffset? lastOutputEventOn, EventsOutOfOrderPolicy? eventsOutOfOrderPolicy, StreamingJobOutputErrorPolicy? outputErrorPolicy, int? eventsOutOfOrderMaxDelayInSeconds, int? eventsLateArrivalMaxDelayInSeconds, AzureLocation? dataLocalion, StreamingJobCompatibilityLevel? compatibilityLevel, DateTimeOffset? createdOn, IList inputs, StreamingJobTransformationData transformation, IList outputs, IList functions, ETag? etag, StreamingJobStorageAccount jobStorageAccount, StreamingJobContentStoragePolicy? contentStoragePolicy, StreamingJobExternal externals, ClusterInfo cluster) : base(id, name, resourceType, systemData, tags, location) + internal StreamingJobData(ResourceIdentifier id, string name, Core.ResourceType resourceType, SystemData systemData, IDictionary tags, AzureLocation location, StreamAnalyticsSku sku, ManagedServiceIdentity identity, StreamAnalyticsSku skuPropertiesSku, Guid? jobId, string provisioningState, string jobState, StreamingJobType? jobType, StreamingJobOutputStartMode? outputStartMode, DateTimeOffset? outputStartOn, DateTimeOffset? lastOutputEventOn, EventsOutOfOrderPolicy? eventsOutOfOrderPolicy, StreamingJobOutputErrorPolicy? outputErrorPolicy, int? eventsOutOfOrderMaxDelayInSeconds, int? eventsLateArrivalMaxDelayInSeconds, AzureLocation? dataLocalion, StreamingJobCompatibilityLevel? compatibilityLevel, DateTimeOffset? createdOn, IList inputs, StreamingJobTransformationData transformation, IList outputs, IList functions, ETag? etag, StreamingJobStorageAccount jobStorageAccount, StreamingJobContentStoragePolicy? contentStoragePolicy, StreamingJobExternal externals, ClusterInfo cluster) : base(id, name, resourceType, systemData, tags, location) { - Identity = identity; Sku = sku; + Identity = identity; + SkuPropertiesSku = skuPropertiesSku; JobId = jobId; ProvisioningState = provisioningState; JobState = jobState; @@ -90,22 +92,12 @@ internal StreamingJobData(ResourceIdentifier id, string name, ResourceType resou Cluster = cluster; } + /// Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests. + public StreamAnalyticsSku Sku { get; set; } /// Describes the managed identity assigned to this job that can be used to authenticate with inputs and outputs. Current supported identity types: SystemAssigned, UserAssigned, SystemAssigned,UserAssigned. public ManagedServiceIdentity Identity { get; set; } /// Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests. - internal StreamAnalyticsSku Sku { get; set; } - /// The name of the SKU. Required on PUT (CreateOrReplace) requests. - public StreamAnalyticsSkuName? SkuName - { - get => Sku is null ? default : Sku.Name; - set - { - if (Sku is null) - Sku = new StreamAnalyticsSku(); - Sku.Name = value; - } - } - + public StreamAnalyticsSku SkuPropertiesSku { get; set; } /// A GUID uniquely identifying the streaming job. This GUID is generated upon creation of the streaming job. public Guid? JobId { get; } /// Describes the provisioning status of the streaming job. diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobFunctionData.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobFunctionData.cs index 473d403f8997..359051bc693f 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobFunctionData.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobFunctionData.cs @@ -30,7 +30,7 @@ public StreamingJobFunctionData() /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. /// The available derived classes include and . /// - internal StreamingJobFunctionData(ResourceIdentifier id, string name, ResourceType? resourceType, StreamingJobFunctionProperties properties) : base(id, name, resourceType) + internal StreamingJobFunctionData(ResourceIdentifier id, string name, Core.ResourceType? resourceType, StreamingJobFunctionProperties properties) : base(id, name, resourceType) { Properties = properties; } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobFunctionResource.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobFunctionResource.cs index 80b20bc30609..a7e5d281f5aa 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobFunctionResource.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobFunctionResource.cs @@ -64,7 +64,7 @@ internal StreamingJobFunctionResource(ArmClient client, ResourceIdentifier id) : } /// Gets the resource type for the operations. - public static readonly ResourceType ResourceType = "Microsoft.StreamAnalytics/streamingjobs/functions"; + public static readonly Core.ResourceType ResourceType = "Microsoft.StreamAnalytics/streamingjobs/functions"; /// Gets whether or not the current instance has data. public virtual bool HasData { get; } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobInputData.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobInputData.cs index 22b8d1e662d9..97c492064edb 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobInputData.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobInputData.cs @@ -30,7 +30,7 @@ public StreamingJobInputData() /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. /// The available derived classes include and . /// - internal StreamingJobInputData(ResourceIdentifier id, string name, ResourceType? resourceType, StreamingJobInputProperties properties) : base(id, name, resourceType) + internal StreamingJobInputData(ResourceIdentifier id, string name, Core.ResourceType? resourceType, StreamingJobInputProperties properties) : base(id, name, resourceType) { Properties = properties; } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobInputResource.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobInputResource.cs index f1b0919f6c09..baf78ac02bc6 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobInputResource.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobInputResource.cs @@ -64,7 +64,7 @@ internal StreamingJobInputResource(ArmClient client, ResourceIdentifier id) : ba } /// Gets the resource type for the operations. - public static readonly ResourceType ResourceType = "Microsoft.StreamAnalytics/streamingjobs/inputs"; + public static readonly Core.ResourceType ResourceType = "Microsoft.StreamAnalytics/streamingjobs/inputs"; /// Gets whether or not the current instance has data. public virtual bool HasData { get; } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobOutputData.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobOutputData.cs index 840441f94650..7187098c82de 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobOutputData.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobOutputData.cs @@ -32,20 +32,20 @@ public StreamingJobOutputData() /// /// Describes the data source that output will be written to. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , , , , , , , , , , , and . + /// The available derived classes include , , , , , , , , , , , , , , and . /// /// The time frame for filtering Stream Analytics job outputs. /// The size window to constrain a Stream Analytics output to. /// /// Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// /// Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention. /// The current entity tag for the output. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. /// A list of the last output event times for each output partition. The index of the array corresponds to the partition number. /// Settings which determine whether to send watermarks to downstream. - internal StreamingJobOutputData(ResourceIdentifier id, string name, ResourceType? resourceType, StreamingJobOutputDataSource datasource, TimeSpan? timeFrame, float? sizeWindow, StreamAnalyticsDataSerialization serialization, StreamingJobDiagnostics diagnostics, ETag? etag, IReadOnlyList lastOutputEventTimestamps, StreamingJobOutputWatermarkProperties watermarkSettings) : base(id, name, resourceType) + internal StreamingJobOutputData(ResourceIdentifier id, string name, Core.ResourceType? resourceType, StreamingJobOutputDataSource datasource, TimeSpan? timeFrame, int? sizeWindow, StreamAnalyticsDataSerialization serialization, StreamingJobDiagnostics diagnostics, ETag? etag, IReadOnlyList lastOutputEventTimestamps, StreamingJobOutputWatermarkProperties watermarkSettings) : base(id, name, resourceType) { Datasource = datasource; TimeFrame = timeFrame; @@ -60,17 +60,17 @@ internal StreamingJobOutputData(ResourceIdentifier id, string name, ResourceType /// /// Describes the data source that output will be written to. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , , , , , , , , , , , and . + /// The available derived classes include , , , , , , , , , , , , , , and . /// public StreamingJobOutputDataSource Datasource { get; set; } /// The time frame for filtering Stream Analytics job outputs. public TimeSpan? TimeFrame { get; set; } /// The size window to constrain a Stream Analytics output to. - public float? SizeWindow { get; set; } + public int? SizeWindow { get; set; } /// /// Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. /// Please note is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. - /// The available derived classes include , , , and . + /// The available derived classes include , , , , and . /// public StreamAnalyticsDataSerialization Serialization { get; set; } /// Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention. diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobOutputResource.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobOutputResource.cs index 09d0a6a136d1..9581528a3a46 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobOutputResource.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobOutputResource.cs @@ -64,7 +64,7 @@ internal StreamingJobOutputResource(ArmClient client, ResourceIdentifier id) : b } /// Gets the resource type for the operations. - public static readonly ResourceType ResourceType = "Microsoft.StreamAnalytics/streamingjobs/outputs"; + public static readonly Core.ResourceType ResourceType = "Microsoft.StreamAnalytics/streamingjobs/outputs"; /// Gets whether or not the current instance has data. public virtual bool HasData { get; } diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobResource.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobResource.cs index 42dfa4a5e4f0..c511bf5c9859 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobResource.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobResource.cs @@ -36,6 +36,8 @@ public static ResourceIdentifier CreateResourceIdentifier(string subscriptionId, private readonly ClientDiagnostics _streamingJobClientDiagnostics; private readonly StreamingJobsRestOperations _streamingJobRestClient; + private readonly ClientDiagnostics _skuClientDiagnostics; + private readonly SkuRestOperations _skuRestClient; private readonly StreamingJobData _data; /// Initializes a new instance of the class for mocking. @@ -60,13 +62,15 @@ internal StreamingJobResource(ArmClient client, ResourceIdentifier id) : base(cl _streamingJobClientDiagnostics = new ClientDiagnostics("Azure.ResourceManager.StreamAnalytics", ResourceType.Namespace, Diagnostics); TryGetApiVersion(ResourceType, out string streamingJobApiVersion); _streamingJobRestClient = new StreamingJobsRestOperations(Pipeline, Diagnostics.ApplicationId, Endpoint, streamingJobApiVersion); + _skuClientDiagnostics = new ClientDiagnostics("Azure.ResourceManager.StreamAnalytics", ProviderConstants.DefaultProviderNamespace, Diagnostics); + _skuRestClient = new SkuRestOperations(Pipeline, Diagnostics.ApplicationId, Endpoint); #if DEBUG ValidateResourceId(Id); #endif } /// Gets the resource type for the operations. - public static readonly ResourceType ResourceType = "Microsoft.StreamAnalytics/streamingjobs"; + public static readonly Core.ResourceType ResourceType = "Microsoft.StreamAnalytics/streamingjobs"; /// Gets whether or not the current instance has data. public virtual bool HasData { get; } @@ -713,6 +717,50 @@ public virtual ArmOperation Scale(WaitUntil waitUntil, ScaleStreamingJobContent } } + /// + /// Gets a list of available SKUs about the specified streaming job. + /// + /// + /// Request Path + /// /subscriptions/{subscriptionId}/resourcegroups/{resourceGroupName}/providers/Microsoft.StreamAnalytics/streamingjobs/{jobName}/skus + /// + /// + /// Operation Id + /// Sku_List + /// + /// + /// + /// The cancellation token to use. + /// An async collection of that may take multiple service requests to iterate over. + public virtual AsyncPageable GetSkusAsync(CancellationToken cancellationToken = default) + { + HttpMessage FirstPageRequest(int? pageSizeHint) => _skuRestClient.CreateListRequest(Id.SubscriptionId, Id.ResourceGroupName, Id.Name); + HttpMessage NextPageRequest(int? pageSizeHint, string nextLink) => _skuRestClient.CreateListNextPageRequest(nextLink, Id.SubscriptionId, Id.ResourceGroupName, Id.Name); + return PageableHelpers.CreateAsyncPageable(FirstPageRequest, NextPageRequest, GetStreamingJobSkuResult.DeserializeGetStreamingJobSkuResult, _skuClientDiagnostics, Pipeline, "StreamingJobResource.GetSkus", "value", "nextLink", cancellationToken); + } + + /// + /// Gets a list of available SKUs about the specified streaming job. + /// + /// + /// Request Path + /// /subscriptions/{subscriptionId}/resourcegroups/{resourceGroupName}/providers/Microsoft.StreamAnalytics/streamingjobs/{jobName}/skus + /// + /// + /// Operation Id + /// Sku_List + /// + /// + /// + /// The cancellation token to use. + /// A collection of that may take multiple service requests to iterate over. + public virtual Pageable GetSkus(CancellationToken cancellationToken = default) + { + HttpMessage FirstPageRequest(int? pageSizeHint) => _skuRestClient.CreateListRequest(Id.SubscriptionId, Id.ResourceGroupName, Id.Name); + HttpMessage NextPageRequest(int? pageSizeHint, string nextLink) => _skuRestClient.CreateListNextPageRequest(nextLink, Id.SubscriptionId, Id.ResourceGroupName, Id.Name); + return PageableHelpers.CreatePageable(FirstPageRequest, NextPageRequest, GetStreamingJobSkuResult.DeserializeGetStreamingJobSkuResult, _skuClientDiagnostics, Pipeline, "StreamingJobResource.GetSkus", "value", "nextLink", cancellationToken); + } + /// /// Add a tag to the current resource. /// diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobTransformationData.cs b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobTransformationData.cs index 58a2b51e4886..6f99736f814d 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobTransformationData.cs +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/Generated/StreamingJobTransformationData.cs @@ -32,7 +32,7 @@ public StreamingJobTransformationData() /// Specifies the valid streaming units a streaming job can scale to. /// Specifies the query that will be run in the streaming job. You can learn more about the Stream Analytics Query Language (SAQL) here: https://msdn.microsoft.com/library/azure/dn834998 . Required on PUT (CreateOrReplace) requests. /// The current entity tag for the transformation. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency. - internal StreamingJobTransformationData(ResourceIdentifier id, string name, ResourceType? resourceType, int? streamingUnits, IList validStreamingUnits, string query, ETag? etag) : base(id, name, resourceType) + internal StreamingJobTransformationData(ResourceIdentifier id, string name, Core.ResourceType? resourceType, int? streamingUnits, IList validStreamingUnits, string query, ETag? etag) : base(id, name, resourceType) { StreamingUnits = streamingUnits; ValidStreamingUnits = validStreamingUnits; diff --git a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/autorest.md b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/autorest.md index e771607288c9..49df2c462cfb 100644 --- a/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/autorest.md +++ b/sdk/streamanalytics/Azure.ResourceManager.StreamAnalytics/src/autorest.md @@ -8,7 +8,7 @@ azure-arm: true csharp: true library-name: StreamAnalytics namespace: Azure.ResourceManager.StreamAnalytics -require: https://github.com/Azure/azure-rest-api-specs/blob/692cb8b5eb71505afa267cfbbee322d520eb15ff/specification/streamanalytics/resource-manager/readme.md +require: /mnt/vss/_work/1/s/azure-rest-api-specs/specification/streamanalytics/resource-manager/readme.md tag: package-2021-10-preview output-folder: $(this-folder)/Generated clear-output-folder: true