mirror of
https://github.com/microsoft/fabric-rest-api-specs.git
synced 2026-11-04 12:04:23 +00:00
Updating swagger files.
This commit is contained in:
Fabric-APIs-Publish-Specification-Pipeline committed
1 parent
a886167a8e
commit
2946344ff3
29 files changed
+5233
No files matched your search
@@ -0,0 +1,139 @@
|
||||
{
|
||||
"swagger": "2.0",
|
||||
"info": {
|
||||
"version": "v1",
|
||||
"title": "Eventstream data types"
|
||||
},
|
||||
"paths": {},
|
||||
"definitions": {
|
||||
"Eventstreams": {
|
||||
"description": "A list of eventstreams.",
|
||||
"required": ["value"],
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"value": {
|
||||
"description": "A list of eventstreams.",
|
||||
"type": "array",
|
||||
"items": {
|
||||
"$ref": "#/definitions/Eventstream"
|
||||
}
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "../common/definitions.json#/definitions/PaginatedResponse"
|
||||
}
|
||||
]
|
||||
},
|
||||
"Eventstream": {
|
||||
"description": "An eventstream object.",
|
||||
"type": "object",
|
||||
"required": ["type"],
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "../common/definitions.json#/definitions/Item"
|
||||
}
|
||||
]
|
||||
},
|
||||
"CreateEventstreamRequest": {
|
||||
"description": "Create eventstream request payload.",
|
||||
"type": "object",
|
||||
"required": ["displayName"],
|
||||
"properties": {
|
||||
"displayName": {
|
||||
"description": "The eventstream display name. The display name must follow naming rules according to item type.",
|
||||
"type": "string",
|
||||
"readOnly": false
|
||||
},
|
||||
"description": {
|
||||
"description": "The eventstream description. Maximum length is 256 characters.",
|
||||
"type": "string",
|
||||
"readOnly": false
|
||||
},
|
||||
"definition": {
|
||||
"description": "The [eventstream public definition](/rest/api/fabric/articles/item-management/definitions/eventstream-definition).",
|
||||
"$ref": "#/definitions/EventstreamDefinition",
|
||||
"readOnly": false
|
||||
}
|
||||
}
|
||||
},
|
||||
"UpdateEventstreamDefinitionRequest": {
|
||||
"description": "Update eventstream public definition request payload.",
|
||||
"type": "object",
|
||||
"required": ["definition"],
|
||||
"properties": {
|
||||
"definition": {
|
||||
"$ref": "#/definitions/EventstreamDefinition"
|
||||
}
|
||||
}
|
||||
},
|
||||
"EventstreamDefinitionResponse": {
|
||||
"description": "Eventstream public definition response.",
|
||||
"type": "object",
|
||||
"required": ["definition"],
|
||||
"properties": {
|
||||
"definition": {
|
||||
"$ref": "#/definitions/EventstreamDefinition",
|
||||
"readOnly": true
|
||||
}
|
||||
}
|
||||
},
|
||||
"EventstreamDefinition" : {
|
||||
"description": "Eventstream public definition object.",
|
||||
"type": "object",
|
||||
"required": ["parts"],
|
||||
"properties": {
|
||||
"format": {
|
||||
"description": "The format of the item definition.",
|
||||
"type": "string",
|
||||
"readOnly": false
|
||||
},
|
||||
"parts": {
|
||||
"description": "A list of definition parts.",
|
||||
"type": "array",
|
||||
"items": {
|
||||
"$ref": "#/definitions/EventstreamDefinitionPart"
|
||||
},
|
||||
"readOnly": false
|
||||
}
|
||||
}
|
||||
},
|
||||
"EventstreamDefinitionPart": {
|
||||
"description": "Eventstream definition part object.",
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"path": {
|
||||
"description": "The eventstream part path.",
|
||||
"type": "string",
|
||||
"readOnly": false
|
||||
},
|
||||
"payload": {
|
||||
"description": "The eventstream part payload.",
|
||||
"type": "string",
|
||||
"readOnly": false
|
||||
},
|
||||
"payloadType":{
|
||||
"description": "The payload type.",
|
||||
"$ref": "../common/definitions.json#/definitions/PayloadType",
|
||||
"readOnly": false
|
||||
}
|
||||
}
|
||||
},
|
||||
"UpdateEventstreamRequest": {
|
||||
"description": "Update eventstream request.",
|
||||
"type": "object",
|
||||
"properties": {
|
||||
"displayName": {
|
||||
"description": "The eventstream display name. The display name must follow naming rules according to item type.",
|
||||
"type": "string",
|
||||
"readOnly": false
|
||||
},
|
||||
"description": {
|
||||
"description": "The eventstream description. Maximum length is 256 characters.",
|
||||
"type": "string",
|
||||
"readOnly": false
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,247 @@
|
||||
{
|
||||
"swagger": "2.0",
|
||||
"info": {
|
||||
"version": "v1",
|
||||
"title": "Eventstream common data types"
|
||||
},
|
||||
"paths": {},
|
||||
"definitions": {
|
||||
"CompatibilityLevel": {
|
||||
"type": "string",
|
||||
"description": "Represents the compatibility level of the Eventstream topology. Additional compatibility levels may be added over time.",
|
||||
"enum": [
|
||||
"1.0"
|
||||
],
|
||||
"x-ms-enum": {
|
||||
"name": "CompatibilityLevel",
|
||||
"modelAsString": true,
|
||||
"values": [
|
||||
{
|
||||
"value": "1.0",
|
||||
"description": "The compatibility level of the Eventstream topology is 1.0."
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
"NodeReference": {
|
||||
"type": "object",
|
||||
"description": "Represents a reference to a node using its unique name.",
|
||||
"required": [
|
||||
"name"
|
||||
],
|
||||
"properties": {
|
||||
"name": {
|
||||
"type": "string",
|
||||
"description": "The unique name of the node."
|
||||
}
|
||||
}
|
||||
},
|
||||
"RuntimeInformation": {
|
||||
"type": "object",
|
||||
"description": "Represents the runtime information of a node.",
|
||||
"required": [
|
||||
"status"
|
||||
],
|
||||
"properties": {
|
||||
"status": {
|
||||
"type": "string",
|
||||
"description": "The status of the node. Additional node status may be added over time.",
|
||||
"enum": [
|
||||
"Unknown",
|
||||
"Creating",
|
||||
"Created",
|
||||
"Updating",
|
||||
"Running",
|
||||
"Paused",
|
||||
"Failed",
|
||||
"Warning",
|
||||
"Deleting",
|
||||
"Pausing",
|
||||
"Resuming",
|
||||
"External"
|
||||
],
|
||||
"x-ms-enum": {
|
||||
"name": "NodeStatus",
|
||||
"modelAsString": true,
|
||||
"values": [
|
||||
{
|
||||
"value": "Unknown",
|
||||
"description": "The status of the node is unknown."
|
||||
},
|
||||
{
|
||||
"value": "Creating",
|
||||
"description": "The node is being created."
|
||||
},
|
||||
{
|
||||
"value": "Created",
|
||||
"description": "The node has been created."
|
||||
},
|
||||
{
|
||||
"value": "Updating",
|
||||
"description": "The node is being updated."
|
||||
},
|
||||
{
|
||||
"value": "Running",
|
||||
"description": "The node is running."
|
||||
},
|
||||
{
|
||||
"value": "Paused",
|
||||
"description": "The node is paused."
|
||||
},
|
||||
{
|
||||
"value": "Failed",
|
||||
"description": "The node has failed."
|
||||
},
|
||||
{
|
||||
"value": "Warning",
|
||||
"description": "The node has a warning."
|
||||
},
|
||||
{
|
||||
"value": "Deleting",
|
||||
"description": "The node is being deleted."
|
||||
},
|
||||
{
|
||||
"value": "Pausing",
|
||||
"description": "The node is being paused."
|
||||
},
|
||||
{
|
||||
"value": "Resuming",
|
||||
"description": "The node is being resumed."
|
||||
},
|
||||
{
|
||||
"value": "External",
|
||||
"description": "The node status depends on an external service."
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
"error": {
|
||||
"$ref": "#/definitions/ErrorInfo",
|
||||
"description": "The error information."
|
||||
}
|
||||
}
|
||||
},
|
||||
"ErrorInfo": {
|
||||
"type": "object",
|
||||
"description": "Represents the error information.",
|
||||
"required": [
|
||||
"errorMessage"
|
||||
],
|
||||
"properties": {
|
||||
"errorCode": {
|
||||
"type": "string",
|
||||
"description": "The error code."
|
||||
},
|
||||
"errorMessage": {
|
||||
"type": "string",
|
||||
"description": "The error message."
|
||||
},
|
||||
"errorDetails": {
|
||||
"type": "array",
|
||||
"description": "The error details.",
|
||||
"items": {
|
||||
"type": "string"
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
"BaseCustomEndpointConnection": {
|
||||
"type": "object",
|
||||
"description": "Represents the connection information for a custom endpoint.",
|
||||
"required": [
|
||||
"fullyQualifiedNamespace",
|
||||
"eventHubName"
|
||||
],
|
||||
"properties": {
|
||||
"fullyQualifiedNamespace": {
|
||||
"type": "string",
|
||||
"description": "The fully qualified namespace of the EventHub."
|
||||
},
|
||||
"eventHubName": {
|
||||
"type": "string",
|
||||
"description": "The name of the EventHub."
|
||||
},
|
||||
"accessKeys": {
|
||||
"type": "object",
|
||||
"description": "The access keys.",
|
||||
"items": {
|
||||
"$ref": "#/definitions/AccessKeys"
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
"AccessKeys": {
|
||||
"type": "object",
|
||||
"description": "The access keys.",
|
||||
"required": [
|
||||
"primaryKey",
|
||||
"secondaryKey",
|
||||
"primaryConnectionString",
|
||||
"secondaryConnectionString"
|
||||
],
|
||||
"properties": {
|
||||
"primaryKey": {
|
||||
"type": "string",
|
||||
"description": "The primary key."
|
||||
},
|
||||
"secondaryKey": {
|
||||
"type": "string",
|
||||
"description": "The secondary key."
|
||||
},
|
||||
"primaryConnectionString": {
|
||||
"type": "string",
|
||||
"description": "The primary connection string."
|
||||
},
|
||||
"secondaryConnectionString": {
|
||||
"type": "string",
|
||||
"description": "The secondary connection string."
|
||||
}
|
||||
}
|
||||
},
|
||||
"DataSourceStartType": {
|
||||
"type": "string",
|
||||
"description": "Represents the start type of the data source. Additional start types may be added over time.",
|
||||
"enum": [
|
||||
"Now",
|
||||
"WhenLastStopped",
|
||||
"CustomTime"
|
||||
],
|
||||
"x-ms-enum": {
|
||||
"name": "DataSourceStartType",
|
||||
"modelAsString": true,
|
||||
"values": [
|
||||
{
|
||||
"value": "Now",
|
||||
"description": "The data source starts now."
|
||||
},
|
||||
{
|
||||
"value": "WhenLastStopped",
|
||||
"description": "The data source starts when it was last stopped."
|
||||
},
|
||||
{
|
||||
"value": "CustomTime",
|
||||
"description": "The data source starts at a custom time."
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
"DataSourceStartRequest": {
|
||||
"type": "object",
|
||||
"description": "Represents the request to start a data source.",
|
||||
"required": [
|
||||
"startType"
|
||||
],
|
||||
"properties": {
|
||||
"startType": {
|
||||
"$ref": "#/definitions/DataSourceStartType",
|
||||
"description": "The start type of the data source."
|
||||
},
|
||||
"customStartDateTime": {
|
||||
"type": "string",
|
||||
"description": "The custom start time of the data source in UTC, using the YYYY-MM-DDTHH:mm:ssZ format.",
|
||||
"format": "date-time"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,341 @@
|
||||
{
|
||||
"swagger": "2.0",
|
||||
"info": {
|
||||
"version": "v1",
|
||||
"title": "Eventstream destination data types"
|
||||
},
|
||||
"paths": {},
|
||||
"definitions": {
|
||||
"DestinationType": {
|
||||
"type": "string",
|
||||
"description": "Represents the type of the destination. Additional destination types may be added over time.",
|
||||
"enum": [
|
||||
"Activator",
|
||||
"CustomEndpoint",
|
||||
"Eventhouse",
|
||||
"Lakehouse"
|
||||
],
|
||||
"x-ms-enum": {
|
||||
"name": "DestinationType",
|
||||
"modelAsString": true,
|
||||
"values": [
|
||||
{
|
||||
"value": "Activator",
|
||||
"description": "The Activator destination type."
|
||||
},
|
||||
{
|
||||
"value": "CustomEndpoint",
|
||||
"description": "The CustomEndpoint destination type."
|
||||
},
|
||||
{
|
||||
"value": "Eventhouse",
|
||||
"description": "The Eventhouse destination type."
|
||||
},
|
||||
{
|
||||
"value": "Lakehouse",
|
||||
"description": "The Lakehouse destination type."
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
"BaseDestination": {
|
||||
"type": "object",
|
||||
"description": "Represents the base Eventstream destination.",
|
||||
"required": [
|
||||
"name",
|
||||
"inputNodes"
|
||||
],
|
||||
"properties": {
|
||||
"id": {
|
||||
"type": "string",
|
||||
"description": "The unique identifier of the destination.",
|
||||
"format": "uuid"
|
||||
},
|
||||
"name": {
|
||||
"type": "string",
|
||||
"description": "The unique name of the destination."
|
||||
},
|
||||
"inputNodes": {
|
||||
"type": "array",
|
||||
"description": "A list of the references to the input nodes of the destination.",
|
||||
"items": {
|
||||
"$ref": "./common.json#/definitions/NodeReference"
|
||||
}
|
||||
},
|
||||
"inputSchemas": {
|
||||
"type": "array",
|
||||
"description": "The input schemas of the destination.",
|
||||
"items": {
|
||||
"$ref": "operatorCommon.json#/definitions/InputSchema"
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
"DestinationResponse": {
|
||||
"type": "object",
|
||||
"description": "Represents an Eventstream destination response.",
|
||||
"required": [
|
||||
"type"
|
||||
],
|
||||
"properties": {
|
||||
"type": {
|
||||
"description": "The type of the destination.",
|
||||
"$ref": "#/definitions/DestinationType"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/BaseDestination"
|
||||
},
|
||||
{
|
||||
"$ref": "common.json#/definitions/RuntimeInformation"
|
||||
}
|
||||
],
|
||||
"discriminator": "type"
|
||||
},
|
||||
"DestinationConnectionResponse": {
|
||||
"type": "object",
|
||||
"description": "Represents the connection information for a destination custom endpoint.",
|
||||
"required": [
|
||||
"consumerGroupName"
|
||||
],
|
||||
"properties": {
|
||||
"consumerGroupName": {
|
||||
"type": "string",
|
||||
"description": "The consumer group name."
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "./common.json#/definitions/BaseCustomEndpointConnection"
|
||||
}
|
||||
]
|
||||
},
|
||||
"ActivatorDestinationResponse": {
|
||||
"type": "object",
|
||||
"description": "Activator destination response.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties of the Activator destination.",
|
||||
"$ref": "#/definitions/ActivatorDestinationProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/DestinationResponse"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Activator"
|
||||
},
|
||||
"CustomEndpointDestinationResponse": {
|
||||
"type": "object",
|
||||
"description": "Custom endpoint events destination response.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties of the custom endpoint destination.",
|
||||
"$ref": "#/definitions/CustomEndpointDestinationProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/DestinationResponse"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "CustomEndpoint"
|
||||
},
|
||||
"EventhouseDestinationResponse": {
|
||||
"type": "object",
|
||||
"description": "Eventhouse destination response.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"$ref": "#/definitions/EventhouseDestinationProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/DestinationResponse"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Eventhouse"
|
||||
},
|
||||
"LakehouseDestinationResponse": {
|
||||
"type": "object",
|
||||
"description": "Lakehouse destination response.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties of the Lakehouse destination.",
|
||||
"$ref": "#/definitions/LakehouseDestinationProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/DestinationResponse"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Lakehouse"
|
||||
},
|
||||
"ActivatorDestinationProperties": {
|
||||
"type": "object",
|
||||
"description": "Activator destination properties.",
|
||||
"required": [
|
||||
"workspaceId",
|
||||
"itemId"
|
||||
],
|
||||
"properties": {
|
||||
"workspaceId": {
|
||||
"type": "string",
|
||||
"description": "The Activator workspace identifier.",
|
||||
"format": "uuid"
|
||||
},
|
||||
"itemId": {
|
||||
"type": "string",
|
||||
"description": "The Activator item identifier.",
|
||||
"format": "uuid"
|
||||
},
|
||||
"inputSerialization": {
|
||||
"$ref": "./serialization.json#/definitions/SerializationInfo"
|
||||
}
|
||||
}
|
||||
},
|
||||
"CustomEndpointDestinationProperties": {
|
||||
"type": "object",
|
||||
"description": "Custom endpoint events destination properties.",
|
||||
"properties": {}
|
||||
},
|
||||
"EventhouseDestinationProperties": {
|
||||
"type": "object",
|
||||
"description": "Eventhouse destination properties.",
|
||||
"required": [
|
||||
"dataIngestionMode",
|
||||
"workspaceId",
|
||||
"itemId"
|
||||
],
|
||||
"properties": {
|
||||
"dataIngestionMode": {
|
||||
"type": "string",
|
||||
"description": "The data ingestion mode.",
|
||||
"enum": [
|
||||
"DirectIngestion",
|
||||
"ProcessedIngestion"
|
||||
]
|
||||
},
|
||||
"workspaceId": {
|
||||
"type": "string",
|
||||
"description": "The Eventhouse workspace identifier.",
|
||||
"format": "uuid"
|
||||
},
|
||||
"itemId": {
|
||||
"type": "string",
|
||||
"description": "The Eventhouse item identifier.",
|
||||
"format": "uuid"
|
||||
}
|
||||
},
|
||||
"discriminator": "dataIngestionMode"
|
||||
},
|
||||
"EventhouseDirectIngestionModeDestinationProperties": {
|
||||
"type": "object",
|
||||
"description": "Eventhouse DirectIngestion mode destination properties.",
|
||||
"properties": {
|
||||
"tableName": {
|
||||
"type": "string",
|
||||
"description": "The KQL table name."
|
||||
},
|
||||
"connectionName": {
|
||||
"type": "string",
|
||||
"description": "The connection name."
|
||||
},
|
||||
"mappingRuleName": {
|
||||
"type": "string",
|
||||
"description": "The mapping rule name."
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/EventhouseDestinationProperties"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "DirectIngestion"
|
||||
},
|
||||
"EventhouseProcessedIngestionModeDestinationProperties": {
|
||||
"type": "object",
|
||||
"description": "Eventhouse ProcessedIngestion mode destination properties.",
|
||||
"required": [
|
||||
"databaseName",
|
||||
"tableName"
|
||||
],
|
||||
"properties": {
|
||||
"databaseName": {
|
||||
"type": "string",
|
||||
"description": "The KQL database name."
|
||||
},
|
||||
"tableName": {
|
||||
"type": "string",
|
||||
"description": "The KQL table name."
|
||||
},
|
||||
"inputSerialization": {
|
||||
"$ref": "./serialization.json#/definitions/SerializationInfo"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/EventhouseDestinationProperties"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "ProcessedIngestion"
|
||||
},
|
||||
"LakehouseDestinationProperties": {
|
||||
"type": "object",
|
||||
"description": "Lakehouse destination properties.",
|
||||
"required": [
|
||||
"workspaceId",
|
||||
"itemId",
|
||||
"deltaTable"
|
||||
],
|
||||
"properties": {
|
||||
"workspaceId": {
|
||||
"type": "string",
|
||||
"description": "The Lakehouse workspace identifier.",
|
||||
"format": "uuid"
|
||||
},
|
||||
"itemId": {
|
||||
"type": "string",
|
||||
"description": "The Lakehouse item identifier.",
|
||||
"format": "uuid"
|
||||
},
|
||||
"schema": {
|
||||
"type": "string",
|
||||
"description": "The schema name."
|
||||
},
|
||||
"deltaTable": {
|
||||
"type": "string",
|
||||
"description": "The delta table name."
|
||||
},
|
||||
"minimumRows": {
|
||||
"type": "integer",
|
||||
"description": "The minimum number of rows for an output batch. Default is 100000.",
|
||||
"default": 100000
|
||||
},
|
||||
"maximumDurationInSeconds": {
|
||||
"type": "integer",
|
||||
"description": "The maximum duration in seconds for an output batch. Default is 120.",
|
||||
"default": 120
|
||||
},
|
||||
"inputSerialization": {
|
||||
"$ref": "./serialization.json#/definitions/SerializationInfo"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,349 @@
|
||||
{
|
||||
"swagger": "2.0",
|
||||
"info": {
|
||||
"version": "v1",
|
||||
"title": "Eventstream operator data types"
|
||||
},
|
||||
"paths": {},
|
||||
"definitions": {
|
||||
"Operator": {
|
||||
"type": "object",
|
||||
"description": "Represents an Eventstream operator.",
|
||||
"required": [
|
||||
"name",
|
||||
"type",
|
||||
"inputNodes"
|
||||
],
|
||||
"properties": {
|
||||
"name": {
|
||||
"type": "string",
|
||||
"description": "The name of the operator."
|
||||
},
|
||||
"type": {
|
||||
"type": "string",
|
||||
"description": "The type of the operator. Additional operator types may be added over time.",
|
||||
"enum": [
|
||||
"Filter",
|
||||
"Join",
|
||||
"ManageFields",
|
||||
"Aggregate",
|
||||
"GroupBy",
|
||||
"Union",
|
||||
"Expand"
|
||||
],
|
||||
"x-ms-enum": {
|
||||
"name": "OperatorType",
|
||||
"modelAsString": true,
|
||||
"values": [
|
||||
{
|
||||
"value": "Filter",
|
||||
"description": "The operator filters the input data."
|
||||
},
|
||||
{
|
||||
"value": "Join",
|
||||
"description": "The operator joins the input data."
|
||||
},
|
||||
{
|
||||
"value": "ManageFields",
|
||||
"description": "The operator manages the fields of the input data."
|
||||
},
|
||||
{
|
||||
"value": "Aggregate",
|
||||
"description": "The operator aggregates the input data."
|
||||
},
|
||||
{
|
||||
"value": "GroupBy",
|
||||
"description": "The operator groups the input data."
|
||||
},
|
||||
{
|
||||
"value": "Union",
|
||||
"description": "The operator unions the input data."
|
||||
},
|
||||
{
|
||||
"value": "Expand",
|
||||
"description": "The operator expands the input data."
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
"inputNodes": {
|
||||
"type": "array",
|
||||
"description": "A list of the references to the input nodes of the operator.",
|
||||
"items": {
|
||||
"$ref": "./common.json#/definitions/NodeReference"
|
||||
}
|
||||
},
|
||||
"inputSchemas": {
|
||||
"type": "array",
|
||||
"description": "The input schemas of the operator.",
|
||||
"items": {
|
||||
"$ref": "operatorCommon.json#/definitions/InputSchema"
|
||||
}
|
||||
}
|
||||
},
|
||||
"discriminator": "type"
|
||||
},
|
||||
"AggregateOperator": {
|
||||
"type": "object",
|
||||
"description": "Aggregate operator.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "Aggregate operator properties.",
|
||||
"$ref": "#/definitions/AggregateOperatorProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/Operator"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Aggregate"
|
||||
},
|
||||
"ExpandOperator": {
|
||||
"type": "object",
|
||||
"description": "Expand operator.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "Expand operator properties.",
|
||||
"$ref": "#/definitions/ExpandOperatorProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/Operator"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Expand"
|
||||
},
|
||||
"FilterOperator": {
|
||||
"type": "object",
|
||||
"description": "Filter operator.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "Filter operator properties.",
|
||||
"$ref": "#/definitions/FilterOperatorProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/Operator"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Filter"
|
||||
},
|
||||
"GroupByOperator": {
|
||||
"type": "object",
|
||||
"description": "GroupBy operator.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "GroupBy operator properties.",
|
||||
"$ref": "#/definitions/GroupByOperatorProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/Operator"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "GroupBy"
|
||||
},
|
||||
"JoinOperator": {
|
||||
"type": "object",
|
||||
"description": "Join operator.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "Join operator properties.",
|
||||
"$ref": "#/definitions/JoinOperatorProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/Operator"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Join"
|
||||
},
|
||||
"ManageFieldsOperator": {
|
||||
"type": "object",
|
||||
"description": "ManageFields operator.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "ManageFields operator properties.",
|
||||
"$ref": "#/definitions/ManageFieldsOperatorProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/Operator"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "ManageFields"
|
||||
},
|
||||
"UnionOperator": {
|
||||
"type": "object",
|
||||
"description": "Union operator.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "Union operator properties.",
|
||||
"$ref": "#/definitions/UnionOperatorProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/Operator"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Union"
|
||||
},
|
||||
"AggregateOperatorProperties": {
|
||||
"type": "object",
|
||||
"description": "Aggregate operator properties.",
|
||||
"required": [
|
||||
"aggregations"
|
||||
],
|
||||
"properties": {
|
||||
"aggregations": {
|
||||
"type": "array",
|
||||
"description": "A list of the aggregations.",
|
||||
"items": {
|
||||
"$ref": "./operatorCommon.json#/definitions/InColumnAggregation"
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
"ExpandOperatorProperties": {
|
||||
"type": "object",
|
||||
"description": "Expand operator properties.",
|
||||
"required": [
|
||||
"column"
|
||||
],
|
||||
"properties": {
|
||||
"column": {
|
||||
"type": "array",
|
||||
"description": "A list of the columns to expand.",
|
||||
"items": {
|
||||
"$ref": "./operatorCommon.json#/definitions/ColumnReferenceExpression"
|
||||
}
|
||||
},
|
||||
"ignoreMissingOrEmpty": {
|
||||
"type": "boolean",
|
||||
"description": "Missing or empty columns setting. True - Ignore the columns, False - Do not ignore the columns."
|
||||
}
|
||||
}
|
||||
},
|
||||
"FilterOperatorProperties": {
|
||||
"type": "object",
|
||||
"description": "Filter operator properties.",
|
||||
"required": [
|
||||
"conditions"
|
||||
],
|
||||
"properties": {
|
||||
"conditions": {
|
||||
"type": "array",
|
||||
"description": "A list of the filter conditions.",
|
||||
"items": {
|
||||
"$ref": "./operatorCommon.json#/definitions/FilterCondition"
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
"GroupByOperatorProperties": {
|
||||
"type": "object",
|
||||
"description": "GroupBy operator properties.",
|
||||
"required": [
|
||||
"aggregations",
|
||||
"groupBy",
|
||||
"window"
|
||||
],
|
||||
"properties": {
|
||||
"aggregations": {
|
||||
"type": "array",
|
||||
"description": "A list of the aggregations.",
|
||||
"items": {
|
||||
"$ref": "./operatorCommon.json#/definitions/Aggregation"
|
||||
}
|
||||
},
|
||||
"groupBy": {
|
||||
"type": "array",
|
||||
"description": "A list of the columns to group by.",
|
||||
"items": {
|
||||
"$ref": "./operatorCommon.json#/definitions/ColumnReferenceExpression"
|
||||
}
|
||||
},
|
||||
"window": {
|
||||
"$ref": "./operatorCommon.json#/definitions/GroupByWindow"
|
||||
}
|
||||
}
|
||||
},
|
||||
"JoinOperatorProperties": {
|
||||
"type": "object",
|
||||
"description": "Join operator properties.",
|
||||
"required": [
|
||||
"joinType",
|
||||
"duration"
|
||||
],
|
||||
"properties": {
|
||||
"joinType": {
|
||||
"type": "string",
|
||||
"description": "The type of the join.",
|
||||
"enum": [
|
||||
"Inner",
|
||||
"LeftOuter"
|
||||
]
|
||||
},
|
||||
"joinOn": {
|
||||
"type": "array",
|
||||
"description": "A list of the join conditions.",
|
||||
"items": {
|
||||
"$ref": "./operatorCommon.json#/definitions/JoinOn"
|
||||
}
|
||||
},
|
||||
"duration": {
|
||||
"$ref": "./operatorCommon.json#/definitions/OperatorCommonDuration"
|
||||
}
|
||||
}
|
||||
},
|
||||
"ManageFieldsOperatorProperties": {
|
||||
"type": "object",
|
||||
"description": "ManageFields operator properties.",
|
||||
"required": [
|
||||
"columns"
|
||||
],
|
||||
"properties": {
|
||||
"columns": {
|
||||
"type": "array",
|
||||
"description": "A list of the columns to manage.",
|
||||
"items": {
|
||||
"$ref": "./operatorCommon.json#/definitions/ManageFieldsOperation"
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
"UnionOperatorProperties": {
|
||||
"type": "object",
|
||||
"description": "Union operator properties.",
|
||||
"properties": {}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,644 @@
|
||||
{
|
||||
"swagger": "2.0",
|
||||
"info": {
|
||||
"version": "v1",
|
||||
"title": "Eventstream operator common data types"
|
||||
},
|
||||
"paths": {},
|
||||
"definitions": {
|
||||
"OperatorCommonDuration": {
|
||||
"type": "object",
|
||||
"description": "Represents the duration.",
|
||||
"required": [
|
||||
"value",
|
||||
"unit"
|
||||
],
|
||||
"properties": {
|
||||
"value": {
|
||||
"type": "integer",
|
||||
"description": "The value of the duration."
|
||||
},
|
||||
"unit": {
|
||||
"type": "string",
|
||||
"description": "The unit of the duration.",
|
||||
"enum": [
|
||||
"Microsecond",
|
||||
"Millisecond",
|
||||
"Second",
|
||||
"Minute",
|
||||
"Hour",
|
||||
"Day",
|
||||
"Weekday",
|
||||
"Week",
|
||||
"DayOfYear",
|
||||
"Month",
|
||||
"Quarter",
|
||||
"Year"
|
||||
]
|
||||
}
|
||||
}
|
||||
},
|
||||
"ColumnReferenceExpression": {
|
||||
"type": "object",
|
||||
"description": "Represents a reference to a column.",
|
||||
"required": [
|
||||
"columnName"
|
||||
],
|
||||
"properties": {
|
||||
"node": {
|
||||
"type": "string",
|
||||
"description": "The name of the reference node."
|
||||
},
|
||||
"columnName": {
|
||||
"type": "string",
|
||||
"description": "The name of the column."
|
||||
},
|
||||
"columnPathSegments": {
|
||||
"type": "array",
|
||||
"description": "The path segments to the column reference for nested columns.",
|
||||
"items": {
|
||||
"type": "string"
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
"LiteralExpression": {
|
||||
"type": "object",
|
||||
"description": "Represents a literal expression.",
|
||||
"required": [
|
||||
"dataType",
|
||||
"value"
|
||||
],
|
||||
"properties": {
|
||||
"dataType": {
|
||||
"$ref": "#/definitions/DataType",
|
||||
"description": "The data type of the literal expression."
|
||||
},
|
||||
"value": {
|
||||
"type": "string",
|
||||
"description": "The value of the literal expression."
|
||||
}
|
||||
}
|
||||
},
|
||||
"Aggregation": {
|
||||
"type": "object",
|
||||
"description": "Represents an aggregation on a column.",
|
||||
"required": [
|
||||
"aggregationFunction",
|
||||
"column"
|
||||
],
|
||||
"properties": {
|
||||
"aggregationFunction": {
|
||||
"type": "string",
|
||||
"description": "The aggregation function.",
|
||||
"enum": [
|
||||
"Average",
|
||||
"Count",
|
||||
"Maximum",
|
||||
"Minimum",
|
||||
"PercentileContinuous",
|
||||
"PercentileDiscrete",
|
||||
"StandardDeviation",
|
||||
"StandardDeviationPopulation",
|
||||
"Sum",
|
||||
"Variance",
|
||||
"VariancePopulation"
|
||||
]
|
||||
},
|
||||
"arguments": {
|
||||
"type": "array",
|
||||
"description": "A list of the arguments for the aggregation.",
|
||||
"items": {
|
||||
"type": "object"
|
||||
}
|
||||
},
|
||||
"column": {
|
||||
"$ref": "#/definitions/ColumnReferenceExpression"
|
||||
},
|
||||
"alias": {
|
||||
"type": "string",
|
||||
"description": "The alias of the aggregation."
|
||||
}
|
||||
}
|
||||
},
|
||||
"InColumnAggregation": {
|
||||
"type": "object",
|
||||
"description": "Represents an aggregation on a column.",
|
||||
"required": [
|
||||
"duration"
|
||||
],
|
||||
"properties": {
|
||||
"partitionBy": {
|
||||
"type": "array",
|
||||
"description": "A list of the columns to partition by.",
|
||||
"items": {
|
||||
"$ref": "#/definitions/ColumnReferenceExpression"
|
||||
}
|
||||
},
|
||||
"duration": {
|
||||
"$ref": "#/definitions/OperatorCommonDuration"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/Aggregation"
|
||||
}
|
||||
]
|
||||
},
|
||||
"FilterCondition": {
|
||||
"type": "object",
|
||||
"description": "Represents a filter condition.",
|
||||
"required": [
|
||||
"column",
|
||||
"operatorType"
|
||||
],
|
||||
"properties": {
|
||||
"column": {
|
||||
"$ref": "#/definitions/ColumnReferenceExpression"
|
||||
},
|
||||
"operatorType": {
|
||||
"type": "string",
|
||||
"description": "The operator type.",
|
||||
"enum": [
|
||||
"Equals",
|
||||
"NotEquals",
|
||||
"GreaterThan",
|
||||
"GreaterThanOrEquals",
|
||||
"LessThan",
|
||||
"LessThanOrEquals",
|
||||
"Contains",
|
||||
"DoesNotContain",
|
||||
"StartsWith",
|
||||
"DoesNotStartWith",
|
||||
"EndsWith",
|
||||
"DoesNotEndWith",
|
||||
"IsEmpty",
|
||||
"IsNull",
|
||||
"IsNotNull",
|
||||
"IsNotNullOrEmpty"
|
||||
]
|
||||
},
|
||||
"value": {
|
||||
"$ref": "#/definitions/LiteralExpression"
|
||||
}
|
||||
}
|
||||
},
|
||||
"GroupByWindow": {
|
||||
"type": "object",
|
||||
"description": "Represents the window for the group by operator.",
|
||||
"required": [
|
||||
"type"
|
||||
],
|
||||
"properties": {
|
||||
"type": {
|
||||
"type": "string",
|
||||
"description": "The type of the window.",
|
||||
"enum": [
|
||||
"Tumbling",
|
||||
"Hopping",
|
||||
"Sliding",
|
||||
"Snapshot",
|
||||
"Session"
|
||||
]
|
||||
}
|
||||
},
|
||||
"discriminator": "type"
|
||||
},
|
||||
"TumblingWindow": {
|
||||
"type": "object",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties for a tumbling window.",
|
||||
"$ref": "#/definitions/TumblingWindowProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/GroupByWindow"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Tumbling"
|
||||
},
|
||||
"HoppingWindow": {
|
||||
"type": "object",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties for a hopping window.",
|
||||
"$ref": "#/definitions/HoppingWindowProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/GroupByWindow"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Hopping"
|
||||
},
|
||||
"SlidingWindow": {
|
||||
"type": "object",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties for a sliding window.",
|
||||
"$ref": "#/definitions/SlidingWindowProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/GroupByWindow"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Sliding"
|
||||
},
|
||||
"SnapshotWindow": {
|
||||
"type": "object",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties for a snapshot window.",
|
||||
"$ref": "#/definitions/SnapshotWindowProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/GroupByWindow"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Snapshot"
|
||||
},
|
||||
"SessionWindow": {
|
||||
"type": "object",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties for a session window.",
|
||||
"$ref": "#/definitions/SessionWindowProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/GroupByWindow"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Session"
|
||||
},
|
||||
"TumblingWindowProperties": {
|
||||
"type": "object",
|
||||
"description": "Properties for a tumbling window.",
|
||||
"required": [
|
||||
"duration"
|
||||
],
|
||||
"properties": {
|
||||
"duration": {
|
||||
"$ref": "#/definitions/OperatorCommonDuration"
|
||||
},
|
||||
"offset": {
|
||||
"$ref": "#/definitions/OperatorCommonDuration"
|
||||
}
|
||||
}
|
||||
},
|
||||
"HoppingWindowProperties": {
|
||||
"type": "object",
|
||||
"description": "Properties for a hopping window.",
|
||||
"required": [
|
||||
"hopSize",
|
||||
"duration"
|
||||
],
|
||||
"properties": {
|
||||
"hopSize": {
|
||||
"$ref": "#/definitions/OperatorCommonDuration"
|
||||
},
|
||||
"duration": {
|
||||
"$ref": "#/definitions/OperatorCommonDuration"
|
||||
},
|
||||
"offset": {
|
||||
"$ref": "#/definitions/OperatorCommonDuration"
|
||||
}
|
||||
}
|
||||
},
|
||||
"SlidingWindowProperties": {
|
||||
"type": "object",
|
||||
"description": "Properties for a sliding window.",
|
||||
"required": [
|
||||
"duration"
|
||||
],
|
||||
"properties": {
|
||||
"duration": {
|
||||
"$ref": "#/definitions/OperatorCommonDuration"
|
||||
}
|
||||
}
|
||||
},
|
||||
"SnapshotWindowProperties": {
|
||||
"type": "object",
|
||||
"description": "Properties for a snapshot window.",
|
||||
"properties": {}
|
||||
},
|
||||
"SessionWindowProperties": {
|
||||
"type": "object",
|
||||
"description": "Properties for a session window.",
|
||||
"required": [
|
||||
"maxDuration",
|
||||
"timeout"
|
||||
],
|
||||
"properties": {
|
||||
"maxDuration": {
|
||||
"$ref": "#/definitions/OperatorCommonDuration"
|
||||
},
|
||||
"timeout": {
|
||||
"$ref": "#/definitions/OperatorCommonDuration"
|
||||
},
|
||||
"partitionBy": {
|
||||
"$ref": "#/definitions/ColumnReferenceExpression"
|
||||
}
|
||||
}
|
||||
},
|
||||
"JoinOn": {
|
||||
"type": "object",
|
||||
"description": "Represents a join condition.",
|
||||
"required": [
|
||||
"left",
|
||||
"right"
|
||||
],
|
||||
"properties": {
|
||||
"left": {
|
||||
"$ref": "#/definitions/ColumnReferenceExpression"
|
||||
},
|
||||
"right": {
|
||||
"$ref": "#/definitions/ColumnReferenceExpression"
|
||||
}
|
||||
}
|
||||
},
|
||||
"ManageFieldsOperation": {
|
||||
"type": "object",
|
||||
"description": "Represents an operation on a column.",
|
||||
"required": [
|
||||
"operationType"
|
||||
],
|
||||
"properties": {
|
||||
"operationType": {
|
||||
"type": "string",
|
||||
"description": "The operation type.",
|
||||
"enum": [
|
||||
"FunctionCall",
|
||||
"Cast",
|
||||
"Rename"
|
||||
],
|
||||
"x-ms-enum": {
|
||||
"name": "operationType",
|
||||
"modelAsString": true,
|
||||
"values": [
|
||||
{
|
||||
"value": "FunctionCall",
|
||||
"description": "Function call operation."
|
||||
},
|
||||
{
|
||||
"value": "Cast",
|
||||
"description": "Cast operation."
|
||||
},
|
||||
{
|
||||
"value": "Rename",
|
||||
"description": "Rename operation."
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
"alias": {
|
||||
"type": "string",
|
||||
"description": "The alias of the operation."
|
||||
}
|
||||
},
|
||||
"discriminator": "operationType"
|
||||
},
|
||||
"ManageFieldsFunctionCallOperation": {
|
||||
"type": "object",
|
||||
"description": "Represents a manage fields function call operation.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties for a manage fields function call operation.",
|
||||
"$ref": "#/definitions/FunctionCallProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/ManageFieldsOperation"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "FunctionCall"
|
||||
},
|
||||
"ManageFieldsCastOperation": {
|
||||
"type": "object",
|
||||
"description": "Represents a manage fields cast operation.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties for a manage fields cast operation.",
|
||||
"$ref": "#/definitions/CastProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/ManageFieldsOperation"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Cast"
|
||||
},
|
||||
"ManageFieldsRenameOperation": {
|
||||
"type": "object",
|
||||
"description": "Represents a manage fields rename operation.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties for a manage fields rename operation.",
|
||||
"$ref": "#/definitions/RenameProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/ManageFieldsOperation"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Rename"
|
||||
},
|
||||
"FunctionCallProperties": {
|
||||
"type": "object",
|
||||
"description": "Properties for a function call operation.",
|
||||
"required": [
|
||||
"functionName",
|
||||
"arguments"
|
||||
],
|
||||
"properties": {
|
||||
"functionName": {
|
||||
"type": "string",
|
||||
"description": "The name of the function."
|
||||
},
|
||||
"arguments": {
|
||||
"type": "array",
|
||||
"description": "A list of the arguments for the function.",
|
||||
"items": {
|
||||
"type": "object"
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
"CastProperties": {
|
||||
"type": "object",
|
||||
"description": "Properties for a cast operation.",
|
||||
"required": [
|
||||
"targetDataType",
|
||||
"column"
|
||||
],
|
||||
"properties": {
|
||||
"targetDataType": {
|
||||
"$ref": "#/definitions/DataType"
|
||||
},
|
||||
"column": {
|
||||
"$ref": "#/definitions/ColumnReferenceExpression"
|
||||
}
|
||||
}
|
||||
},
|
||||
"RenameProperties": {
|
||||
"type": "object",
|
||||
"description": "Properties for a rename operation.",
|
||||
"required": [
|
||||
"column"
|
||||
],
|
||||
"properties": {
|
||||
"column": {
|
||||
"$ref": "#/definitions/ColumnReferenceExpression"
|
||||
}
|
||||
}
|
||||
},
|
||||
"DataType": {
|
||||
"type": "string",
|
||||
"description": "Represents the data type. Additional data types may be added over time.",
|
||||
"enum": [
|
||||
"BigInt",
|
||||
"Float",
|
||||
"Nvarchar(max)",
|
||||
"DateTime",
|
||||
"Bit",
|
||||
"Record",
|
||||
"Array",
|
||||
"Any"
|
||||
],
|
||||
"x-ms-enum": {
|
||||
"name": "DataType",
|
||||
"modelAsString": true,
|
||||
"values": [
|
||||
{
|
||||
"value": "BigInt",
|
||||
"description": "BigInt data type."
|
||||
},
|
||||
{
|
||||
"value": "Float",
|
||||
"description": "Float data type."
|
||||
},
|
||||
{
|
||||
"value": "Nvarchar(max)",
|
||||
"description": "Nvarchar(max) data type."
|
||||
},
|
||||
{
|
||||
"value": "DateTime",
|
||||
"description": "DateTime data type."
|
||||
},
|
||||
{
|
||||
"value": "Bit",
|
||||
"description": "Bit data type."
|
||||
},
|
||||
{
|
||||
"value": "Record",
|
||||
"description": "Record data type."
|
||||
},
|
||||
{
|
||||
"value": "Array",
|
||||
"description": "Array data type."
|
||||
},
|
||||
{
|
||||
"value": "Any",
|
||||
"description": "Unknown data type."
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
"ColumnSchema": {
|
||||
"type": "object",
|
||||
"description": "Represents the schema of a column.",
|
||||
"required": [
|
||||
"type"
|
||||
],
|
||||
"properties": {
|
||||
"name": {
|
||||
"type": "string",
|
||||
"description": "The name of the column."
|
||||
},
|
||||
"type": {
|
||||
"$ref": "#/definitions/DataType",
|
||||
"description": "The data type of the column."
|
||||
},
|
||||
"fields": {
|
||||
"type": "array",
|
||||
"description": "A list of the fields for the record or array data type.",
|
||||
"items": {
|
||||
"$ref": "#/definitions/ColumnSchema"
|
||||
}
|
||||
},
|
||||
"items": {
|
||||
"$ref": "#/definitions/ColumnSchema",
|
||||
"description": "The schema of the array items."
|
||||
}
|
||||
}
|
||||
},
|
||||
"Schema": {
|
||||
"type": "object",
|
||||
"description": "Represents the schema of the data.",
|
||||
"required": [
|
||||
"columns"
|
||||
],
|
||||
"properties": {
|
||||
"columns": {
|
||||
"type": "array",
|
||||
"description": "A list of the columns in the schema.",
|
||||
"items": {
|
||||
"$ref": "#/definitions/ColumnSchema"
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
"InputSchema": {
|
||||
"type": "object",
|
||||
"description": "Represents the input schema of the source, destination, or operator.",
|
||||
"required": [
|
||||
"name",
|
||||
"schema"
|
||||
],
|
||||
"properties": {
|
||||
"name": {
|
||||
"type": "string",
|
||||
"description": "The name of the input schema."
|
||||
},
|
||||
"schema": {
|
||||
"$ref": "#/definitions/Schema"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,154 @@
|
||||
{
|
||||
"swagger": "2.0",
|
||||
"info": {
|
||||
"version": "v1",
|
||||
"title": "Eventstream serialization data types"
|
||||
},
|
||||
"paths": {},
|
||||
"definitions": {
|
||||
"SerializationType": {
|
||||
"type": "string",
|
||||
"description": "The serialization type.",
|
||||
"enum": [
|
||||
"Avro",
|
||||
"Json",
|
||||
"Csv"
|
||||
],
|
||||
"x-ms-enum": {
|
||||
"name": "SerializationType",
|
||||
"modelAsString": true,
|
||||
"values": [
|
||||
{
|
||||
"value": "Avro",
|
||||
"description": "The serialization type is Avro."
|
||||
},
|
||||
{
|
||||
"value": "Json",
|
||||
"description": "The serialization type is JSON."
|
||||
},
|
||||
{
|
||||
"value": "Csv",
|
||||
"description": "The serialization type is CSV."
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
"SerializationInfo": {
|
||||
"type": "object",
|
||||
"description": "Serialization information.",
|
||||
"required": [
|
||||
"type"
|
||||
],
|
||||
"properties": {
|
||||
"type": {
|
||||
"description": "The serialization type.",
|
||||
"$ref": "#/definitions/SerializationType"
|
||||
}
|
||||
},
|
||||
"discriminator": "type"
|
||||
},
|
||||
"JsonSerializationInfo": {
|
||||
"type": "object",
|
||||
"description": "JSON serialization information.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "JSON serialization properties.",
|
||||
"$ref": "#/definitions/JsonSerializationProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/SerializationInfo"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Json"
|
||||
},
|
||||
"JsonSerializationProperties": {
|
||||
"type": "object",
|
||||
"description": "JSON serialization properties.",
|
||||
"properties": {
|
||||
"encoding": {
|
||||
"type": "string",
|
||||
"description": "The encoding type.",
|
||||
"enum": [
|
||||
"UTF8"
|
||||
]
|
||||
}
|
||||
}
|
||||
},
|
||||
"CsvSerializationInfo": {
|
||||
"type": "object",
|
||||
"description": "CSV serialization information.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "CSV serialization properties.",
|
||||
"$ref": "#/definitions/CsvSerializationProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/SerializationInfo"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Csv"
|
||||
},
|
||||
"CsvSerializationProperties": {
|
||||
"type": "object",
|
||||
"description": "CSV serialization properties.",
|
||||
"required": [
|
||||
"fieldDelimiter"
|
||||
],
|
||||
"properties": {
|
||||
"encoding": {
|
||||
"type": "string",
|
||||
"description": "The encoding type.",
|
||||
"enum": [
|
||||
"UTF8"
|
||||
]
|
||||
},
|
||||
"fieldDelimiter": {
|
||||
"type": "string",
|
||||
"description": "The field delimiter."
|
||||
},
|
||||
"format": {
|
||||
"type": "string",
|
||||
"description": "The format type.",
|
||||
"enum": [
|
||||
"WithHeaders",
|
||||
"WithoutHeaders"
|
||||
]
|
||||
}
|
||||
}
|
||||
},
|
||||
"AvroSerializationInfo": {
|
||||
"type": "object",
|
||||
"description": "Avro serialization information.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "Avro serialization properties.",
|
||||
"$ref": "#/definitions/AvroSerializationProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/SerializationInfo"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "Avro"
|
||||
},
|
||||
"AvroSerializationProperties": {
|
||||
"type": "object",
|
||||
"description": "Avro serialization properties.",
|
||||
"properties": {}
|
||||
}
|
||||
}
|
||||
}
|
||||
File diff suppressed because it is too large.
Load diff
@@ -0,0 +1,117 @@
|
||||
{
|
||||
"swagger": "2.0",
|
||||
"info": {
|
||||
"version": "v1",
|
||||
"title": "Eventstream stream data types"
|
||||
},
|
||||
"paths": {},
|
||||
"definitions": {
|
||||
"StreamType": {
|
||||
"type": "string",
|
||||
"description": "Represents the type of the stream. Additional stream types may be added over time.",
|
||||
"enum": [
|
||||
"DefaultStream",
|
||||
"DerivedStream"
|
||||
],
|
||||
"x-ms-enum": {
|
||||
"name": "StreamType",
|
||||
"modelAsString": true,
|
||||
"values": [
|
||||
{
|
||||
"value": "DefaultStream",
|
||||
"description": "The stream is a default stream."
|
||||
},
|
||||
{
|
||||
"value": "DerivedStream",
|
||||
"description": "The stream is derived from another stream."
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
"StreamResponse": {
|
||||
"type": "object",
|
||||
"description": "Represents an Eventstream default or derived stream.",
|
||||
"required": [
|
||||
"id",
|
||||
"name",
|
||||
"type",
|
||||
"inputNodes"
|
||||
],
|
||||
"properties": {
|
||||
"id": {
|
||||
"type": "string",
|
||||
"description": "The unique identifier of the stream.",
|
||||
"format": "uuid"
|
||||
},
|
||||
"name": {
|
||||
"type": "string",
|
||||
"description": "The unique name of the stream."
|
||||
},
|
||||
"type": {
|
||||
"description": "The type of the stream.",
|
||||
"$ref": "#/definitions/StreamType"
|
||||
},
|
||||
"inputNodes": {
|
||||
"type": "array",
|
||||
"description": "A list of the references to the input nodes of the stream.",
|
||||
"items": {
|
||||
"$ref": "./common.json#/definitions/NodeReference"
|
||||
}
|
||||
}
|
||||
},
|
||||
"discriminator": "type"
|
||||
},
|
||||
"DefaultStreamResponse": {
|
||||
"type": "object",
|
||||
"description": "Default stream response.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties of the default stream.",
|
||||
"$ref": "#/definitions/DefaultStreamProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/StreamResponse"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "DefaultStream"
|
||||
},
|
||||
"DerivedStreamResponse": {
|
||||
"type": "object",
|
||||
"description": "Derived stream response.",
|
||||
"required": [
|
||||
"properties"
|
||||
],
|
||||
"properties": {
|
||||
"properties": {
|
||||
"description": "The properties of the derived stream.",
|
||||
"$ref": "#/definitions/DerivedStreamProperties"
|
||||
}
|
||||
},
|
||||
"allOf": [
|
||||
{
|
||||
"$ref": "#/definitions/StreamResponse"
|
||||
}
|
||||
],
|
||||
"x-ms-discriminator-value": "DerivedStream"
|
||||
},
|
||||
"DefaultStreamProperties": {
|
||||
"type": "object",
|
||||
"description": "The default stream properties.",
|
||||
"properties": {}
|
||||
},
|
||||
"DerivedStreamProperties": {
|
||||
"type": "object",
|
||||
"description": "The derived stream properties.",
|
||||
"properties": {
|
||||
"inputSerialization": {
|
||||
"$ref": "./serialization.json#/definitions/SerializationInfo"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,47 @@
|
||||
{
|
||||
"swagger": "2.0",
|
||||
"info": {
|
||||
"version": "v1",
|
||||
"title": "Eventstream topology data types"
|
||||
},
|
||||
"paths": {},
|
||||
"definitions": {
|
||||
"EventstreamTopologyResponse": {
|
||||
"type": "object",
|
||||
"description": "Represents the Eventstream topology response.",
|
||||
"properties": {
|
||||
"sources": {
|
||||
"type": "array",
|
||||
"description": "A list of Eventstream sources.",
|
||||
"items": {
|
||||
"$ref": "./source.json#/definitions/SourceResponse"
|
||||
}
|
||||
},
|
||||
"destinations": {
|
||||
"type": "array",
|
||||
"description": "A list of Eventstream destinations.",
|
||||
"items": {
|
||||
"$ref": "./destination.json#/definitions/DestinationResponse"
|
||||
}
|
||||
},
|
||||
"streams": {
|
||||
"type": "array",
|
||||
"description": "A list of Eventstream default and derived streams.",
|
||||
"items": {
|
||||
"$ref": "./stream.json#/definitions/StreamResponse"
|
||||
}
|
||||
},
|
||||
"operators": {
|
||||
"type": "array",
|
||||
"description": "A list of Eventstream operators.",
|
||||
"items": {
|
||||
"$ref": "./operator.json#/definitions/Operator"
|
||||
}
|
||||
},
|
||||
"compatibilityLevel": {
|
||||
"$ref": "./common.json#/definitions/CompatibilityLevel"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,27 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"createEventstreamRequest": {
|
||||
"displayName": "Eventstream_1",
|
||||
"description": "Eventstream_1 description."
|
||||
}
|
||||
},
|
||||
"responses": {
|
||||
"201": {
|
||||
"body": {
|
||||
"displayName": "Eventstream_1",
|
||||
"description": "Eventstream_1 description.",
|
||||
"type": "Eventstream",
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"id": "5b218778-e7a5-4d73-8187-f10824047715"
|
||||
}
|
||||
},
|
||||
"202": {
|
||||
"headers": {
|
||||
"Location": "https://api.fabric.microsoft.com/v1/operations/0acd697c-1550-43cd-b998-91bfbfbd47c6",
|
||||
"x-ms-operation-id": "0acd697c-1550-43cd-b998-91bfbfbd47c6",
|
||||
"Retry-After": 30
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,42 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"createEventstreamRequest": {
|
||||
"displayName": "Eventstream_1",
|
||||
"description": "Eventstream_1 description.",
|
||||
"definition": {
|
||||
"format": "eventstream",
|
||||
"parts": [
|
||||
{
|
||||
"path": "eventstream.json",
|
||||
"payload": "SSdkIGxpa2UgdG8gdGVsbCBh..IGpva2UgZm9yIHlvdS4K",
|
||||
"payloadType": "InlineBase64"
|
||||
},
|
||||
{
|
||||
"path": ".platform",
|
||||
"payload": "ZG90UGxhdGZvcm1CYXNlNjRTdHJpbmc=",
|
||||
"payloadType": "InlineBase64"
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
},
|
||||
"responses": {
|
||||
"201": {
|
||||
"body": {
|
||||
"displayName": "Eventstream_1",
|
||||
"description": "Eventstream_1 description.",
|
||||
"type": "Eventstream",
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"id": "5b218778-e7a5-4d73-8187-f10824047715"
|
||||
}
|
||||
},
|
||||
"202": {
|
||||
"headers": {
|
||||
"Location": "https://api.fabric.microsoft.com/v1/operations/0acd697c-1550-43cd-b998-91bfbfbd47c6",
|
||||
"x-ms-operation-id": "0acd697c-1550-43cd-b998-91bfbfbd47c6",
|
||||
"Retry-After": 30
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,9 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "5b218778-e7a5-4d73-8187-f10824047715"
|
||||
},
|
||||
"responses": {
|
||||
"200": {}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,17 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "5b218778-e7a5-4d73-8187-f10824047715"
|
||||
},
|
||||
"responses": {
|
||||
"200": {
|
||||
"body": {
|
||||
"displayName": "Eventstream_1",
|
||||
"description": "An eventstream description.",
|
||||
"type": "Eventstream",
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"id": "5b218778-e7a5-4d73-8187-f10824047715"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,33 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "6e335e92-a2a2-4b5a-970a-bd6a89fbb765",
|
||||
"eventstreamId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229"
|
||||
},
|
||||
"responses": {
|
||||
"200": {
|
||||
"body": {
|
||||
"definition": {
|
||||
"parts": [
|
||||
{
|
||||
"path": "eventstream.json",
|
||||
"payload": "SSdkIGxpa2UgdG8gdGVsbCBh..IGpva2UgZm9yIHlvdS4K",
|
||||
"payloadType": "InlineBase64"
|
||||
},
|
||||
{
|
||||
"path": ".platform",
|
||||
"payload": "ZG90UGxhdGZvcm1CYXNlNjRTdHJpbmc=",
|
||||
"payloadType": "InlineBase64"
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
},
|
||||
"202": {
|
||||
"headers": {
|
||||
"Location": "https://api.fabric.microsoft.com/v1/operations/431e8d7b-4a95-4c02-8ccd-6faef5ba1bd7",
|
||||
"x-ms-operation-id": "431e8d7b-4a95-4c02-8ccd-6faef5ba1bd7",
|
||||
"Retry-After": 30
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,33 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "8c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"destinationId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37"
|
||||
},
|
||||
"responses": {
|
||||
"200": {
|
||||
"id": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"name": "LakehouseDestination",
|
||||
"type": "Lakehouse",
|
||||
"properties": {
|
||||
"workspaceId": "9625b495-17b3-4d6c-aeea-a81ae76ba369",
|
||||
"itemId": "ee579458-85ea-4652-bd77-5c7d7c298b2a",
|
||||
"schema": "dbo",
|
||||
"deltaTable": "deltaTable",
|
||||
"inputSerialization": {
|
||||
"type": "Json",
|
||||
"properties": {
|
||||
"encoding": "UTF8"
|
||||
}
|
||||
}
|
||||
},
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "InputNodeName"
|
||||
}
|
||||
],
|
||||
"status": "Running",
|
||||
"error": null
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,20 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "8c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"destinationId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37"
|
||||
},
|
||||
"responses": {
|
||||
"200": {
|
||||
"fullyQualifiedNamespace": "namespace.servicebus.windows.net",
|
||||
"eventHubName": "eventhub",
|
||||
"consumerGroupName": "$Default",
|
||||
"accessKeys": {
|
||||
"primaryKey": "key1",
|
||||
"secondaryKey": "key2",
|
||||
"primaryConnectionString": "connectionString1",
|
||||
"secondaryConnectionString": "connectionString2"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,26 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "8c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"sourceId": "e2886002-d696-4c05-969c-51361365cc24"
|
||||
},
|
||||
"responses": {
|
||||
"200": {
|
||||
"id": "e2886002-d696-4c05-969c-51361365cc24",
|
||||
"name": "AzureEventHubSource",
|
||||
"type": "AzureEventHub",
|
||||
"properties": {
|
||||
"dataConnectionId": "9c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"consumerGroupName": "$Default",
|
||||
"inputSerialization": {
|
||||
"type": "Json",
|
||||
"properties": {
|
||||
"encoding": "UTF8"
|
||||
}
|
||||
}
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,19 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "8c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"sourceId": "f344e2e0-e846-4991-ac26-d27dfb6a73c2"
|
||||
},
|
||||
"responses": {
|
||||
"200": {
|
||||
"fullyQualifiedNamespace": "namespace.servicebus.windows.net",
|
||||
"eventHubName": "eventhub",
|
||||
"accessKeys": {
|
||||
"primaryKey": "key1",
|
||||
"secondaryKey": "key2",
|
||||
"primaryConnectionString": "connectionString1",
|
||||
"secondaryConnectionString": "connectionString2"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,623 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "8c500070-073f-4a88-b478-8fabe1941c52"
|
||||
},
|
||||
"responses": {
|
||||
"200": {
|
||||
"compatibilityLevel": "1.0",
|
||||
"sources": [
|
||||
{
|
||||
"name": "AzureEventHubSource",
|
||||
"type": "AzureEventHub",
|
||||
"properties": {
|
||||
"dataConnectionId": "9c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"consumerGroupName": "$Default",
|
||||
"inputSerialization": {
|
||||
"type": "Json",
|
||||
"properties": {
|
||||
"encoding": "UTF8"
|
||||
}
|
||||
}
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"id": "e2886002-d696-4c05-969c-51361365cc24",
|
||||
"name": "AzureIoTHubSource",
|
||||
"type": "AzureIoTHub",
|
||||
"properties": {
|
||||
"dataConnectionId": "8c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"consumerGroupName": "$Default",
|
||||
"inputSerialization": {
|
||||
"type": "Json",
|
||||
"properties": {
|
||||
"encoding": "UTF8"
|
||||
}
|
||||
}
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "CustomEndpointSource",
|
||||
"type": "CustomEndpoint",
|
||||
"properties": {},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "SampleDataSource",
|
||||
"type": "SimpleData",
|
||||
"properties": {
|
||||
"sampleType": "Bicycles"
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "AmazonKinesisSource",
|
||||
"type": "AmazonKinesis",
|
||||
"properties": {
|
||||
"dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"region": "us-east-1"
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "AmazonMSKKafkaSource",
|
||||
"type": "AmazonMSKKafka",
|
||||
"properties": {
|
||||
"dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"topic": "topic",
|
||||
"consumerGroupName": "consumerGroupName",
|
||||
"autoOffsetReset": "Earliest",
|
||||
"saslMechanism": "PLAIN",
|
||||
"securityProtocol": "SASL_PLAINTEXT"
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "ApacheKafkaSource",
|
||||
"type": "ApacheKafka",
|
||||
"properties": {
|
||||
"dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"topic": "topic",
|
||||
"consumerGroupName": "consumerGroupName",
|
||||
"autoOffsetReset": "Latest",
|
||||
"saslMechanism": "SCRAM-SHA-512",
|
||||
"securityProtocol": "SASL_SSL"
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "ConfluentCloudSource",
|
||||
"type": "ConfluentCloud",
|
||||
"properties": {
|
||||
"dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"topic": "topic",
|
||||
"consumerGroupName": "consumerGroupName",
|
||||
"autoOffsetReset": "Earliest"
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "AzureCosmosDBCDCSource",
|
||||
"type": "AzureCosmosDBCDC",
|
||||
"properties": {
|
||||
"dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"containerName": "containerName",
|
||||
"databaseName": "databaseName",
|
||||
"offsetPolicy": "Earliest"
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "AzureSQLDBCDCSource",
|
||||
"type": "AzureSQLDBCDC",
|
||||
"properties": {
|
||||
"dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"tableName": "tableName"
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "AzureSQLMIDBCDCSource",
|
||||
"type": "AzureSQLMIDBCDC",
|
||||
"properties": {
|
||||
"dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"tableName": "tableName"
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "SQLServerOnVMDBCDCSource",
|
||||
"type": "SQLServerOnVMDBCDC",
|
||||
"properties": {
|
||||
"dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"tableName": "tableName"
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "MySQLCDCSource",
|
||||
"type": "MySQLCDC",
|
||||
"properties": {
|
||||
"dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"tableName": "tableName",
|
||||
"serverId": 9,
|
||||
"port": 3306
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "PostgreSQLCDCSource",
|
||||
"type": "PostgreSQLCDC",
|
||||
"properties": {
|
||||
"dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"tableName": "tableName",
|
||||
"slotName": "slotName",
|
||||
"port": 5432
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "GooglePubSubSource",
|
||||
"type": "GooglePubSub",
|
||||
"properties": {
|
||||
"dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37"
|
||||
},
|
||||
"status": "Running",
|
||||
"error": null
|
||||
}
|
||||
],
|
||||
"destinations": [
|
||||
{
|
||||
"name": "CustomEndpointDestination",
|
||||
"type": "CustomEndpoint",
|
||||
"properties": {},
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "DerivedStreamName"
|
||||
}
|
||||
],
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "LakehouseDestination",
|
||||
"type": "Lakehouse",
|
||||
"properties": {
|
||||
"workspaceId": "9625b495-17b3-4d6c-aeea-a81ae76ba369",
|
||||
"itemId": "ee579458-85ea-4652-bd77-5c7d7c298b2a",
|
||||
"schema": "dbo",
|
||||
"deltaTable": "deltaTable",
|
||||
"minimumRows": 100000,
|
||||
"maximumDurationInSeconds": 120,
|
||||
"inputSerialization": {
|
||||
"type": "Json",
|
||||
"properties": {
|
||||
"encoding": "UTF8"
|
||||
}
|
||||
}
|
||||
},
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "DerivedStreamName"
|
||||
}
|
||||
],
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "EventhouseProcessedIngestionModeDestination",
|
||||
"type": "Eventhouse",
|
||||
"properties": {
|
||||
"dataIngestionMode": "ProcessedIngestion",
|
||||
"workspaceId": "9625b495-17b3-4d6c-aeea-a81ae76ba369",
|
||||
"itemId": "4c8c3353-9652-4567-b8f3-eb585ef01ba9",
|
||||
"databaseName": "databaseName",
|
||||
"tableName": "tableName",
|
||||
"inputSerialization": {
|
||||
"type": "Json",
|
||||
"properties": {
|
||||
"encoding": "UTF8"
|
||||
}
|
||||
}
|
||||
},
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "EventStreamName-stream"
|
||||
}
|
||||
],
|
||||
"status": "Running",
|
||||
"error": null
|
||||
},
|
||||
{
|
||||
"name": "EventhouseDirectIngestionModeDestination",
|
||||
"type": "Eventhouse",
|
||||
"properties": {
|
||||
"dataIngestionMode": "DirectIngestion",
|
||||
"workspaceId": "9625b495-17b3-4d6c-aeea-a81ae76ba369",
|
||||
"itemId": "4c8c3353-9652-4567-b8f3-eb585ef01ba9",
|
||||
"connectionName": "connectionName",
|
||||
"mappingRuleName": "mappingRuleName"
|
||||
},
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "EventStreamName-stream"
|
||||
}
|
||||
],
|
||||
"status": "External",
|
||||
"error": null
|
||||
}
|
||||
],
|
||||
"streams": [
|
||||
{
|
||||
"name": "DerivedStreamName",
|
||||
"type": "DerivedStream",
|
||||
"properties": {
|
||||
"inputSerialization": {
|
||||
"type": "Json",
|
||||
"properties": {
|
||||
"encoding": "UTF8"
|
||||
}
|
||||
}
|
||||
},
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "FilterName"
|
||||
}
|
||||
]
|
||||
}
|
||||
],
|
||||
"operators": [
|
||||
{
|
||||
"name": "FilterName",
|
||||
"type": "Filter",
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "EventStreamName-stream"
|
||||
}
|
||||
],
|
||||
"properties": {
|
||||
"conditions": [
|
||||
{
|
||||
"column": {
|
||||
"node": "nodeName",
|
||||
"columnName": "columnName",
|
||||
"columnPathSegments": [
|
||||
"path",
|
||||
"to",
|
||||
"column"
|
||||
]
|
||||
},
|
||||
"operator": "Equals",
|
||||
"value": {
|
||||
"dataType": "nvarchar(max)",
|
||||
"value": "stringValue"
|
||||
}
|
||||
}
|
||||
]
|
||||
},
|
||||
"inputSchemas": [
|
||||
{
|
||||
"name": "EventStreamName-stream",
|
||||
"schema": {
|
||||
"columns": [
|
||||
{
|
||||
"name": "BikepointID",
|
||||
"type": "Nvarchar(max)",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "Street",
|
||||
"type": "Nvarchar(max)",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "Neighbourhood",
|
||||
"type": "Nvarchar(max)",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "Latitude",
|
||||
"type": "Float",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "Longitude",
|
||||
"type": "Float",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "No_Bikes",
|
||||
"type": "BigInt",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "No_Empty_Docks",
|
||||
"type": "BigInt",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "Record_Example",
|
||||
"type": "Record",
|
||||
"fields": [
|
||||
{
|
||||
"name": "column1",
|
||||
"type": "BigInt"
|
||||
},
|
||||
{
|
||||
"name": "column2",
|
||||
"type": "Nvarchar(max)"
|
||||
}
|
||||
]
|
||||
},
|
||||
{
|
||||
"name": "Array_Example",
|
||||
"type": "Array",
|
||||
"items": {
|
||||
"type": "BigInt"
|
||||
}
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
]
|
||||
},
|
||||
{
|
||||
"name": "JoinerName",
|
||||
"type": "Join",
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "FilterName"
|
||||
},
|
||||
{
|
||||
"name": "DerivedStreamName"
|
||||
}
|
||||
],
|
||||
"properties": {
|
||||
"joinType": "Inner",
|
||||
"joinOn": [
|
||||
{
|
||||
"left": {
|
||||
"node": "leftNodeName",
|
||||
"columnName": "leftColumnName"
|
||||
},
|
||||
"right": {
|
||||
"node": "rightNodeName",
|
||||
"columnName": "rightColumnName"
|
||||
}
|
||||
}
|
||||
],
|
||||
"duration": {
|
||||
"value": 1,
|
||||
"unit": "Minute"
|
||||
}
|
||||
}
|
||||
},
|
||||
{
|
||||
"name": "FieldsManagerName",
|
||||
"type": "ManageFields",
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "DerivedStreamName"
|
||||
}
|
||||
],
|
||||
"properties": {
|
||||
"columns": [
|
||||
{
|
||||
"type": "Rename",
|
||||
"properties": {
|
||||
"column": {
|
||||
"node": "renameNode",
|
||||
"columnName": "renameColumn"
|
||||
}
|
||||
},
|
||||
"alias": "renameAlias"
|
||||
},
|
||||
{
|
||||
"type": "Cast",
|
||||
"properties": {
|
||||
"targetDataType": "BigInt",
|
||||
"column": {
|
||||
"node": "castNode",
|
||||
"columnName": "castColumn"
|
||||
}
|
||||
},
|
||||
"alias": "castAlias"
|
||||
},
|
||||
{
|
||||
"type": "FunctionCall",
|
||||
"properties": {
|
||||
"functionName": "CharIndex",
|
||||
"arguments": [
|
||||
"a",
|
||||
{
|
||||
"node": "functionCallNode",
|
||||
"columnName": "functionCallColumn"
|
||||
},
|
||||
1
|
||||
]
|
||||
},
|
||||
"alias": "indexOf"
|
||||
}
|
||||
]
|
||||
},
|
||||
"inputSchemas": [
|
||||
{
|
||||
"name": "DerivedStreamName",
|
||||
"schema": {
|
||||
"columns": [
|
||||
{
|
||||
"name": "BikepointID",
|
||||
"type": "Nvarchar(max)",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "Street",
|
||||
"type": "Nvarchar(max)",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "Neighbourhood",
|
||||
"type": "Nvarchar(max)",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "Latitude",
|
||||
"type": "Float",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "Longitude",
|
||||
"type": "Float",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "No_Bikes",
|
||||
"type": "BigInt",
|
||||
"fields": null,
|
||||
"items": null
|
||||
},
|
||||
{
|
||||
"name": "No_Empty_Docks",
|
||||
"type": "BigInt",
|
||||
"fields": null,
|
||||
"items": null
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
]
|
||||
},
|
||||
{
|
||||
"name": "AggregatorName",
|
||||
"type": "Aggregate",
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "DerivedStreamName"
|
||||
}
|
||||
],
|
||||
"properties": {
|
||||
"aggregations": [
|
||||
{
|
||||
"aggregationFunction": "Average",
|
||||
"column": {
|
||||
"node": "aggregationNode",
|
||||
"columnName": "aggregationColumn"
|
||||
},
|
||||
"alias": "aggregatedAlias",
|
||||
"partitionBy": [
|
||||
{
|
||||
"node": "partitionByNode",
|
||||
"columnName": "partitionByColumn"
|
||||
}
|
||||
],
|
||||
"duration": {
|
||||
"value": 1,
|
||||
"unit": "Minute"
|
||||
}
|
||||
}
|
||||
]
|
||||
}
|
||||
},
|
||||
{
|
||||
"name": "GroupByName",
|
||||
"type": "GroupBy",
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "DerivedStreamName"
|
||||
}
|
||||
],
|
||||
"properties": {
|
||||
"aggregations": [
|
||||
{
|
||||
"aggregationFunction": "Average",
|
||||
"column": {
|
||||
"node": "groupByAggregationNode",
|
||||
"columnName": "groupByAggregationColumn"
|
||||
},
|
||||
"alias": "groupByAggregationAlias"
|
||||
}
|
||||
],
|
||||
"groupBy": [
|
||||
{
|
||||
"node": "groupByNode",
|
||||
"columnName": "groupByColumn"
|
||||
}
|
||||
],
|
||||
"window": {
|
||||
"type": "Tumbling",
|
||||
"properties": {
|
||||
"duration": {
|
||||
"value": 5,
|
||||
"unit": "Minute"
|
||||
},
|
||||
"offset": {
|
||||
"value": 1,
|
||||
"unit": "Minute"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
{
|
||||
"name": "UnionName",
|
||||
"type": "Union",
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "FilterName"
|
||||
},
|
||||
{
|
||||
"name": "GroupByName"
|
||||
}
|
||||
],
|
||||
"properties": {}
|
||||
},
|
||||
{
|
||||
"name": "ExpansionName",
|
||||
"type": "Expand",
|
||||
"inputNodes": [
|
||||
{
|
||||
"name": "MyNode"
|
||||
}
|
||||
],
|
||||
"properties": {
|
||||
"column": [
|
||||
{
|
||||
"node": "expansionNode",
|
||||
"columnName": "expansionColumn"
|
||||
}
|
||||
],
|
||||
"ignoreMissingOrEmpty": true
|
||||
}
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,34 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229"
|
||||
},
|
||||
"responses": {
|
||||
"200": {
|
||||
"body": {
|
||||
"value": [
|
||||
{
|
||||
"id": "3546052c-ae64-4526-b1a8-52af7761426f",
|
||||
"displayName": "Eventstream_1",
|
||||
"description": "An eventstream description.",
|
||||
"type": "Eventstream",
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229"
|
||||
},
|
||||
{
|
||||
"id": "dc307e72-3e89-4425-97c3-a364d86dddfa",
|
||||
"displayName": "Eventstream_2",
|
||||
"description": "An eventstream description.",
|
||||
"type": "Eventstream",
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229"
|
||||
},
|
||||
{
|
||||
"id": "b48a1f80-862a-4b97-b672-7217bf064dc0",
|
||||
"displayName": "Eventstream_3",
|
||||
"description": "An eventstream description.",
|
||||
"type": "Eventstream",
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229"
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,9 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "8c500070-073f-4a88-b478-8fabe1941c52"
|
||||
},
|
||||
"responses": {
|
||||
"200": {}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,10 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "8c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"destinationId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37"
|
||||
},
|
||||
"responses": {
|
||||
"200": {}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,10 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "8c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"sourceId": "e2886002-d696-4c05-969c-51361365cc24"
|
||||
},
|
||||
"responses": {
|
||||
"200": {}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,12 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "8c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"resumeEventstreamRequest": {
|
||||
"startType": "Now"
|
||||
}
|
||||
},
|
||||
"responses": {
|
||||
"200": {}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,14 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "8c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"destinationId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
|
||||
"resumeEventstreamDestinationRequest": {
|
||||
"startType": "CustomTime",
|
||||
"customStartDateTime": "2023-05-23T16:22:20Z"
|
||||
}
|
||||
},
|
||||
"responses": {
|
||||
"200": {}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,13 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "8c500070-073f-4a88-b478-8fabe1941c52",
|
||||
"sourceId": "e2886002-d696-4c05-969c-51361365cc24",
|
||||
"resumeEventstreamSourceRequest": {
|
||||
"startType": "WhenLastStopped"
|
||||
}
|
||||
},
|
||||
"responses": {
|
||||
"200": {}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,21 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "5b218778-e7a5-4d73-8187-f10824047715",
|
||||
"updateEventstreamRequest": {
|
||||
"displayName": "Eventstream_New_Name",
|
||||
"description": "A new description for eventstream."
|
||||
}
|
||||
},
|
||||
"responses": {
|
||||
"200": {
|
||||
"body": {
|
||||
"displayName": "Eventstream_New_Name",
|
||||
"description": "A new description for eventstream.",
|
||||
"type": "Eventstream",
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"id": "5b218778-e7a5-4d73-8187-f10824047715"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,33 @@
|
||||
{
|
||||
"parameters": {
|
||||
"workspaceId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
|
||||
"eventstreamId": "5b218778-e7a5-4d73-8187-f10824047715",
|
||||
"updateMetadata": true,
|
||||
"updateEventstreamDefinitionRequest": {
|
||||
"definition": {
|
||||
"parts": [
|
||||
{
|
||||
"path": "eventstream.json",
|
||||
"payload": "SSdkIGxpa2UgdG8gdGVsbCBh..IGpva2UgZm9yIHlvdS4K",
|
||||
"payloadType": "InlineBase64"
|
||||
},
|
||||
{
|
||||
"path": ".platform",
|
||||
"payload": "ZG90UGxhdGZvcm1CYXNlNjRTdHJpbmc=",
|
||||
"payloadType": "InlineBase64"
|
||||
}
|
||||
]
|
||||
}
|
||||
}
|
||||
},
|
||||
"responses": {
|
||||
"200": {},
|
||||
"202": {
|
||||
"headers": {
|
||||
"Location": "https://api.fabric.microsoft.com/v1/operations/427f6c34-b64e-4ee4-8ea5-b533c0e203ef",
|
||||
"x-ms-operation-id": "427f6c34-b64e-4ee4-8ea5-b533c0e203ef",
|
||||
"Retry-After": 30
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
File diff suppressed because it is too large.
Load diff
Reference in new issue
Block a user