ArmStreamAnalyticsModelFactory.StreamingJobData Method
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
Initializes a new instance of StreamingJobData.
public static Azure.ResourceManager.StreamAnalytics.StreamingJobData StreamingJobData (Azure.Core.ResourceIdentifier id = default, string name = default, Azure.Core.ResourceType resourceType = default, Azure.ResourceManager.Models.SystemData systemData = default, System.Collections.Generic.IDictionary<string,string> tags = default, Azure.Core.AzureLocation location = default, Azure.ResourceManager.Models.ManagedServiceIdentity identity = default, Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSkuName? skuName = default, Guid? jobId = default, string provisioningState = default, string jobState = default, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobType? jobType = default, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputStartMode? outputStartMode = default, DateTimeOffset? outputStartOn = default, DateTimeOffset? lastOutputEventOn = default, Azure.ResourceManager.StreamAnalytics.Models.EventsOutOfOrderPolicy? eventsOutOfOrderPolicy = default, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputErrorPolicy? outputErrorPolicy = default, int? eventsOutOfOrderMaxDelayInSeconds = default, int? eventsLateArrivalMaxDelayInSeconds = default, Azure.Core.AzureLocation? dataLocalion = default, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobCompatibilityLevel? compatibilityLevel = default, DateTimeOffset? createdOn = default, System.Collections.Generic.IEnumerable<Azure.ResourceManager.StreamAnalytics.StreamingJobInputData> inputs = default, Azure.ResourceManager.StreamAnalytics.StreamingJobTransformationData transformation = default, System.Collections.Generic.IEnumerable<Azure.ResourceManager.StreamAnalytics.StreamingJobOutputData> outputs = default, System.Collections.Generic.IEnumerable<Azure.ResourceManager.StreamAnalytics.StreamingJobFunctionData> functions = default, Azure.ETag? etag = default, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobStorageAccount jobStorageAccount = default, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobContentStoragePolicy? contentStoragePolicy = default, Azure.ResourceManager.StreamAnalytics.Models.StreamingJobExternal externals = default, Azure.Core.ResourceIdentifier clusterId = default);static member StreamingJobData : Azure.Core.ResourceIdentifier * string * Azure.Core.ResourceType * Azure.ResourceManager.Models.SystemData * System.Collections.Generic.IDictionary<string, string> * Azure.Core.AzureLocation * Azure.ResourceManager.Models.ManagedServiceIdentity * Nullable<Azure.ResourceManager.StreamAnalytics.Models.StreamAnalyticsSkuName> * Nullable<Guid> * string * string * Nullable<Azure.ResourceManager.StreamAnalytics.Models.StreamingJobType> * Nullable<Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputStartMode> * Nullable<DateTimeOffset> * Nullable<DateTimeOffset> * Nullable<Azure.ResourceManager.StreamAnalytics.Models.EventsOutOfOrderPolicy> * Nullable<Azure.ResourceManager.StreamAnalytics.Models.StreamingJobOutputErrorPolicy> * Nullable<int> * Nullable<int> * Nullable<Azure.Core.AzureLocation> * Nullable<Azure.ResourceManager.StreamAnalytics.Models.StreamingJobCompatibilityLevel> * Nullable<DateTimeOffset> * seq<Azure.ResourceManager.StreamAnalytics.StreamingJobInputData> * Azure.ResourceManager.StreamAnalytics.StreamingJobTransformationData * seq<Azure.ResourceManager.StreamAnalytics.StreamingJobOutputData> * seq<Azure.ResourceManager.StreamAnalytics.StreamingJobFunctionData> * Nullable<Azure.ETag> * Azure.ResourceManager.StreamAnalytics.Models.StreamingJobStorageAccount * Nullable<Azure.ResourceManager.StreamAnalytics.Models.StreamingJobContentStoragePolicy> * Azure.ResourceManager.StreamAnalytics.Models.StreamingJobExternal * Azure.Core.ResourceIdentifier -> Azure.ResourceManager.StreamAnalytics.StreamingJobDataPublic Shared Function StreamingJobData (Optional id As ResourceIdentifier = Nothing, Optional name As String = Nothing, Optional resourceType As ResourceType = Nothing, Optional systemData As SystemData = Nothing, Optional tags As IDictionary(Of String, String) = Nothing, Optional location As AzureLocation = Nothing, Optional identity As ManagedServiceIdentity = Nothing, Optional skuName As Nullable(Of StreamAnalyticsSkuName) = Nothing, Optional jobId As Nullable(Of Guid) = Nothing, Optional provisioningState As String = Nothing, Optional jobState As String = Nothing, Optional jobType As Nullable(Of StreamingJobType) = Nothing, Optional outputStartMode As Nullable(Of StreamingJobOutputStartMode) = Nothing, Optional outputStartOn As Nullable(Of DateTimeOffset) = Nothing, Optional lastOutputEventOn As Nullable(Of DateTimeOffset) = Nothing, Optional eventsOutOfOrderPolicy As Nullable(Of EventsOutOfOrderPolicy) = Nothing, Optional outputErrorPolicy As Nullable(Of StreamingJobOutputErrorPolicy) = Nothing, Optional eventsOutOfOrderMaxDelayInSeconds As Nullable(Of Integer) = Nothing, Optional eventsLateArrivalMaxDelayInSeconds As Nullable(Of Integer) = Nothing, Optional dataLocalion As Nullable(Of AzureLocation) = Nothing, Optional compatibilityLevel As Nullable(Of StreamingJobCompatibilityLevel) = Nothing, Optional createdOn As Nullable(Of DateTimeOffset) = Nothing, Optional inputs As IEnumerable(Of StreamingJobInputData) = Nothing, Optional transformation As StreamingJobTransformationData = Nothing, Optional outputs As IEnumerable(Of StreamingJobOutputData) = Nothing, Optional functions As IEnumerable(Of StreamingJobFunctionData) = Nothing, Optional etag As Nullable(Of ETag) = Nothing, Optional jobStorageAccount As StreamingJobStorageAccount = Nothing, Optional contentStoragePolicy As Nullable(Of StreamingJobContentStoragePolicy) = Nothing, Optional externals As StreamingJobExternal = Nothing, Optional clusterId As ResourceIdentifier = Nothing) As StreamingJobDataParameters
The id.
- name
- String
The name.
- resourceType
- ResourceType
The resourceType.
- systemData
- SystemData
The systemData.
- tags
- IDictionary<String,String>
The tags.
- location
- AzureLocation
The location.
- identity
- ManagedServiceIdentity
Describes the managed identity assigned to this job that can be used to authenticate with inputs and outputs. Current supported identity types: SystemAssigned, UserAssigned, SystemAssigned,UserAssigned.
- skuName
- Nullable<StreamAnalyticsSkuName>
Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests.
A GUID uniquely identifying the streaming job. This GUID is generated upon creation of the streaming job.
- provisioningState
- String
Describes the provisioning status of the streaming job.
- jobState
- String
Describes the state of the streaming job.
- jobType
- Nullable<StreamingJobType>
Describes the type of the job. Valid modes are Cloud and 'Edge'.
- outputStartMode
- Nullable<StreamingJobOutputStartMode>
This property should only be utilized when it is desired that the job be started immediately upon creation. Value may be JobStartTime, CustomTime, or LastOutputEventTime to indicate whether the starting point of the output event stream should start whenever the job is started, start at a custom user time stamp specified via the outputStartTime property, or start from the last event output time.
- outputStartOn
- Nullable<DateTimeOffset>
Value is either an ISO-8601 formatted time stamp that indicates the starting point of the output event stream, or null to indicate that the output event stream will start whenever the streaming job is started. This property must have a value if outputStartMode is set to CustomTime.
- lastOutputEventOn
- Nullable<DateTimeOffset>
Value is either an ISO-8601 formatted timestamp indicating the last output event time of the streaming job or null indicating that output has not yet been produced. In case of multiple outputs or multiple streams, this shows the latest value in that set.
- eventsOutOfOrderPolicy
- Nullable<EventsOutOfOrderPolicy>
Indicates the policy to apply to events that arrive out of order in the input event stream.
- outputErrorPolicy
- Nullable<StreamingJobOutputErrorPolicy>
Indicates the policy to apply to events that arrive at the output and cannot be written to the external storage due to being malformed (missing column values, column values of wrong type or size).
The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.
The maximum tolerable delay in seconds where events arriving late could be included. Supported range is -1 to 1814399 (20.23:59:59 days) and -1 is used to specify wait indefinitely. If the property is absent, it is interpreted to have a value of -1.
- dataLocalion
- Nullable<AzureLocation>
The data locale of the stream analytics job. Value should be the name of a supported .NET Culture from the set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Defaults to 'en-US' if none specified.
- compatibilityLevel
- Nullable<StreamingJobCompatibilityLevel>
Controls certain runtime behaviors of the streaming job.
- createdOn
- Nullable<DateTimeOffset>
Value is an ISO-8601 formatted UTC timestamp indicating when the streaming job was created.
- inputs
- IEnumerable<StreamingJobInputData>
A list of one or more inputs to the streaming job. The name property for each input is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual input.
- transformation
- StreamingJobTransformationData
Indicates the query and the number of streaming units to use for the streaming job. The name property of the transformation is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.
- outputs
- IEnumerable<StreamingJobOutputData>
A list of one or more outputs for the streaming job. The name property for each output is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual output.
- functions
- IEnumerable<StreamingJobFunctionData>
A list of one or more functions for the streaming job. The name property for each function is required when specifying this property in a PUT request. This property cannot be modify via a PATCH operation. You must use the PATCH API available for the individual transformation.
The current entity tag for the streaming job. 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.
- jobStorageAccount
- StreamingJobStorageAccount
The properties that are associated with an Azure Storage account with MSI.
- contentStoragePolicy
- Nullable<StreamingJobContentStoragePolicy>
Valid values are JobStorageAccount and SystemAccount. If set to JobStorageAccount, this requires the user to also specify jobStorageAccount property. .
- externals
- StreamingJobExternal
The storage account where the custom code artifacts are located.
- clusterId
- ResourceIdentifier
The cluster which streaming jobs will run on.
Returns
A new StreamingJobData instance for mocking.
Applies to
Azure SDK for .NET