Compartir a través de


StreamingJob Constructores

Definición

Sobrecargas

StreamingJob()

Inicializa una nueva instancia de la clase 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 una nueva instancia de la clase StreamingJob.

StreamingJob()

Inicializa una nueva instancia de la clase StreamingJob.

public StreamingJob ();
Public Sub New ()

Se aplica 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 una nueva instancia de la clase 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

Identificador de recurso completo para el recurso. Por ejemplo: /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}

name
String

Nombre del recurso.

type
String

Tipo de recurso. Por ejemplo, Microsoft.Compute/virtualMachines o Microsoft.Storage/storageAccounts.

tags
IDictionary<String,String>

Etiquetas del recurso.

location
String

Ubicación geográfica donde reside el recurso

sku
Sku

Describe la SKU del trabajo de streaming. Se requiere en las solicitudes PUT (CreateOrReplace).

jobId
String

Guid que identifica de forma única el trabajo de streaming. Este GUID se genera al crear el trabajo de streaming.

provisioningState
String

Describe el estado de aprovisionamiento del trabajo de streaming.

jobState
String

Describe el estado del trabajo de streaming.

jobType
String

Describe el tipo del trabajo. Los modos válidos son Cloud y "Edge". Entre los valores posibles se incluyen: "Cloud", "Edge"

outputStartMode
String

Esta propiedad solo debe utilizarse cuando se desee que el trabajo se inicie inmediatamente después de la creación. El valor puede ser JobStartTime, CustomTime o LastOutputEventTime para indicar si el punto inicial del flujo de eventos de salida debe iniciarse cada vez que se inicia el trabajo, empezar en una marca de tiempo de usuario personalizada especificada a través de la propiedad outputStartTime o comenzar desde la última hora de salida del evento. Entre los valores posibles se incluyen: "JobStartTime", "CustomTime", "LastOutputEventTime".

outputStartTime
Nullable<DateTime>

El valor es una marca de tiempo con formato ISO-8601 que indica el punto inicial de la secuencia de eventos de salida o NULL para indicar que la secuencia de eventos de salida empezará cuando se inicie el trabajo de transmisión. Esta propiedad debe tener un valor si outputStartMode está establecido en CustomTime.

lastOutputEventTime
Nullable<DateTime>

El valor es una marca de tiempo con formato ISO-8601 que indica la última hora del evento de salida del trabajo de streaming o null que indica que la salida aún no se ha generado. En el caso de varias salidas o varias secuencias, esto muestra el valor más reciente de ese conjunto.

eventsOutOfOrderPolicy
String

Indica la directiva que aplicar a los eventos que llegan desordenados en el flujo de eventos de entrada. Entre los valores posibles se incluyen: "Adjust", "Drop"

outputErrorPolicy
String

Indica la directiva que se aplica a los eventos que llegan a la salida y no se pueden escribir en el almacenamiento externo porque están mal formados (faltan valores de las columnas o el tamaño o tipo de los valores de las columnas no son correctos). Entre los valores posibles se incluyen: 'Stop', 'Drop'

eventsOutOfOrderMaxDelayInSeconds
Nullable<Int32>

El retraso máximo tolerable, en segundos, en que se pueden ajustar los eventos que no funcionan para que vuelvan a estar en orden.

eventsLateArrivalMaxDelayInSeconds
Nullable<Int32>

El retraso tolerable máximo, en segundos, que pueden tener los eventos que llegan tarde para ser incluidos. El rango admitido es -1 a 1814399 (20.23:59:59 días) y-1 se usa para especificar que la espera es indefinida. Si la propiedad no está presente, se interpreta que tiene el valor -1.

dataLocale
String

La configuración regional de los datos del trabajo de análisis del flujo de datos. El valor debe ser el nombre de una referencia cultural de .NET admitida del conjunto https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. El valor predeterminado es "en-US" si no se ha especificado ninguno.

compatibilityLevel
String

Controla ciertos comportamientos del runtime del trabajo de streaming. Entre los valores posibles se incluyen: "1.0", "1.2".

createdDate
Nullable<DateTime>

El valor es una marca de tiempo UTC con formato ISO-8601 que indica cuándo se creó el trabajo de streaming.

inputs
IList<Input>

Lista de una o varias entradas para el trabajo de streaming. La propiedad name para cada entrada es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar la API PATCH disponible para la entrada individual.

transformation
Transformation

Indica la consulta y el número de unidades de streaming que se van a usar para el trabajo de streaming. La propiedad name de la transformación es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar la API PATCH disponible para la transformación individual.

outputs
IList<Output>

Lista de una o varias salidas para el trabajo de streaming. La propiedad name de cada salida es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar la API PATCH disponible para la salida individual.

functions
IList<Function>

Lista de una o varias funciones para el trabajo de streaming. La propiedad name de cada función es necesaria al especificar esta propiedad en una solicitud PUT. Esta propiedad no se puede modificar a través de una operación PATCH. Debe usar la API PATCH disponible para la transformación individual.

etag
String

Etiqueta de entidad actual para el trabajo de streaming. Se trata de una cadena opaca. Puede usarlo para detectar si el recurso ha cambiado entre solicitudes. También puede usarlo en los encabezados If-Match o If-None-Match para operaciones de escritura para simultaneidad optimista.

jobStorageAccount
JobStorageAccount

Propiedades asociadas a una cuenta de Azure Storage con MSI

contentStoragePolicy
String

Los valores válidos son JobStorageAccount y SystemAccount. Si se establece en JobStorageAccount, esto requiere que el usuario especifique también la propiedad jobStorageAccount. Entre los valores posibles se incluyen: "SystemAccount", "JobStorageAccount"

cluster
ClusterInfo

Clúster en el que se ejecutarán los trabajos de streaming.

identity
Identity

Describe la identidad administrada asignada por el sistema asignada a este trabajo que se puede usar para autenticarse con entradas y salidas.

Se aplica a