Skip to content

Commit 155b407

Browse files
SDKAutoVincent Feng
andcommitted
CodeGen from PR 22092 in Azure/azure-rest-api-specs
[Hub Generated] Review request for Microsoft.StreamAnalytics to add version preview/2021-10-01-preview (#22092) * Added support for Delta Lake output * Corrected api version * Fixed LPO issues. Co-authored-by: Vincent Feng <vifeng@microsoft.com>
1 parent 5c1df54 commit 155b407

File tree

2 files changed

+112
-0
lines changed

2 files changed

+112
-0
lines changed

schemas/2017-04-01-preview/Microsoft.StreamAnalytics.json

Lines changed: 56 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1402,6 +1402,59 @@
14021402
},
14031403
"description": "The properties that are associated with the CustomClr serialization type."
14041404
},
1405+
"DeltaSerialization": {
1406+
"type": "object",
1407+
"properties": {
1408+
"properties": {
1409+
"oneOf": [
1410+
{
1411+
"$ref": "#/definitions/DeltaSerializationProperties"
1412+
},
1413+
{
1414+
"$ref": "https://schema.management.azure.com/schemas/common/definitions.json#/definitions/expression"
1415+
}
1416+
],
1417+
"description": "The properties that are associated with the Delta Lake serialization type."
1418+
},
1419+
"type": {
1420+
"type": "string",
1421+
"enum": [
1422+
"Delta"
1423+
]
1424+
}
1425+
},
1426+
"required": [
1427+
"type"
1428+
],
1429+
"description": "Describes how data from an input is serialized or how data is serialized when written to an output in Delta Lake format."
1430+
},
1431+
"DeltaSerializationProperties": {
1432+
"type": "object",
1433+
"properties": {
1434+
"deltaTablePath": {
1435+
"type": "string",
1436+
"description": "Specifies the path of the Delta Lake table that the output will be written to."
1437+
},
1438+
"partitionColumns": {
1439+
"oneOf": [
1440+
{
1441+
"type": "array",
1442+
"items": {
1443+
"type": "string"
1444+
}
1445+
},
1446+
{
1447+
"$ref": "https://schema.management.azure.com/schemas/common/definitions.json#/definitions/expression"
1448+
}
1449+
],
1450+
"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."
1451+
}
1452+
},
1453+
"required": [
1454+
"deltaTablePath"
1455+
],
1456+
"description": "The properties that are associated with the Delta Lake serialization type."
1457+
},
14051458
"DocumentDbOutputDataSource": {
14061459
"type": "object",
14071460
"properties": {
@@ -2439,6 +2492,9 @@
24392492
"Serialization": {
24402493
"type": "object",
24412494
"oneOf": [
2495+
{
2496+
"$ref": "#/definitions/DeltaSerialization"
2497+
},
24422498
{
24432499
"$ref": "#/definitions/ParquetSerialization"
24442500
},

schemas/2021-10-01-preview/Microsoft.StreamAnalytics.json

Lines changed: 56 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1530,6 +1530,59 @@
15301530
},
15311531
"description": "The properties that are associated with the CustomClr serialization type."
15321532
},
1533+
"DeltaSerialization": {
1534+
"type": "object",
1535+
"properties": {
1536+
"properties": {
1537+
"oneOf": [
1538+
{
1539+
"$ref": "#/definitions/DeltaSerializationProperties"
1540+
},
1541+
{
1542+
"$ref": "https://schema.management.azure.com/schemas/common/definitions.json#/definitions/expression"
1543+
}
1544+
],
1545+
"description": "The properties that are associated with the Delta Lake serialization type."
1546+
},
1547+
"type": {
1548+
"type": "string",
1549+
"enum": [
1550+
"Delta"
1551+
]
1552+
}
1553+
},
1554+
"required": [
1555+
"type"
1556+
],
1557+
"description": "Describes how data from an input is serialized or how data is serialized when written to an output in Delta Lake format."
1558+
},
1559+
"DeltaSerializationProperties": {
1560+
"type": "object",
1561+
"properties": {
1562+
"deltaTablePath": {
1563+
"type": "string",
1564+
"description": "Specifies the path of the Delta Lake table that the output will be written to."
1565+
},
1566+
"partitionColumns": {
1567+
"oneOf": [
1568+
{
1569+
"type": "array",
1570+
"items": {
1571+
"type": "string"
1572+
}
1573+
},
1574+
{
1575+
"$ref": "https://schema.management.azure.com/schemas/common/definitions.json#/definitions/expression"
1576+
}
1577+
],
1578+
"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."
1579+
}
1580+
},
1581+
"required": [
1582+
"deltaTablePath"
1583+
],
1584+
"description": "The properties that are associated with the Delta Lake serialization type."
1585+
},
15331586
"DocumentDbOutputDataSource": {
15341587
"type": "object",
15351588
"properties": {
@@ -3019,6 +3072,9 @@
30193072
"Serialization": {
30203073
"type": "object",
30213074
"oneOf": [
3075+
{
3076+
"$ref": "#/definitions/DeltaSerialization"
3077+
},
30223078
{
30233079
"$ref": "#/definitions/ParquetSerialization"
30243080
},

0 commit comments

Comments
 (0)