Add Reflex, Event Set, and SubnetResourceId property

specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/preview/2021-10-01-preview/inputs.json

@@ -479,6 +479,10 @@
         "watermarkSettings": {
           "$ref": "#/definitions/InputWatermarkProperties",
           "description": "Settings which determine whether to read watermark events."
+        },
+        "messagingCatalogConfiguration": {
+          "$ref": "#/definitions/MessagingCatalogConfiguration",
+          "description": "Messaging catalog configuration"
         }
       },
       "required": [
@@ -1448,6 +1452,115 @@
         "name": "InputWatermarkMode",
         "modelAsString": true
       }
+    },
+    "MessagingCatalogConfiguration": {
+      "type": "string",
+      "description": "The messaging catalog configuration.",
+      "properties": {
+        "endpoint": {
+          "type": "string",
+          "description": "endpoint"
+        },
+        "errorPolicy": {
+          "$ref": "#/definitions/SchemaRegistryErrorPolicy",
+          "description": "errorPolicy"
+        },
+        "messages": {
+          "type": "array",
+          "items": {
+            "$ref": "#/definitions/Message"
+          },
+          "description": "messages"
+        },
+        "schemaGroups": {
+          "type": "array",
+          "items": {
+            "$ref": "#/definitions/SchemaGroup"
+          },
+          "description": "schemaGroups"
+        },
+        "format": {
+          "$ref": "#/definitions/MessagingCatalogMessageFormat",
+          "description": "format"
+        },
+        "protocol": {
+          "$ref": "#/definitions/MessagingCatalogProtocol",
+          "description": "protocol"
+        },
+        "schemaFormat": {
+          "type": "string",
+          "description": "schema"
+        },
+        "authenticationMode": {
+          "$ref": "../../common/v1/definitions.json#/definitions/AuthenticationMode",
+          "description": "Authentication Mode."
+        }
+      }
+    },
+    "SchemaRegistryErrorPolicy": {
+      "type": "string",
+      "description": "The schema registry error policy.",
+      "enum": [
+        "Drop",
+        "Accept"
+      ],
+      "x-ms-enum": {
+        "name": "SchemaRegistryErrorPolicy",
+        "modelAsString": true
+      }
+    },
+    "Message": {
+      "description": "The message properties",
+      "type": "object",
+      "properties": {
+        "messageGroupId": {
+          "type": "string",
+          "description": "The message group id."
+        },
+        "messageId": {
+          "type": "string",
+          "description": "The message id."
+        },
+        "schemaVersion": {
+          "type": "string",
+          "description": "The schema version."
+        }
+      }
+    },
+    "SchemaGroup": {
+      "description": "The schema group",
+      "type": "object",
+      "properties": {
+        "id": {
+          "type": "string",
+          "description": "The schema group id."
+        }
+      }
+    },
+    "MessagingCatalogMessageFormat": {
+      "type": "string",
+      "description": "The messaging catalog message format.",
+      "enum": [
+        "NotSet",
+        "CloudEvents_1_0"
+      ],
+      "x-ms-enum": {
+        "name": "MessagingCatalogMessageFormat",
+        "modelAsString": true
+      }
+    },
+    "MessagingCatalogProtocol": {
+      "type": "string",
+      "description": "The messaging catalog protocol.",
+      "enum": [
+        "NotSet",
+        "Any",
+        "AMQP_1_0"
+      ],
+      "x-ms-enum": {
+        "name": "MessagingCatalogProtocol",
+        "modelAsString": true
+      }
     }
   },
   "parameters": {

specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/preview/2021-10-01-preview/outputs.json

@@ -1207,6 +1207,47 @@
         }
       }
     },
+    "ReflexOutputDataSource": {
+      "type": "object",
+      "description": "Describes a Reflex output data source.",
+      "x-ms-discriminator-value": "Reflex",
+      "allOf": [
+        {
+          "$ref": "#/definitions/OutputDataSource"
+        }
+      ],
+      "properties": {
+        "properties": {
+          "$ref": "#/definitions/ReflexOutputDataSourceProperties",
+          "description": "The properties that are associated with a Reflex output. Required on PUT (CreateOrReplace) requests.",
+          "x-ms-client-flatten": true
+        }
+      }
+    },
+    "ReflexOutputDataSourceProperties": {
+      "type": "object",
+      "description": "The properties that are associated with a Reflex output.",
+      "allOf": [
+        {
+          "$ref": "#/definitions/OAuthBasedDataSourceProperties"
+        }
+      ],
+      "properties": {
+        "AegSubscriptionName": {
+          "type": "string",
+          "description": "Unique ASA query ID. For EventGrid it's an unique subscription name, set internally by EventGrid on subscription creation."
+        },
+        "FabricEsName": {
+          "type": "string",
+          "description": "Public EG populates aeg-subscription-name with the subscription name set by the subscription creator. This header was added, because Fabric EG didn't populate aeg-subscription-name with our set value, but EG internal value. The EG subscription name set by us during creation gets populated to fabris-es-name. There is no additional validation to ensure the existence of the subscription, so both aeg-subscription-name and fabris-es-name can be set to any ID that best represents the ASA query subscription."
+        },
+        "WebhookUrl": {
+          "type": "string",
+          "description": "Webhook URL Format: https://{RegionCode}.data.activator.pipe.{WebhookEnvironment}.aria.trafficmanager.net/api/v2/OneRiv
+          er/PushEvents/{tenantId}/{sourceType}/{eventName}"
+        }
+      }
+    },
     "GatewayMessageBusOutputDataSourceProperties": {
       "type": "object",
       "description": "The properties that are associated with a Gateway Message Bus.",

specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/preview/2021-10-01-preview/streamingjobs.json

@@ -844,6 +844,10 @@
         "cluster": {
           "$ref": "#/definitions/ClusterInfo",
           "description": "The cluster which streaming jobs will run on."
+        },
+        "subnetResourceId": {
+          "type": "string",
+          "description": "The subnet resource id that the user can link their streaming job to."
         }
       }
     },