Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"parameters": {
"api-version": "2020-03-01",
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg8440",
"jobName": "sj9597",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,17 @@
},
"responses": {
"200": {
"headers": {
"Location": "https://management.azure.com/subscriptions/subscriptionId/resourceGroups/resourceGroup/providers/Microsoft.StreamAnalytics/streamingjobs/jobName/inputs/inputName?api-version=2021-10-01-preview"
},
"body": {
"status": "TestSucceeded"
}
},
"202": {}
"202": {
"headers": {
"Location": "https://management.azure.com/subscriptions/subscriptionId/resourceGroups/resourceGroup/providers/Microsoft.StreamAnalytics/streamingjobs/jobName/inputs/inputName?api-version=2021-10-01-preview"
}
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,103 @@
{
"parameters": {
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg",
"jobName": "sjName",
"outputName": "output1221",
"output": {
"properties": {
"datasource": {
"type": "Microsoft.Storage/Blob",
"properties": {
"storageAccounts": [
{
"accountName": "someAccountName",
"accountKey": "accountKey=="
}
],
"container": "deltaoutput",
"pathPattern": null,
"dateFormat": null,
"timeFormat": null
}
},
"serialization": {
"type": "Delta",
"properties": {
"deltaTablePath": "/folder1/table1",
"partitionColumns": [
"column1"
]
}
}
}
}
},
"responses": {
"201": {
"headers": {
"ETag": "219b3b09-f823-4d78-ace0-90e24c12c501"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/output1221",
"name": "output1221",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "Microsoft.Storage/Blob",
"properties": {
"storageAccounts": [
{
"accountName": "someAccountName"
}
],
"container": "deltaoutput"
}
},
"serialization": {
"type": "Delta",
"properties": {
"deltaTablePath": "/folder1/table1",
"partitionColumns": [
"column1"
]
}
}
}
}
},
"200": {
"headers": {
"ETag": "219b3b09-f823-4d78-ace0-90e24c12c501"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/output1221",
"name": "output1221",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "Microsoft.Storage/Blob",
"properties": {
"storageAccounts": [
{
"accountName": "someAccountName"
}
],
"container": "deltaoutput"
}
},
"serialization": {
"type": "Delta",
"properties": {
"deltaTablePath": "/folder1/table1",
"partitionColumns": [
"column1"
]
}
}
}
}
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,43 @@
{
"parameters": {
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg",
"jobName": "sjName",
"outputName": "output1221"
},
"responses": {
"200": {
"headers": {
"ETag": "219b3b09-f823-4d78-ace0-90e24c12c501"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/output1221",
"name": "output1221",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "Microsoft.Storage/Blob",
"properties": {
"storageAccounts": [
{
"accountName": "someAccountName"
}
],
"container": "deltaoutput"
}
},
"serialization": {
"type": "Delta",
"properties": {
"deltaTablePath": "/folder1/table1",
"partitionColumns": [
"column1"
]
}
}
}
}
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,17 @@
},
"responses": {
"200": {
"headers": {
"Location": "https://management.azure.com/subscriptions/subscriptionId/resourceGroups/resourceGroup/providers/Microsoft.StreamAnalytics/streamingjobs/jobName/outputs/outputName?api-version=2021-10-01-preview"
},
"body": {
"status": "TestSucceeded"
}
},
"202": {}
"202": {
"headers": {
"Location": "https://management.azure.com/subscriptions/subscriptionId/resourceGroups/resourceGroup/providers/Microsoft.StreamAnalytics/streamingjobs/jobName/outputs/outputName?api-version=2021-10-01-preview"
}
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,62 @@
{
"parameters": {
"api-version": "2021-10-01-preview",
"subscriptionId": "56b5e0a9-b645-407d-99b0-c64f86013e3d",
"resourceGroupName": "sjrg",
"jobName": "sjName",
"outputName": "output1221",
"output": {
"properties": {
"datasource": {
"type": "Microsoft.Storage/Blob",
"properties": {
"container": "deltaoutput2"
}
},
"serialization": {
"type": "Delta",
"properties": {
"deltaTablePath": "/folder1/table2",
"partitionColumns": [
"column2"
]
}
}
}
}
},
"responses": {
"200": {
"headers": {
"ETag": "219b3b09-f823-4d78-ace0-90e24c12c501"
},
"body": {
"id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/output1221",
"name": "output1221",
"type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
"properties": {
"datasource": {
"type": "Microsoft.Storage/Blob",
"properties": {
"storageAccounts": [
{
"accountName": "someAccountName"
}
],
"container": "deltaoutput2"
}
},
"serialization": {
"type": "Delta",
"properties": {
"deltaTablePath": "/folder1/table2",
"partitionColumns": [
"column2"
]
}
}
}
}
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -971,13 +971,51 @@
"Avro",
"Json",
"CustomClr",
"Parquet"
"Parquet",
"Delta"
],
"x-ms-enum": {
"name": "EventSerializationType",
"modelAsString": true
}
},
"DeltaSerialization": {
"type": "object",
"description": "Describes how data from an input is serialized or how data is serialized when written to an output in Delta Lake format.",
"x-ms-discriminator-value": "Delta",
"allOf": [
{
"$ref": "#/definitions/Serialization"
}
],
"properties": {
"properties": {
"$ref": "#/definitions/DeltaSerializationProperties",
"description": "The properties that are associated with the Delta Lake serialization type. Required on PUT (CreateOrReplace) requests.",
"x-ms-client-flatten": true
}
}
},
"DeltaSerializationProperties": {
"type": "object",
"description": "The properties that are associated with the Delta Lake serialization type.",
"properties": {
"deltaTablePath": {
"type": "string",
"description": "Specifies the path of the Delta Lake table that the output will be written to."
},
"partitionColumns": {
"type": "array",
"items": {
"type": "string"
},
"description": "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."
}
},
"required": [
"deltaTablePath"
]
},
"ParquetSerialization": {
"type": "object",
"description": "Describes how data from an input is serialized or how data is serialized when written to an output in Parquet format.",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -79,6 +79,9 @@
},
"Create a PostgreSQL output": {
"$ref": "./examples/Output_Create_PostgreSQL.json"
},
"Create a Delta Lake output": {
"$ref": "./examples/Output_Create_DeltaLake.json"
}
},
"parameters": [
Expand Down Expand Up @@ -195,6 +198,9 @@
},
"Update an Azure Data Lake Store output with JSON serialization": {
"$ref": "./examples/Output_Update_AzureDataLakeStore.json"
},
"Update a Delta Lake output": {
"$ref": "./examples/Output_Update_DeltaLake.json"
}
},
"parameters": [
Expand Down Expand Up @@ -334,6 +340,9 @@
},
"Get an Azure Data Lake Store output with JSON serialization": {
"$ref": "./examples/Output_Get_AzureDataLakeStore_JSON.json"
},
"Get a Delta Lake output": {
"$ref": "./examples/Output_Get_DeltaLake.json"
}
},
"parameters": [
Expand Down