Compartilhar via


StreamingJob Construtores

Definição

Sobrecargas

StreamingJob()

Inicializa uma nova instância da classe 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)

Inicializa uma nova instância da classe StreamingJob.

StreamingJob()

Inicializa uma nova instância da classe StreamingJob.

public StreamingJob ();
Public Sub New ()

Aplica-se a

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)

Inicializa uma nova instância da classe 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)

Parâmetros

id
String

ID de recurso totalmente qualificada para o recurso. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}

name
String

O nome do recurso

type
String

Tipo do recurso. Por exemplo, Microsoft.Compute/virtualMachines ou Microsoft.Storage/storageAccounts.

tags
IDictionary<String,String>

Marcas de recurso.

location
String

A localização geográfica em que o recurso reside

sku
Sku

Descreve a SKU do trabalho de streaming. Necessário em solicitações PUT (CreateOrReplace).

jobId
String

Um GUID que identifica exclusivamente o trabalho de streaming. Esse GUID é gerado após a criação do trabalho de streaming.

provisioningState
String

Descreve o status de provisionamento do trabalho de streaming.

jobState
String

Descreve o estado do trabalho de streaming.

jobType
String

Descreve o tipo do trabalho. Os modos válidos são Cloud e 'Edge'. Os valores possíveis incluem: 'Cloud', 'Edge'

outputStartMode
String

Essa propriedade só deve ser utilizada quando desejar que o trabalho seja iniciado imediatamente após a criação. O valor pode ser JobStartTime, CustomTime ou LastOutputEventTime para indicar se o ponto de partida do fluxo de eventos de saída deve ser iniciado sempre que o trabalho for iniciado, começar em um carimbo de data/hora do usuário personalizado especificado por meio da propriedade outputStartTime ou iniciar a partir da hora de saída do último evento. Os valores possíveis incluem: 'JobStartTime', 'CustomTime', 'LastOutputEventTime'

outputStartTime
Nullable<DateTime>

O valor é um carimbo de hora formatados com o ISO 8601 que indica o ponto de partida do fluxo de eventos de saída ou nulo para indicar que o fluxo de eventos de saída será iniciado sempre que o trabalho de streaming for iniciado. Essa propriedade deverá ter um valor se outputStartMode estiver definido como CustomTime.

lastOutputEventTime
Nullable<DateTime>

O valor é um carimbo de data/hora formatado iso-8601 que indica a hora do último evento de saída do trabalho de streaming ou nulo indicando que a saída ainda não foi produzida. No caso de várias saídas ou vários fluxos, isso mostra o valor mais recente nesse conjunto.

eventsOutOfOrderPolicy
String

Indica a política a ser aplicada aos eventos que chegam fora de ordem no fluxo de eventos de entrada. Os valores possíveis incluem: 'Adjust', 'Drop'

outputErrorPolicy
String

Indica a política a ser aplicada aos eventos que chegam à saída e não podem ser gravados no armazenamento externo por estarem malformados (faltando valores de coluna, valores de coluna de tipo ou tamanho incorreto). Os valores possíveis incluem: 'Stop', 'Drop'

eventsOutOfOrderMaxDelayInSeconds
Nullable<Int32>

O atraso máximo tolerável em segundos em que os eventos fora de ordem podem ser ajustados para voltar à ordem.

eventsLateArrivalMaxDelayInSeconds
Nullable<Int32>

O atraso máximo tolerável em segundos em que os eventos que chegam atrasados podem ser incluídos. O intervalo com suporte é de -1 a 1814399 (20.23:59:59 dias) e -1 é usado para especificar a espera indefinidamente. Se a propriedade estiver ausente, ela será interpretada como tendo um valor de -1.

dataLocale
String

A localidade de dados do trabalho do Stream Analytics. O valor deve ser o nome de uma cultura .NET com suporte do conjunto https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Se nenhuma for especificada, o padrão será 'en-US'.

compatibilityLevel
String

Controla determinados comportamentos de runtime do trabalho de streaming. Os valores possíveis incluem: '1.0', '1.2'

createdDate
Nullable<DateTime>

O valor é um carimbo de data/hora UTC formatado em ISO-8601 que indica quando o trabalho de streaming foi criado.

inputs
IList<Input>

Uma lista de uma ou mais entradas para o trabalho de streaming. A propriedade name para cada entrada é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a entrada individual.

transformation
Transformation

Indica a consulta e o número de unidades de streaming a serem usadas para o trabalho de streaming. A propriedade name da transformação é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a transformação individual.

outputs
IList<Output>

Uma lista de uma ou mais saídas para o trabalho de streaming. A propriedade name para cada saída é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a saída individual.

functions
IList<Function>

Uma lista de uma ou mais funções para o trabalho de streaming. A propriedade name para cada função é necessária ao especificar essa propriedade em uma solicitação PUT. Essa propriedade não pode ser modificada por meio de uma operação PATCH. Você deve usar a API PATCH disponível para a transformação individual.

etag
String

A marca de entidade atual para o trabalho de streaming. Essa é uma cadeia de caracteres opaca. Você pode usá-lo para detectar se o recurso foi alterado entre solicitações. Você também pode usá-lo nos cabeçalhos If-Match ou If-None-Match para operações de gravação para simultaneidade otimista.

jobStorageAccount
JobStorageAccount

As propriedades associadas a uma conta de Armazenamento do Azure com MSI

contentStoragePolicy
String

Os valores válidos são JobStorageAccount e SystemAccount. Se definido como JobStorageAccount, isso exigirá que o usuário também especifique a propriedade jobStorageAccount. Os valores possíveis incluem: 'SystemAccount', 'JobStorageAccount'

cluster
ClusterInfo

O cluster no qual os trabalhos de streaming serão executados.

identity
Identity

Descreve a identidade gerenciada atribuída pelo sistema atribuída a esse trabalho que pode ser usada para autenticar com entradas e saídas.

Aplica-se a