MICROSOFT.STREAMANALYTICS
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 7 months ago