pulumi-azure-native-kotlin/com.pulumi.azurenative.streamanalytics.kotlin.outputs

Package-level declarations

Types

data class AggregateFunctionPropertiesResponse(val binding: Either<AzureMachineLearningWebServiceFunctionBindingResponse, JavaScriptFunctionBindingResponse>? = null, val etag: String, val inputs: List<FunctionInputResponse>? = null, val output: FunctionOutputResponse? = null, val type: String)

The properties that are associated with an aggregate function.

AvroSerializationResponse

data class AvroSerializationResponse(val type: String)

Describes how data from an input is serialized or how data is serialized when written to an output in Avro format.

AzureDataLakeStoreOutputDataSourceResponse

data class AzureDataLakeStoreOutputDataSourceResponse(val accountName: String? = null, val authenticationMode: String? = null, val dateFormat: String? = null, val filePathPrefix: String? = null, val refreshToken: String? = null, val tenantId: String? = null, val timeFormat: String? = null, val tokenUserDisplayName: String? = null, val tokenUserPrincipalName: String? = null, val type: String)

Describes an Azure Data Lake Store output data source.

AzureFunctionOutputDataSourceResponse

data class AzureFunctionOutputDataSourceResponse(val apiKey: String? = null, val functionAppName: String? = null, val functionName: String? = null, val maxBatchCount: Double? = null, val maxBatchSize: Double? = null, val type: String)

Defines the metadata of AzureFunctionOutputDataSource

AzureMachineLearningWebServiceFunctionBindingResponse

data class AzureMachineLearningWebServiceFunctionBindingResponse(val apiKey: String? = null, val batchSize: Int? = null, val endpoint: String? = null, val inputs: AzureMachineLearningWebServiceInputsResponse? = null, val outputs: List<AzureMachineLearningWebServiceOutputColumnResponse>? = null, val type: String)

The binding to an Azure Machine Learning web service.

AzureMachineLearningWebServiceInputColumnResponse

data class AzureMachineLearningWebServiceInputColumnResponse(val dataType: String? = null, val mapTo: Int? = null, val name: String? = null)

Describes an input column for the Azure Machine Learning web service endpoint.

AzureMachineLearningWebServiceInputsResponse

data class AzureMachineLearningWebServiceInputsResponse(val columnNames: List<AzureMachineLearningWebServiceInputColumnResponse>? = null, val name: String? = null)

The inputs for the Azure Machine Learning web service endpoint.

AzureMachineLearningWebServiceOutputColumnResponse

data class AzureMachineLearningWebServiceOutputColumnResponse(val dataType: String? = null, val name: String? = null)

Describes an output column for the Azure Machine Learning web service endpoint.

AzureSqlDatabaseOutputDataSourceResponse

data class AzureSqlDatabaseOutputDataSourceResponse(val authenticationMode: String? = null, val database: String? = null, val maxBatchCount: Double? = null, val maxWriterCount: Double? = null, val password: String? = null, val server: String? = null, val table: String? = null, val type: String, val user: String? = null)

Describes an Azure SQL database output data source.

AzureSqlReferenceInputDataSourceResponse

data class AzureSqlReferenceInputDataSourceResponse(val database: String? = null, val deltaSnapshotQuery: String? = null, val fullSnapshotQuery: String? = null, val password: String? = null, val refreshRate: String? = null, val refreshType: String? = null, val server: String? = null, val table: String? = null, val type: String, val user: String? = null)

Describes an Azure SQL database reference input data source.

AzureSynapseOutputDataSourceResponse

data class AzureSynapseOutputDataSourceResponse(val database: String? = null, val password: String? = null, val server: String? = null, val table: String? = null, val type: String, val user: String? = null)

Describes an Azure Synapse output data source.

AzureTableOutputDataSourceResponse

data class AzureTableOutputDataSourceResponse(val accountKey: String? = null, val accountName: String? = null, val batchSize: Int? = null, val columnsToRemove: List<String>? = null, val partitionKey: String? = null, val rowKey: String? = null, val table: String? = null, val type: String)

Describes an Azure Table output data source.

BlobOutputDataSourceResponse

data class BlobOutputDataSourceResponse(val authenticationMode: String? = null, val blobPathPrefix: String? = null, val container: String? = null, val dateFormat: String? = null, val pathPattern: String? = null, val storageAccounts: List<StorageAccountResponse>? = null, val timeFormat: String? = null, val type: String)

