다음을 통해 공유

StreamingJob Constructors

  • Reference

Definition

Namespace:
Microsoft.Azure.Management.StreamAnalytics.Models
Assembly:
Microsoft.Azure.Management.StreamAnalytics.dll
Package:
Microsoft.Azure.Management.StreamAnalytics v4.0.0

Overloads

StreamingJob()

Initializes a new instance of the StreamingJob class.
StreamingJob(String, String, String, IDictionary<String,String>, String, Sku, String, String, String, String, String, Nullable<DateTime>, Nullable<DateTime>, String, String, Nullable<Int32>, Nullable<Int32>, String, String, Nullable<DateTime>, IList<Input>, Transformation, IList<Output>, IList<Function>, String, JobStorageAccount, String, ClusterInfo, Identity)

Initializes a new instance of the StreamingJob class.

StreamingJob()

Initializes a new instance of the StreamingJob class.

public StreamingJob ();
Public Sub New ()

Applies to

StreamingJob(String, String, String, IDictionary<String,String>, String, Sku, String, String, String, String, String, Nullable<DateTime>, Nullable<DateTime>, String, String, Nullable<Int32>, Nullable<Int32>, String, String, Nullable<DateTime>, IList<Input>, Transformation, IList<Output>, IList<Function>, String, JobStorageAccount, String, ClusterInfo, Identity)

Initializes a new instance of the StreamingJob class.

public StreamingJob (string id = default, string name = default, string type = default, System.Collections.Generic.IDictionary<string,string> tags = default, string location = default, Microsoft.Azure.Management.StreamAnalytics.Models.Sku sku = default, string jobId = default, string provisioningState = default, string jobState = default, string jobType = default, string outputStartMode = default, DateTime? outputStartTime = default, DateTime? lastOutputEventTime = default, string eventsOutOfOrderPolicy = default, string outputErrorPolicy = default, int? eventsOutOfOrderMaxDelayInSeconds = default, int? eventsLateArrivalMaxDelayInSeconds = default, string dataLocale = default, string compatibilityLevel = default, DateTime? createdDate = default, System.Collections.Generic.IList<Microsoft.Azure.Management.StreamAnalytics.Models.Input> inputs = default, Microsoft.Azure.Management.StreamAnalytics.Models.Transformation transformation = default, System.Collections.Generic.IList<Microsoft.Azure.Management.StreamAnalytics.Models.Output> outputs = default, System.Collections.Generic.IList<Microsoft.Azure.Management.StreamAnalytics.Models.Function> functions = default, string etag = default, Microsoft.Azure.Management.StreamAnalytics.Models.JobStorageAccount jobStorageAccount = default, string contentStoragePolicy = default, Microsoft.Azure.Management.StreamAnalytics.Models.ClusterInfo cluster = default, Microsoft.Azure.Management.StreamAnalytics.Models.Identity identity = default);
new Microsoft.Azure.Management.StreamAnalytics.Models.StreamingJob : string * string * string * System.Collections.Generic.IDictionary<string, string> * string * Microsoft.Azure.Management.StreamAnalytics.Models.Sku * string * string * string * string * string * Nullable<DateTime> * Nullable<DateTime> * string * string * Nullable<int> * Nullable<int> * string * string * Nullable<DateTime> * System.Collections.Generic.IList<Microsoft.Azure.Management.StreamAnalytics.Models.Input> * Microsoft.Azure.Management.StreamAnalytics.Models.Transformation * System.Collections.Generic.IList<Microsoft.Azure.Management.StreamAnalytics.Models.Output> * System.Collections.Generic.IList<Microsoft.Azure.Management.StreamAnalytics.Models.Function> * string * Microsoft.Azure.Management.StreamAnalytics.Models.JobStorageAccount * string * Microsoft.Azure.Management.StreamAnalytics.Models.ClusterInfo * Microsoft.Azure.Management.StreamAnalytics.Models.Identity -> Microsoft.Azure.Management.StreamAnalytics.Models.StreamingJob
Public Sub New (Optional id As String = Nothing, Optional name As String = Nothing, Optional type As String = Nothing, Optional tags As IDictionary(Of String, String) = Nothing, Optional location As String = Nothing, Optional sku As Sku = Nothing, Optional jobId As String = Nothing, Optional provisioningState As String = Nothing, Optional jobState As String = Nothing, Optional jobType As String = Nothing, Optional outputStartMode As String = Nothing, Optional outputStartTime As Nullable(Of DateTime) = Nothing, Optional lastOutputEventTime As Nullable(Of DateTime) = Nothing, Optional eventsOutOfOrderPolicy As String = Nothing, Optional outputErrorPolicy As String = Nothing, Optional eventsOutOfOrderMaxDelayInSeconds As Nullable(Of Integer) = Nothing, Optional eventsLateArrivalMaxDelayInSeconds As Nullable(Of Integer) = Nothing, Optional dataLocale As String = Nothing, Optional compatibilityLevel As String = Nothing, Optional createdDate As Nullable(Of DateTime) = Nothing, Optional inputs As IList(Of Input) = Nothing, Optional transformation As Transformation = Nothing, Optional outputs As IList(Of Output) = Nothing, Optional functions As IList(Of Function) = Nothing, Optional etag As String = Nothing, Optional jobStorageAccount As JobStorageAccount = Nothing, Optional contentStoragePolicy As String = Nothing, Optional cluster As ClusterInfo = Nothing, Optional identity As Identity = Nothing)

Parameters

id
String

Fully qualified resource Id for the resource. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}

name
String

The name of the resource

type
String

The type of the resource. Ex- Microsoft.Compute/virtualMachines or Microsoft.Storage/storageAccounts.

tags
IDictionary<String,String>

Resource tags.

location
String

The geo-location where the resource lives

sku
Sku

Describes the SKU of the streaming job. Required on PUT (CreateOrReplace) requests.

jobId
String

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
String

Describes the type of the job. Valid modes are Cloud and 'Edge'. Possible values include: 'Cloud', 'Edge'

outputStartMode
String

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. Possible values include: 'JobStartTime', 'CustomTime', 'LastOutputEventTime'

outputStartTime
Nullable<DateTime>

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.

lastOutputEventTime
Nullable<DateTime>

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
String

Indicates the policy to apply to events that arrive out of order in the input event stream. Possible values include: 'Adjust', 'Drop'

outputErrorPolicy
String

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). Possible values include: 'Stop', 'Drop'

eventsOutOfOrderMaxDelayInSeconds
Nullable<Int32>

The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.

eventsLateArrivalMaxDelayInSeconds
Nullable<Int32>

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.

dataLocale
String

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
String

Controls certain runtime behaviors of the streaming job. Possible values include: '1.0', '1.2'

createdDate
Nullable<DateTime>

Value is an ISO-8601 formatted UTC timestamp indicating when the streaming job was created.

inputs
IList<Input>

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
Transformation

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
IList<Output>

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
IList<Function>

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.

etag
String

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
JobStorageAccount

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

contentStoragePolicy
String

Valid values are JobStorageAccount and SystemAccount. If set to JobStorageAccount, this requires the user to also specify jobStorageAccount property. Possible values include: 'SystemAccount', 'JobStorageAccount'

cluster
ClusterInfo

The cluster which streaming jobs will run on.

identity
Identity

Describes the system-assigned managed identity assigned to this job that can be used to authenticate with inputs and outputs.

Applies to