Freigeben über


ArmStreamAnalyticsModelFactory.StreamingJobOutputData Method

Definition

Initializes a new instance of StreamingJobOutputData.

public static Azure.ResourceManager.StreamAnalytics.StreamingJobOutputData StreamingJobOutputData (Azure.Core.ResourceIdentifier id = default, string name = default, Azure.Core.ResourceType? resourceType = default, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputDataSource datasource = default, TimeSpan? timeFrame = default, float? sizeWindow = default, Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsDataSerialization serialization = default, System.Collections.Generic.IEnumerable<Azure.ResourceManager.StreamAnalytics.Models.StreamingJobDiagnosticCondition> diagnosticsConditions = default, Azure.ETag? etag = default, System.Collections.Generic.IEnumerable<Azure.ResourceManager.StreamAnalytics.Models.LastOutputEventTimestamp> lastOutputEventTimestamps = default, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputWatermarkProperties watermarkSettings = default);
static member StreamingJobOutputData : Azure.Core.ResourceIdentifier * string * Nullable<Azure.Core.ResourceType> * Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputDataSource * Nullable<TimeSpan> * Nullable<single> * Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsDataSerialization * seq<Azure.ResourceManager.StreamAnalytics.Models.StreamingJobDiagnosticCondition> * Nullable<Azure.ETag> * seq<Azure.ResourceManager.StreamAnalytics.Models.LastOutputEventTimestamp> * Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputWatermarkProperties -> Azure.ResourceManager.StreamAnalytics.StreamingJobOutputData
Public Shared Function StreamingJobOutputData (Optional id As ResourceIdentifier = Nothing, Optional name As String = Nothing, Optional resourceType As Nullable(Of ResourceType) = Nothing, Optional datasource As StreamingJobOutputDataSource = Nothing, Optional timeFrame As Nullable(Of TimeSpan) = Nothing, Optional sizeWindow As Nullable(Of Single) = Nothing, Optional serialization As StreamAnalyticsDataSerialization = Nothing, Optional diagnosticsConditions As IEnumerable(Of StreamingJobDiagnosticCondition) = Nothing, Optional etag As Nullable(Of ETag) = Nothing, Optional lastOutputEventTimestamps As IEnumerable(Of LastOutputEventTimestamp) = Nothing, Optional watermarkSettings As StreamingJobOutputWatermarkProperties = Nothing) As StreamingJobOutputData

Parameters

id
ResourceIdentifier

Resource Id.

name
String

Resource name.

resourceType
Nullable<ResourceType>

Resource type.

datasource
StreamingJobOutputDataSource

Describes the data source that output will be written to. Required on PUT (CreateOrReplace) requests. Please note StreamingJobOutputDataSource is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. The available derived classes include GatewayMessageBusOutputDataSource, FunctionOutputDataSource, PostgreSQLOutputDataSource, DataLakeStoreOutputDataSource, EventHubV2OutputDataSource, EventHubOutputDataSource, ServiceBusQueueOutputDataSource, ServiceBusTopicOutputDataSource, SynapseOutputDataSource, SqlDatabaseOutputDataSource, BlobOutputDataSource, DocumentDbOutputDataSource, TableOutputDataSource, PowerBIOutputDataSource and RawOutputDatasource.

timeFrame
Nullable<TimeSpan>

The time frame for filtering Stream Analytics job outputs.

sizeWindow
Nullable<Single>

The size window to constrain a Stream Analytics output to.

serialization
StreamAnalyticsDataSerialization

Describes how data from an input is serialized or how data is serialized when written to an output. Required on PUT (CreateOrReplace) requests. Please note StreamAnalyticsDataSerialization is the base class. According to the scenario, a derived class of the base class might need to be assigned here, or this property needs to be casted to one of the possible derived classes. The available derived classes include AvroFormatSerialization, CsvFormatSerialization, CustomClrFormatSerialization, JsonFormatSerialization and ParquetFormatSerialization.

diagnosticsConditions
IEnumerable<StreamingJobDiagnosticCondition>

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

etag
Nullable<ETag>

The current entity tag for the output. This is an opaque string. You can use it to detect whether the resource has changed between requests. You can also use it in the If-Match or If-None-Match headers for write operations for optimistic concurrency.

lastOutputEventTimestamps
IEnumerable<LastOutputEventTimestamp>

A list of the last output event times for each output partition. The index of the array corresponds to the partition number.

watermarkSettings
StreamingJobOutputWatermarkProperties

Settings which determine whether to send watermarks to downstream.

Returns

A new StreamingJobOutputData instance for mocking.

Applies to