MICROSOFT.STREAMANALYTICS

Suggest Edits
docs.microsoft.com
Azure documentation

Clusters_CreateOrUpdate

enum_ClusterSkuName := [ "Default" ]

valid {
    input.Body.sku.name == enum_ClusterSkuName[_]
    input.Body.sku.capacity == INTEGER
    input.Body.properties == {}
    input.Body.tags.STRING == STRING
    input.Body.location == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.clusterName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Clusters_Delete

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.clusterName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Clusters_Get

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.clusterName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Clusters_ListByResourceGroup

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Clusters_ListBySubscription

valid {
    input.ReqMap.SubscriptionID == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
}

Clusters_ListStreamingJobs

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.clusterName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Clusters_Update

enum_ClusterSkuName := [ "Default" ]

valid {
    input.Body.sku.name == enum_ClusterSkuName[_]
    input.Body.sku.capacity == INTEGER
    input.Body.properties == {}
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.clusterName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Functions_CreateOrReplace

valid {
    input.Body.properties.type == STRING
    input.Body.properties.properties.inputs[_].dataType == STRING
    input.Body.properties.properties.inputs[_].isConfigurationParameter == BOOLEAN
    input.Body.properties.properties.output.dataType == STRING
    input.Body.properties.properties.binding.type == STRING
    input.Body.name == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.functionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Functions_Delete

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.functionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Functions_Get

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.functionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Functions_ListByStreamingJob

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.Qs.$select == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Functions_RetrieveDefaultDefinition

valid {
    input.Body.bindingType == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.functionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Functions_Test

valid {
    input.Body.properties.type == STRING
    input.Body.properties.properties.inputs[_].dataType == STRING
    input.Body.properties.properties.inputs[_].isConfigurationParameter == BOOLEAN
    input.Body.properties.properties.output.dataType == STRING
    input.Body.properties.properties.binding.type == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.functionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Functions_Update

valid {
    input.Body.properties.type == STRING
    input.Body.properties.properties.inputs[_].dataType == STRING
    input.Body.properties.properties.inputs[_].isConfigurationParameter == BOOLEAN
    input.Body.properties.properties.output.dataType == STRING
    input.Body.properties.properties.binding.type == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.functionName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Inputs_CreateOrReplace

enum_CompressionType := [ "None", "GZip", "Deflate" ]
enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_InputWatermarkMode := [ "None", "ReadWatermark" ]

valid {
    input.Body.properties.type == STRING
    input.Body.properties.serialization.type == enum_EventSerializationType[_]
    input.Body.properties.compression.type == enum_CompressionType[_]
    input.Body.properties.partitionKey == STRING
    input.Body.properties.watermarkSettings.watermarkMode == enum_InputWatermarkMode[_]
    input.Body.name == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.inputName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Inputs_Delete

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.inputName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Inputs_Get

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.inputName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Inputs_ListByStreamingJob

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.Qs.$select == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Inputs_Test

enum_CompressionType := [ "None", "GZip", "Deflate" ]
enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_InputWatermarkMode := [ "None", "ReadWatermark" ]

valid {
    input.Body.properties.type == STRING
    input.Body.properties.serialization.type == enum_EventSerializationType[_]
    input.Body.properties.compression.type == enum_CompressionType[_]
    input.Body.properties.partitionKey == STRING
    input.Body.properties.watermarkSettings.watermarkMode == enum_InputWatermarkMode[_]
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.inputName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Inputs_Update

enum_CompressionType := [ "None", "GZip", "Deflate" ]
enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_InputWatermarkMode := [ "None", "ReadWatermark" ]

valid {
    input.Body.properties.type == STRING
    input.Body.properties.serialization.type == enum_EventSerializationType[_]
    input.Body.properties.compression.type == enum_CompressionType[_]
    input.Body.properties.partitionKey == STRING
    input.Body.properties.watermarkSettings.watermarkMode == enum_InputWatermarkMode[_]
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.inputName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Operations_List

valid {
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
}

Outputs_CreateOrReplace

enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_OutputWatermarkMode := [ "None", "SendCurrentPartitionWatermark", "SendLowestWatermarkAcrossPartitions" ]

valid {
    input.Body.properties.datasource.type == STRING
    input.Body.properties.timeWindow == STRING
    input.Body.properties.sizeWindow == INTEGER
    input.Body.properties.serialization.type == enum_EventSerializationType[_]
    input.Body.properties.watermarkSettings.watermarkMode == enum_OutputWatermarkMode[_]
    input.Body.properties.watermarkSettings.maxWatermarkDifferenceAcrossPartitions == STRING
    input.Body.name == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.outputName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Outputs_Delete

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.outputName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Outputs_Get

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.outputName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Outputs_ListByStreamingJob

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.Qs.$select == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Outputs_Test

enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_OutputWatermarkMode := [ "None", "SendCurrentPartitionWatermark", "SendLowestWatermarkAcrossPartitions" ]

valid {
    input.Body.properties.datasource.type == STRING
    input.Body.properties.timeWindow == STRING
    input.Body.properties.sizeWindow == INTEGER
    input.Body.properties.serialization.type == enum_EventSerializationType[_]
    input.Body.properties.watermarkSettings.watermarkMode == enum_OutputWatermarkMode[_]
    input.Body.properties.watermarkSettings.maxWatermarkDifferenceAcrossPartitions == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.outputName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Outputs_Update

enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_OutputWatermarkMode := [ "None", "SendCurrentPartitionWatermark", "SendLowestWatermarkAcrossPartitions" ]

valid {
    input.Body.properties.datasource.type == STRING
    input.Body.properties.timeWindow == STRING
    input.Body.properties.sizeWindow == INTEGER
    input.Body.properties.serialization.type == enum_EventSerializationType[_]
    input.Body.properties.watermarkSettings.watermarkMode == enum_OutputWatermarkMode[_]
    input.Body.properties.watermarkSettings.maxWatermarkDifferenceAcrossPartitions == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.outputName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

PrivateEndpoints_CreateOrUpdate

valid {
    input.Body.properties.manualPrivateLinkServiceConnections[_].properties.privateLinkServiceId == STRING
    input.Body.properties.manualPrivateLinkServiceConnections[_].properties.groupIds[_] == STRING
    input.Body.properties.manualPrivateLinkServiceConnections[_].properties.privateLinkServiceConnectionState == {}
    input.Body.STRING == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.clusterName == STRING
    input.ReqMap.privateEndpointName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

PrivateEndpoints_Delete

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.clusterName == STRING
    input.ReqMap.privateEndpointName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

PrivateEndpoints_Get

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.clusterName == STRING
    input.ReqMap.privateEndpointName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

PrivateEndpoints_ListByCluster

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.clusterName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Sku_List

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

StreamingJobs_CreateOrReplace

enum_AuthenticationMode := [ "Msi", "UserToken", "ConnectionString" ]
enum_CompatibilityLevel := [ "1.0", "1.2" ]
enum_CompressionType := [ "None", "GZip", "Deflate" ]
enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_EventsOutOfOrderPolicy := [ "Adjust", "Drop" ]
enum_InputWatermarkMode := [ "None", "ReadWatermark" ]
enum_OutputErrorPolicy := [ "Stop", "Drop" ]
enum_OutputStartMode := [ "JobStartTime", "CustomTime", "LastOutputEventTime" ]
enum_OutputWatermarkMode := [ "None", "SendCurrentPartitionWatermark", "SendLowestWatermarkAcrossPartitions" ]
enum_SkuName := [ "Standard" ]
enum_StreamingJobPropertiesContentStoragePolicy := [ "SystemAccount", "JobStorageAccount" ]
enum_StreamingJobPropertiesJobType := [ "Cloud", "Edge" ]
enum_UpdatableUdfRefreshType := [ "Blocking", "Nonblocking" ]

valid {
    input.Body.sku.name == enum_SkuName[_]
    input.Body.sku.capacity == INTEGER
    input.Body.properties.sku.name == enum_SkuName[_]
    input.Body.properties.sku.capacity == INTEGER
    input.Body.properties.jobType == enum_StreamingJobPropertiesJobType[_]
    input.Body.properties.outputStartMode == enum_OutputStartMode[_]
    input.Body.properties.outputStartTime == STRING
    input.Body.properties.eventsOutOfOrderPolicy == enum_EventsOutOfOrderPolicy[_]
    input.Body.properties.outputErrorPolicy == enum_OutputErrorPolicy[_]
    input.Body.properties.eventsOutOfOrderMaxDelayInSeconds == INTEGER
    input.Body.properties.eventsLateArrivalMaxDelayInSeconds == INTEGER
    input.Body.properties.dataLocale == STRING
    input.Body.properties.compatibilityLevel == enum_CompatibilityLevel[_]
    input.Body.properties.inputs[_].properties.type == STRING
    input.Body.properties.inputs[_].properties.serialization.type == enum_EventSerializationType[_]
    input.Body.properties.inputs[_].properties.compression.type == enum_CompressionType[_]
    input.Body.properties.inputs[_].properties.partitionKey == STRING
    input.Body.properties.inputs[_].properties.watermarkSettings.watermarkMode == enum_InputWatermarkMode[_]
    input.Body.properties.inputs[_].name == STRING
    input.Body.properties.transformation.properties.streamingUnits == INTEGER
    input.Body.properties.transformation.properties.validStreamingUnits[_] == INTEGER
    input.Body.properties.transformation.properties.query == STRING
    input.Body.properties.transformation.name == STRING
    input.Body.properties.outputs[_].properties.datasource.type == STRING
    input.Body.properties.outputs[_].properties.timeWindow == STRING
    input.Body.properties.outputs[_].properties.sizeWindow == INTEGER
    input.Body.properties.outputs[_].properties.serialization.type == enum_EventSerializationType[_]
    input.Body.properties.outputs[_].properties.watermarkSettings.watermarkMode == enum_OutputWatermarkMode[_]
    input.Body.properties.outputs[_].properties.watermarkSettings.maxWatermarkDifferenceAcrossPartitions == STRING
    input.Body.properties.outputs[_].name == STRING
    input.Body.properties.functions[_].properties.type == STRING
    input.Body.properties.functions[_].properties.properties.inputs[_].dataType == STRING
    input.Body.properties.functions[_].properties.properties.inputs[_].isConfigurationParameter == BOOLEAN
    input.Body.properties.functions[_].properties.properties.output.dataType == STRING
    input.Body.properties.functions[_].properties.properties.binding.type == STRING
    input.Body.properties.functions[_].name == STRING
    input.Body.properties.jobStorageAccount.authenticationMode == enum_AuthenticationMode[_]
    input.Body.properties.jobStorageAccount.accountName == STRING
    input.Body.properties.jobStorageAccount.accountKey == STRING
    input.Body.properties.contentStoragePolicy == enum_StreamingJobPropertiesContentStoragePolicy[_]
    input.Body.properties.externals.storageAccount.accountName == STRING
    input.Body.properties.externals.storageAccount.accountKey == STRING
    input.Body.properties.externals.storageAccount.authenticationMode == enum_AuthenticationMode[_]
    input.Body.properties.externals.container == STRING
    input.Body.properties.externals.path == STRING
    input.Body.properties.externals.refreshConfiguration.pathPattern == STRING
    input.Body.properties.externals.refreshConfiguration.dateFormat == STRING
    input.Body.properties.externals.refreshConfiguration.timeFormat == STRING
    input.Body.properties.externals.refreshConfiguration.refreshInterval == STRING
    input.Body.properties.externals.refreshConfiguration.refreshType == enum_UpdatableUdfRefreshType[_]
    input.Body.properties.cluster.id == STRING
    input.Body.identity.type == STRING
    input.Body.identity.userAssignedIdentities.STRING.STRING == STRING
    input.Body.tags.STRING == STRING
    input.Body.location == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

StreamingJobs_Delete

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

StreamingJobs_Get

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.Qs.$expand == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

StreamingJobs_List

valid {
    input.ReqMap.SubscriptionID == STRING
    input.Qs.$expand == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
}

StreamingJobs_ListByResourceGroup

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.Qs.$expand == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

StreamingJobs_Scale

valid {
    input.Body.streamingUnits == INTEGER
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

StreamingJobs_Start

enum_OutputStartMode := [ "JobStartTime", "CustomTime", "LastOutputEventTime" ]

valid {
    input.Body.outputStartMode == enum_OutputStartMode[_]
    input.Body.outputStartTime == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

StreamingJobs_Stop

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

StreamingJobs_Update

enum_AuthenticationMode := [ "Msi", "UserToken", "ConnectionString" ]
enum_CompatibilityLevel := [ "1.0", "1.2" ]
enum_CompressionType := [ "None", "GZip", "Deflate" ]
enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_EventsOutOfOrderPolicy := [ "Adjust", "Drop" ]
enum_InputWatermarkMode := [ "None", "ReadWatermark" ]
enum_OutputErrorPolicy := [ "Stop", "Drop" ]
enum_OutputStartMode := [ "JobStartTime", "CustomTime", "LastOutputEventTime" ]
enum_OutputWatermarkMode := [ "None", "SendCurrentPartitionWatermark", "SendLowestWatermarkAcrossPartitions" ]
enum_SkuName := [ "Standard" ]
enum_StreamingJobPropertiesContentStoragePolicy := [ "SystemAccount", "JobStorageAccount" ]
enum_StreamingJobPropertiesJobType := [ "Cloud", "Edge" ]
enum_UpdatableUdfRefreshType := [ "Blocking", "Nonblocking" ]

valid {
    input.Body.sku.name == enum_SkuName[_]
    input.Body.sku.capacity == INTEGER
    input.Body.properties.sku.name == enum_SkuName[_]
    input.Body.properties.sku.capacity == INTEGER
    input.Body.properties.jobType == enum_StreamingJobPropertiesJobType[_]
    input.Body.properties.outputStartMode == enum_OutputStartMode[_]
    input.Body.properties.outputStartTime == STRING
    input.Body.properties.eventsOutOfOrderPolicy == enum_EventsOutOfOrderPolicy[_]
    input.Body.properties.outputErrorPolicy == enum_OutputErrorPolicy[_]
    input.Body.properties.eventsOutOfOrderMaxDelayInSeconds == INTEGER
    input.Body.properties.eventsLateArrivalMaxDelayInSeconds == INTEGER
    input.Body.properties.dataLocale == STRING
    input.Body.properties.compatibilityLevel == enum_CompatibilityLevel[_]
    input.Body.properties.inputs[_].properties.type == STRING
    input.Body.properties.inputs[_].properties.serialization.type == enum_EventSerializationType[_]
    input.Body.properties.inputs[_].properties.compression.type == enum_CompressionType[_]
    input.Body.properties.inputs[_].properties.partitionKey == STRING
    input.Body.properties.inputs[_].properties.watermarkSettings.watermarkMode == enum_InputWatermarkMode[_]
    input.Body.properties.inputs[_].name == STRING
    input.Body.properties.transformation.properties.streamingUnits == INTEGER
    input.Body.properties.transformation.properties.validStreamingUnits[_] == INTEGER
    input.Body.properties.transformation.properties.query == STRING
    input.Body.properties.transformation.name == STRING
    input.Body.properties.outputs[_].properties.datasource.type == STRING
    input.Body.properties.outputs[_].properties.timeWindow == STRING
    input.Body.properties.outputs[_].properties.sizeWindow == INTEGER
    input.Body.properties.outputs[_].properties.serialization.type == enum_EventSerializationType[_]
    input.Body.properties.outputs[_].properties.watermarkSettings.watermarkMode == enum_OutputWatermarkMode[_]
    input.Body.properties.outputs[_].properties.watermarkSettings.maxWatermarkDifferenceAcrossPartitions == STRING
    input.Body.properties.outputs[_].name == STRING
    input.Body.properties.functions[_].properties.type == STRING
    input.Body.properties.functions[_].properties.properties.inputs[_].dataType == STRING
    input.Body.properties.functions[_].properties.properties.inputs[_].isConfigurationParameter == BOOLEAN
    input.Body.properties.functions[_].properties.properties.output.dataType == STRING
    input.Body.properties.functions[_].properties.properties.binding.type == STRING
    input.Body.properties.functions[_].name == STRING
    input.Body.properties.jobStorageAccount.authenticationMode == enum_AuthenticationMode[_]
    input.Body.properties.contentStoragePolicy == enum_StreamingJobPropertiesContentStoragePolicy[_]
    input.Body.properties.externals.storageAccount.accountName == STRING
    input.Body.properties.externals.storageAccount.accountKey == STRING
    input.Body.properties.externals.storageAccount.authenticationMode == enum_AuthenticationMode[_]
    input.Body.properties.externals.container == STRING
    input.Body.properties.externals.path == STRING
    input.Body.properties.externals.refreshConfiguration.pathPattern == STRING
    input.Body.properties.externals.refreshConfiguration.dateFormat == STRING
    input.Body.properties.externals.refreshConfiguration.timeFormat == STRING
    input.Body.properties.externals.refreshConfiguration.refreshInterval == STRING
    input.Body.properties.externals.refreshConfiguration.refreshType == enum_UpdatableUdfRefreshType[_]
    input.Body.properties.cluster.id == STRING
    input.Body.identity.type == STRING
    input.Body.identity.userAssignedIdentities.STRING.STRING == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Subscriptions_CompileQuery

enum_CompatibilityLevel := [ "1.0", "1.2" ]
enum_CompileQueryJobType := [ "Cloud", "Edge" ]

valid {
    input.Body.query == STRING
    input.Body.inputs[_].name == STRING
    input.Body.inputs[_].type == STRING
    input.Body.functions[_].name == STRING
    input.Body.functions[_].type == STRING
    input.Body.functions[_].bindingType == STRING
    input.Body.functions[_].inputs[_].dataType == STRING
    input.Body.functions[_].inputs[_].isConfigurationParameter == BOOLEAN
    input.Body.functions[_].output.dataType == STRING
    input.Body.jobType == enum_CompileQueryJobType[_]
    input.Body.compatibilityLevel == enum_CompatibilityLevel[_]
    input.ReqMap.location == STRING
    input.ReqMap.SubscriptionID == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
}

Subscriptions_ListQuotas

valid {
    input.ReqMap.location == STRING
    input.ReqMap.SubscriptionID == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
}

Subscriptions_SampleInput

enum_CompressionType := [ "None", "GZip", "Deflate" ]
enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_InputWatermarkMode := [ "None", "ReadWatermark" ]

valid {
    input.Body.input.properties.type == STRING
    input.Body.input.properties.serialization.type == enum_EventSerializationType[_]
    input.Body.input.properties.compression.type == enum_CompressionType[_]
    input.Body.input.properties.partitionKey == STRING
    input.Body.input.properties.watermarkSettings.watermarkMode == enum_InputWatermarkMode[_]
    input.Body.input.name == STRING
    input.Body.compatibilityLevel == STRING
    input.Body.eventsUri == STRING
    input.Body.dataLocale == STRING
    input.ReqMap.location == STRING
    input.ReqMap.SubscriptionID == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
}

Subscriptions_TestInput

enum_CompressionType := [ "None", "GZip", "Deflate" ]
enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_InputWatermarkMode := [ "None", "ReadWatermark" ]

valid {
    input.Body.input.properties.type == STRING
    input.Body.input.properties.serialization.type == enum_EventSerializationType[_]
    input.Body.input.properties.compression.type == enum_CompressionType[_]
    input.Body.input.properties.partitionKey == STRING
    input.Body.input.properties.watermarkSettings.watermarkMode == enum_InputWatermarkMode[_]
    input.Body.input.name == STRING
    input.ReqMap.location == STRING
    input.ReqMap.SubscriptionID == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
}

Subscriptions_TestOutput

enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_OutputWatermarkMode := [ "None", "SendCurrentPartitionWatermark", "SendLowestWatermarkAcrossPartitions" ]

valid {
    input.Body.output.properties.datasource.type == STRING
    input.Body.output.properties.timeWindow == STRING
    input.Body.output.properties.sizeWindow == INTEGER
    input.Body.output.properties.serialization.type == enum_EventSerializationType[_]
    input.Body.output.properties.watermarkSettings.watermarkMode == enum_OutputWatermarkMode[_]
    input.Body.output.properties.watermarkSettings.maxWatermarkDifferenceAcrossPartitions == STRING
    input.Body.output.name == STRING
    input.ReqMap.location == STRING
    input.ReqMap.SubscriptionID == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
}

Subscriptions_TestQuery

enum_AuthenticationMode := [ "Msi", "UserToken", "ConnectionString" ]
enum_CompatibilityLevel := [ "1.0", "1.2" ]
enum_CompressionType := [ "None", "GZip", "Deflate" ]
enum_EventSerializationType := [ "Csv", "Avro", "Json", "CustomClr", "Parquet", "Delta" ]
enum_EventsOutOfOrderPolicy := [ "Adjust", "Drop" ]
enum_InputWatermarkMode := [ "None", "ReadWatermark" ]
enum_OutputErrorPolicy := [ "Stop", "Drop" ]
enum_OutputStartMode := [ "JobStartTime", "CustomTime", "LastOutputEventTime" ]
enum_OutputWatermarkMode := [ "None", "SendCurrentPartitionWatermark", "SendLowestWatermarkAcrossPartitions" ]
enum_SkuName := [ "Standard" ]
enum_StreamingJobPropertiesContentStoragePolicy := [ "SystemAccount", "JobStorageAccount" ]
enum_StreamingJobPropertiesJobType := [ "Cloud", "Edge" ]
enum_UpdatableUdfRefreshType := [ "Blocking", "Nonblocking" ]

valid {
    input.Body.diagnostics.writeUri == STRING
    input.Body.diagnostics.path == STRING
    input.Body.streamingJob.sku.name == enum_SkuName[_]
    input.Body.streamingJob.sku.capacity == INTEGER
    input.Body.streamingJob.properties.sku.name == enum_SkuName[_]
    input.Body.streamingJob.properties.sku.capacity == INTEGER
    input.Body.streamingJob.properties.jobType == enum_StreamingJobPropertiesJobType[_]
    input.Body.streamingJob.properties.outputStartMode == enum_OutputStartMode[_]
    input.Body.streamingJob.properties.outputStartTime == STRING
    input.Body.streamingJob.properties.eventsOutOfOrderPolicy == enum_EventsOutOfOrderPolicy[_]
    input.Body.streamingJob.properties.outputErrorPolicy == enum_OutputErrorPolicy[_]
    input.Body.streamingJob.properties.eventsOutOfOrderMaxDelayInSeconds == INTEGER
    input.Body.streamingJob.properties.eventsLateArrivalMaxDelayInSeconds == INTEGER
    input.Body.streamingJob.properties.dataLocale == STRING
    input.Body.streamingJob.properties.compatibilityLevel == enum_CompatibilityLevel[_]
    input.Body.streamingJob.properties.inputs[_].properties.type == STRING
    input.Body.streamingJob.properties.inputs[_].properties.serialization.type == enum_EventSerializationType[_]
    input.Body.streamingJob.properties.inputs[_].properties.compression.type == enum_CompressionType[_]
    input.Body.streamingJob.properties.inputs[_].properties.partitionKey == STRING
    input.Body.streamingJob.properties.inputs[_].properties.watermarkSettings.watermarkMode == enum_InputWatermarkMode[_]
    input.Body.streamingJob.properties.inputs[_].name == STRING
    input.Body.streamingJob.properties.transformation.properties.streamingUnits == INTEGER
    input.Body.streamingJob.properties.transformation.properties.validStreamingUnits[_] == INTEGER
    input.Body.streamingJob.properties.transformation.properties.query == STRING
    input.Body.streamingJob.properties.transformation.name == STRING
    input.Body.streamingJob.properties.outputs[_].properties.datasource.type == STRING
    input.Body.streamingJob.properties.outputs[_].properties.timeWindow == STRING
    input.Body.streamingJob.properties.outputs[_].properties.sizeWindow == INTEGER
    input.Body.streamingJob.properties.outputs[_].properties.serialization.type == enum_EventSerializationType[_]
    input.Body.streamingJob.properties.outputs[_].properties.watermarkSettings.watermarkMode == enum_OutputWatermarkMode[_]
    input.Body.streamingJob.properties.outputs[_].properties.watermarkSettings.maxWatermarkDifferenceAcrossPartitions == STRING
    input.Body.streamingJob.properties.outputs[_].name == STRING
    input.Body.streamingJob.properties.functions[_].properties.type == STRING
    input.Body.streamingJob.properties.functions[_].properties.properties.inputs[_].dataType == STRING
    input.Body.streamingJob.properties.functions[_].properties.properties.inputs[_].isConfigurationParameter == BOOLEAN
    input.Body.streamingJob.properties.functions[_].properties.properties.output.dataType == STRING
    input.Body.streamingJob.properties.functions[_].properties.properties.binding.type == STRING
    input.Body.streamingJob.properties.functions[_].name == STRING
    input.Body.streamingJob.properties.jobStorageAccount.authenticationMode == enum_AuthenticationMode[_]
    input.Body.streamingJob.properties.jobStorageAccount.accountName == STRING
    input.Body.streamingJob.properties.jobStorageAccount.accountKey == STRING
    input.Body.streamingJob.properties.contentStoragePolicy == enum_StreamingJobPropertiesContentStoragePolicy[_]
    input.Body.streamingJob.properties.externals.storageAccount.accountName == STRING
    input.Body.streamingJob.properties.externals.storageAccount.accountKey == STRING
    input.Body.streamingJob.properties.externals.storageAccount.authenticationMode == enum_AuthenticationMode[_]
    input.Body.streamingJob.properties.externals.container == STRING
    input.Body.streamingJob.properties.externals.path == STRING
    input.Body.streamingJob.properties.externals.refreshConfiguration.pathPattern == STRING
    input.Body.streamingJob.properties.externals.refreshConfiguration.dateFormat == STRING
    input.Body.streamingJob.properties.externals.refreshConfiguration.timeFormat == STRING
    input.Body.streamingJob.properties.externals.refreshConfiguration.refreshInterval == STRING
    input.Body.streamingJob.properties.externals.refreshConfiguration.refreshType == enum_UpdatableUdfRefreshType[_]
    input.Body.streamingJob.properties.cluster.id == STRING
    input.Body.streamingJob.identity.type == STRING
    input.Body.streamingJob.identity.userAssignedIdentities.STRING.STRING == STRING
    input.Body.streamingJob.tags.STRING == STRING
    input.Body.streamingJob.location == STRING
    input.ReqMap.location == STRING
    input.ReqMap.SubscriptionID == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
}

Transformations_CreateOrReplace

valid {
    input.Body.properties.streamingUnits == INTEGER
    input.Body.properties.validStreamingUnits[_] == INTEGER
    input.Body.properties.query == STRING
    input.Body.name == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.transformationName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Transformations_Get

valid {
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.transformationName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Transformations_Update

valid {
    input.Body.properties.streamingUnits == INTEGER
    input.Body.properties.validStreamingUnits[_] == INTEGER
    input.Body.properties.query == STRING
    input.ReqMap.SubscriptionID == STRING
    input.ReqMap.ResourceGroup == STRING
    input.ReqMap.jobName == STRING
    input.ReqMap.transformationName == STRING
    input.Qs.api-version == STRING
    input.ProviderMetadata.Region == STRING
    input.ProviderMetadata.SubscriptionID == STRING
    input.ProviderMetadata.ResourceGroup == STRING
}

Updated 8 days ago