Describes a blob output data source.

BlobReferenceInputDataSourceResponse

data class BlobReferenceInputDataSourceResponse(val authenticationMode: String? = null, val container: String? = null, val dateFormat: String? = null, val pathPattern: String? = null, val storageAccounts: List<StorageAccountResponse>? = null, val timeFormat: String? = null, val type: String)

Describes a blob input data source that contains reference data.

BlobStreamInputDataSourceResponse

data class BlobStreamInputDataSourceResponse(val authenticationMode: String? = null, val container: String? = null, val dateFormat: String? = null, val pathPattern: String? = null, val sourcePartitionCount: Int? = null, val storageAccounts: List<StorageAccountResponse>? = null, val timeFormat: String? = null, val type: String)

Describes a blob input data source that contains stream data.

ClusterInfoResponse

data class ClusterInfoResponse(val id: String? = null)

The properties associated with a Stream Analytics cluster.

ClusterJobResponse

data class ClusterJobResponse(val id: String, val jobState: String, val streamingUnits: Int)

A streaming job.

ClusterSkuResponse

data class ClusterSkuResponse(val capacity: Int? = null, val name: String? = null)

The SKU of the cluster. This determines the size/capacity of the cluster. Required on PUT (CreateOrUpdate) requests.

CompressionResponse

data class CompressionResponse(val type: String)

Describes how input data is compressed

CsvSerializationResponse

data class CsvSerializationResponse(val encoding: String? = null, val fieldDelimiter: String? = null, val type: String)

Describes how data from an input is serialized or how data is serialized when written to an output in CSV format.

DiagnosticConditionResponse

data class DiagnosticConditionResponse(val code: String, val message: String, val since: String)

Condition applicable to the resource, or to the job overall, that warrant customer attention.

DiagnosticsResponse

data class DiagnosticsResponse(val conditions: List<DiagnosticConditionResponse>)

Describes conditions applicable to the Input, Output, or the job overall, that warrant customer attention.

DocumentDbOutputDataSourceResponse

data class DocumentDbOutputDataSourceResponse(val accountId: String? = null, val accountKey: String? = null, val collectionNamePattern: String? = null, val database: String? = null, val documentId: String? = null, val partitionKey: String? = null, val type: String)

Describes a DocumentDB output data source.

EventHubOutputDataSourceResponse

data class EventHubOutputDataSourceResponse(val authenticationMode: String? = null, val eventHubName: String? = null, val partitionKey: String? = null, val propertyColumns: List<String>? = null, val serviceBusNamespace: String? = null, val sharedAccessPolicyKey: String? = null, val sharedAccessPolicyName: String? = null, val type: String)

Describes an Event Hub output data source.

EventHubStreamInputDataSourceResponse

data class EventHubStreamInputDataSourceResponse(val authenticationMode: String? = null, val consumerGroupName: String? = null, val eventHubName: String? = null, val serviceBusNamespace: String? = null, val sharedAccessPolicyKey: String? = null, val sharedAccessPolicyName: String? = null, val type: String)

Describes an Event Hub input data source that contains stream data.

EventHubV2OutputDataSourceResponse

data class EventHubV2OutputDataSourceResponse(val authenticationMode: String? = null, val eventHubName: String? = null, val partitionKey: String? = null, val propertyColumns: List<String>? = null, val serviceBusNamespace: String? = null, val sharedAccessPolicyKey: String? = null, val sharedAccessPolicyName: String? = null, val type: String)

Describes an Event Hub output data source.

EventHubV2StreamInputDataSourceResponse

data class EventHubV2StreamInputDataSourceResponse(val authenticationMode: String? = null, val consumerGroupName: String? = null, val eventHubName: String? = null, val serviceBusNamespace: String? = null, val sharedAccessPolicyKey: String? = null, val sharedAccessPolicyName: String? = null, val type: String)

Describes an Event Hub input data source that contains stream data.

FileReferenceInputDataSourceResponse

data class FileReferenceInputDataSourceResponse(val path: String? = null, val type: String)

Describes a file input data source that contains reference data.

FunctionInputResponse

data class FunctionInputResponse(val dataType: String? = null, val isConfigurationParameter: Boolean? = null)

Describes one input parameter of a function.

FunctionOutputResponse

data class FunctionOutputResponse(val dataType: String? = null)

Describes the output of a function.

FunctionResponse

