你当前正在访问 Microsoft Azure Global Edition 技术文档网站。如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

StreamingJob 构造函数

参考

定义

命名空间:: Microsoft.Azure.Management.StreamAnalytics.Models

程序集:: Microsoft.Azure.Management.StreamAnalytics.dll

包:: Microsoft.Azure.Management.StreamAnalytics v4.0.0

重要

一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。

重载

StreamingJob()	初始化 StreamingJob 类的新实例。
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)	初始化 StreamingJob 类的新实例。

StreamingJob()

初始化 StreamingJob 类的新实例。

public StreamingJob ();

Public Sub New ()

适用于

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)

初始化 StreamingJob 类的新实例。

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)

参数

id: String

资源的完全限定资源 ID。例如 - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}

name: String

资源的名称

type: String

资源类型。 Ex-Microsoft.Compute/virtualMachines 或 Microsoft.Storage/storageAccounts。

tags: IDictionary<String,String>

资源标记。

location: String

资源所在的地理位置

sku: Sku

描述流式处理作业的 SKU。在 PUT (CreateOrReplace) 请求上是必需的。

jobId: String

唯一标识流式处理作业的 GUID。此 GUID 是在创建流式处理作业时生成的。

provisioningState: String

描述流式处理作业的预配状态。

jobState: String

描述流式处理作业的状态。

jobType: String

描述作业的类型。有效模式为 Cloud 和 “Edge”。可能的值包括：“Cloud”、“Edge”

outputStartMode: String

仅当需要作业在创建时立即启动时才应使用此属性。值可以是 JobStartTime、CustomTime 或 LastOutputEventTime，以指示输出事件流的起点应在作业每次启动时启动、从通过 outputStartTime 属性指定的自定义用户时间戳开始，还是从上次事件输出时间开始。可能的值包括：“JobStartTime”、“CustomTime”、“LastOutputEventTime”

outputStartTime: Nullable<DateTime>

值为采用 ISO-8601 格式的时间戳（指示输出事件流的起点），或者为 null（指示输出事件流将在每次启动流式处理作业时开始）。如果 outputStartMode 设置为 CustomTime，则此属性必须具有值。

lastOutputEventTime: Nullable<DateTime>

值为 ISO-8601 格式的时间戳，指示流式处理作业的最后一个输出事件时间，或 null，表示尚未生成输出。如果有多个输出或多个流，则显示该集中的最新值。

eventsOutOfOrderPolicy: String

指示要应用于输入事件流中未按顺序到达的事件的策略。可能的值包括：“Adjust”、“Drop”

outputErrorPolicy: String

指示要应用于到达输出但由于格式错误（缺少列值、列值类型或大小错误）而无法写入外部存储的事件的策略。可能的值包括：“Stop”、“Drop”

eventsOutOfOrderMaxDelayInSeconds: Nullable<Int32>

可容许的最大延迟（以秒为单位），其中无序事件可重新调整为有序事件。

eventsLateArrivalMaxDelayInSeconds: Nullable<Int32>

可容忍的最大延迟（以秒为单位），其中可能包括迟到事件。支持的范围为 -1 到 1814399（20.23:59:59 天），-1 用于指定无限期等待。如果该属性不存在，则将其解释为具有值 -1。

dataLocale: String

流分析作业的数据区域设置。值应为集 https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx中支持的 .NET 区域性的名称。如果未指定，则默认为“en-US”。

compatibilityLevel: String

控制流式处理作业的某些运行时行为。可能的值包括：“1.0”、“1.2”

createdDate: Nullable<DateTime>

值是 ISO-8601 格式的 UTC 时间戳，指示创建流式处理作业的时间。

inputs: IList<Input>

流式处理作业的一个或多个输入的列表。在 PUT 请求中指定此属性时，需要每个输入的名称属性。无法通过 PATCH 操作修改此属性。必须使用可用于单个输入的 PATCH API。

transformation: Transformation

指示用于流式处理作业的查询和流单元数。在 PUT 请求中指定此属性时，需要转换的 name 属性。无法通过 PATCH 操作修改此属性。必须使用可用于单个转换的 PATCH API。

outputs: IList<Output>

流式处理作业的一个或多个输出的列表。在 PUT 请求中指定此属性时，需要每个输出的 name 属性。无法通过 PATCH 操作修改此属性。必须使用可用于单个输出的 PATCH API。

functions: IList<Function>

流式处理作业的一个或多个函数的列表。在 PUT 请求中指定此属性时，需要每个函数的 name 属性。无法通过 PATCH 操作修改此属性。必须使用可用于单个转换的 PATCH API。

etag: String

流式处理作业的当前实体标记。这是一个不透明的字符串。可以使用它来检测资源是否在请求之间发生了更改。还可以在 If-Match 或 If-None-Match 标头中使用它进行写入操作，实现乐观并发。

jobStorageAccount: JobStorageAccount

与具有 MSI 的 Azure 存储帐户关联的属性

contentStoragePolicy: String

有效值为 JobStorageAccount 和 SystemAccount。如果设置为 JobStorageAccount，则要求用户同时指定 jobStorageAccount 属性。可能的值包括：“SystemAccount”、“JobStorageAccount”

cluster: ClusterInfo

将运行流式处理作业的群集。

identity: Identity

介绍分配给此作业的系统分配托管标识，该标识可用于通过输入和输出进行身份验证。

适用于

通过

StreamingJob 构造函数

定义

重载

StreamingJob()

适用于

参数

适用于

其他资源