data class FunctionResponse(val id: String, val name: String? = null, val properties: Either<AggregateFunctionPropertiesResponse, ScalarFunctionPropertiesResponse>? = null, val type: String)

A function object, containing all information associated with the named function. All functions are contained under a streaming job.

GatewayMessageBusOutputDataSourceResponse

data class GatewayMessageBusOutputDataSourceResponse(val topic: String? = null, val type: String)

Describes a Gateway Message Bus output data source.

GatewayMessageBusStreamInputDataSourceResponse

data class GatewayMessageBusStreamInputDataSourceResponse(val topic: String? = null, val type: String)

Describes a blob input data source that contains stream data.

GetClusterResult

data class GetClusterResult(val azureApiVersion: String, val capacityAllocated: Int, val capacityAssigned: Int, val clusterId: String, val createdDate: String, val etag: String, val id: String, val location: String? = null, val name: String, val provisioningState: String, val sku: ClusterSkuResponse? = null, val tags: Map<String, String>? = null, val type: String)

A Stream Analytics Cluster object

GetFunctionResult

data class GetFunctionResult(val azureApiVersion: String, val id: String, val name: String? = null, val properties: Either<AggregateFunctionPropertiesResponse, ScalarFunctionPropertiesResponse>, val type: String)

A function object, containing all information associated with the named function. All functions are contained under a streaming job.

GetInputResult

data class GetInputResult(val azureApiVersion: String, val id: String, val name: String? = null, val properties: Either<ReferenceInputPropertiesResponse, StreamInputPropertiesResponse>, val type: String)

An input object, containing all information associated with the named input. All inputs are contained under a streaming job.

GetOutputResult

data class GetOutputResult(val azureApiVersion: String, val datasource: Any? = null, val diagnostics: DiagnosticsResponse, val etag: String, val id: String, val name: String? = null, val serialization: Any? = null, val sizeWindow: Int? = null, val timeWindow: String? = null, val type: String)

An output object, containing all information associated with the named output. All outputs are contained under a streaming job.

GetPrivateEndpointResult

data class GetPrivateEndpointResult(val azureApiVersion: String, val createdDate: String, val etag: String, val id: String, val manualPrivateLinkServiceConnections: List<PrivateLinkServiceConnectionResponse>? = null, val name: String, val type: String)

Complete information about the private endpoint.

GetStreamingJobResult

data class GetStreamingJobResult(val azureApiVersion: String, val cluster: ClusterInfoResponse? = null, val compatibilityLevel: String? = null, val contentStoragePolicy: String? = null, val createdDate: String, val dataLocale: String? = null, val etag: String, val eventsLateArrivalMaxDelayInSeconds: Int? = null, val eventsOutOfOrderMaxDelayInSeconds: Int? = null, val eventsOutOfOrderPolicy: String? = null, val functions: List<FunctionResponse>? = null, val id: String, val identity: IdentityResponse? = null, val inputs: List<InputResponse>? = null, val jobId: String, val jobState: String, val jobStorageAccount: JobStorageAccountResponse? = null, val jobType: String? = null, val lastOutputEventTime: String, val location: String? = null, val name: String, val outputErrorPolicy: String? = null, val outputStartMode: String? = null, val outputStartTime: String? = null, val outputs: List<OutputResponse>? = null, val provisioningState: String, val sku: SkuResponse? = null, val tags: Map<String, String>? = null, val transformation: TransformationResponse? = null, val type: String)

A streaming job object, containing all information associated with the named streaming job.

IdentityResponse

data class IdentityResponse(val principalId: String, val tenantId: String, val type: String? = null)

Describes how identity is verified

InputResponse

data class InputResponse(val id: String, val name: String? = null, val properties: Either<ReferenceInputPropertiesResponse, StreamInputPropertiesResponse>? = null, val type: String)

An input object, containing all information associated with the named input. All inputs are contained under a streaming job.

IoTHubStreamInputDataSourceResponse

data class IoTHubStreamInputDataSourceResponse(val consumerGroupName: String? = null, val endpoint: String? = null, val iotHubNamespace: String? = null, val sharedAccessPolicyKey: String? = null, val sharedAccessPolicyName: String? = null, val type: String)

Describes an IoT Hub input data source that contains stream data.

JavaScriptFunctionBindingResponse

data class JavaScriptFunctionBindingResponse(val script: String? = null, val type: String)

The binding to a JavaScript function.

JobStorageAccountResponse

data class JobStorageAccountResponse(val accountKey: String? = null, val accountName: String? = null, val authenticationMode: String? = null)

The properties that are associated with an Azure Storage account with MSI

JsonSerializationResponse

data class JsonSerializationResponse(val encoding: String? = null, val format: String? = null, val type: String)

Describes how data from an input is serialized or how data is serialized when written to an output in JSON format.

ListClusterStreamingJobsResult

data class ListClusterStreamingJobsResult(val nextLink: String, val value: List<ClusterJobResponse>)

A list of streaming jobs. Populated by a List operation.

OutputResponse

data class OutputResponse(val datasource: Any? = null, val diagnostics: DiagnosticsResponse, val etag: String, val id: String, val name: String? = null, val serialization: Any? = null, val sizeWindow: Int? = null, val timeWindow: String? = null, val type: String)

An output object, containing all information associated with the named output. All outputs are contained under a streaming job.

ParquetSerializationResponse

data class ParquetSerializationResponse(val type: String)

Describes how data from an input is serialized or how data is serialized when written to an output in Parquet format.

PowerBIOutputDataSourceResponse

data class PowerBIOutputDataSourceResponse(val authenticationMode: String? = null, val dataset: String? = null, val groupId: String? = null, val groupName: String? = null, val refreshToken: String? = null, val table: String? = null, val tokenUserDisplayName: String? = null, val tokenUserPrincipalName: String? = null, val type: String)

Describes a Power BI output data source.

PrivateLinkConnectionStateResponse

data class PrivateLinkConnectionStateResponse(val actionsRequired: String, val description: String, val status: String)

A collection of read-only information about the state of the connection to the private remote resource.

PrivateLinkServiceConnectionResponse

data class PrivateLinkServiceConnectionResponse(val groupIds: List<String>? = null, val privateLinkServiceConnectionState: PrivateLinkConnectionStateResponse? = null, val privateLinkServiceId: String? = null, val requestMessage: String)

A grouping of information about the connection to the remote resource.

ReferenceInputPropertiesResponse

data class ReferenceInputPropertiesResponse(val compression: CompressionResponse? = null, val datasource: Any? = null, val diagnostics: DiagnosticsResponse, val etag: String, val partitionKey: String? = null, val serialization: Any? = null, val type: String)

The properties that are associated with an input containing reference data.

ScalarFunctionPropertiesResponse

data class ScalarFunctionPropertiesResponse(val binding: Either<AzureMachineLearningWebServiceFunctionBindingResponse, JavaScriptFunctionBindingResponse>? = null, val etag: String, val inputs: List<FunctionInputResponse>? = null, val output: FunctionOutputResponse? = null, val type: String)

The properties that are associated with a scalar function.

ServiceBusQueueOutputDataSourceResponse

data class ServiceBusQueueOutputDataSourceResponse(val authenticationMode: String? = null, val propertyColumns: List<String>? = null, val queueName: String? = null, val serviceBusNamespace: String? = null, val sharedAccessPolicyKey: String? = null, val sharedAccessPolicyName: String? = null, val systemPropertyColumns: Any? = null, val type: String)

Describes a Service Bus Queue output data source.

ServiceBusTopicOutputDataSourceResponse

data class ServiceBusTopicOutputDataSourceResponse(val authenticationMode: String? = null, val propertyColumns: List<String>? = null, val serviceBusNamespace: String? = null, val sharedAccessPolicyKey: String? = null, val sharedAccessPolicyName: String? = null, val systemPropertyColumns: Map<String, String>? = null, val topicName: String? = null, val type: String)

Describes a Service Bus Topic output data source.

SkuResponse

data class SkuResponse(val name: String? = null)

The properties that are associated with a SKU.

StorageAccountResponse

data class StorageAccountResponse(val accountKey: String? = null, val accountName: String? = null)

The properties that are associated with an Azure Storage account

StreamInputPropertiesResponse

data class StreamInputPropertiesResponse(val compression: CompressionResponse? = null, val datasource: Any? = null, val diagnostics: DiagnosticsResponse, val etag: String, val partitionKey: String? = null, val serialization: Any? = null, val type: String)

The properties that are associated with an input containing stream data.

TransformationResponse

data class TransformationResponse(val etag: String, val id: String, val name: String? = null, val query: String? = null, val streamingUnits: Int? = null, val type: String, val validStreamingUnits: List<Int>? = null)

A transformation object, containing all information associated with the named transformation. All transformations are contained under a streaming job.