Compartir a través de


SynapseSparkJobDefinitionActivity Clase

Definición

Ejecute la actividad de trabajo de Spark.

public class SynapseSparkJobDefinitionActivity : Azure.ResourceManager.DataFactory.Models.ExecutionActivity
type SynapseSparkJobDefinitionActivity = class
    inherit ExecutionActivity
Public Class SynapseSparkJobDefinitionActivity
Inherits ExecutionActivity
Herencia
SynapseSparkJobDefinitionActivity

Constructores

SynapseSparkJobDefinitionActivity(String, SynapseSparkJobReference)

Inicializa una nueva instancia de SynapseSparkJobDefinitionActivity.

Propiedades

AdditionalProperties

Propiedades adicionales

Para asignar un objeto al valor de esta propiedad, use FromObjectAsJson<T>(T, JsonSerializerOptions).

Para asignar una cadena json ya con formato a esta propiedad, use FromString(String).

Ejemplos:

  • BinaryData.FromObjectAsJson("foo")Crea una carga de "foo".
  • BinaryData.FromString("\"foo\"")Crea una carga de "foo".
  • BinaryData.FromObjectAsJson(new { key = "value" })Crea una carga de { "key": "value" }.
  • BinaryData.FromString("{\"key\": \"value\"}")Crea una carga de { "key": "value" }.

(Heredado de PipelineActivity)
Arguments

Los argumentos especificados por el usuario en SynapseSparkJobDefinitionActivity.

Para asignar un objeto al elemento de esta propiedad, use FromObjectAsJson<T>(T, JsonSerializerOptions).

Para asignar una cadena json ya con formato a esta propiedad, use FromString(String).

Ejemplos:

  • BinaryData.FromObjectAsJson("foo")Crea una carga de "foo".
  • BinaryData.FromString("\"foo\"")Crea una carga de "foo".
  • BinaryData.FromObjectAsJson(new { key = "value" })Crea una carga de { "key": "value" }.
  • BinaryData.FromString("{\"key\": \"value\"}")Crea una carga de { "key": "value" }.

ClassName

Identificador completo o la clase principal que se encuentra en el archivo de definición principal, que invalidará el "className" de la definición de trabajo de Spark que proporcione. Tipo: cadena (o Expresión con cadena resultType).

Conf

Propiedades de configuración de Spark, que invalidarán la "conf" de la definición de trabajo de Spark que proporcione.

Para asignar un objeto a esta propiedad, use FromObjectAsJson<T>(T, JsonSerializerOptions).

Para asignar una cadena json ya con formato a esta propiedad, use FromString(String).

Ejemplos:

  • BinaryData.FromObjectAsJson("foo")Crea una carga de "foo".
  • BinaryData.FromString("\"foo\"")Crea una carga de "foo".
  • BinaryData.FromObjectAsJson(new { key = "value" })Crea una carga de { "key": "value" }.
  • BinaryData.FromString("{\"key\": \"value\"}")Crea una carga de { "key": "value" }.

ConfigurationType

Tipo de la configuración de Spark.

DependsOn

La actividad depende de la condición.

(Heredado de PipelineActivity)
Description

Descripción de la actividad.

(Heredado de PipelineActivity)
DriverSize

Número de núcleos y memoria que se usarán para el controlador asignado en el grupo de Spark especificado para el trabajo, que se usará para invalidar "driverCores" y "driverMemory" de la definición de trabajo de Spark que proporcione. Tipo: cadena (o Expresión con cadena resultType).

ExecutorSize

Número de núcleos y memoria que se van a usar para los ejecutores asignados en el grupo de Spark especificado para el trabajo, que se usará para invalidar "executorCores" y "executorMemory" de la definición de trabajo de Spark que proporcione. Tipo: cadena (o Expresión con cadena resultType).

File

El archivo principal que se usa para el trabajo, que invalidará el "archivo" de la definición de trabajo de Spark que proporcione. Tipo: cadena (o Expresión con cadena resultType).

Files

(En desuso. Use pythonCodeReference y filesV2) Archivos adicionales que se usan como referencia en el archivo de definición principal, que invalidará los "archivos" de la definición de trabajo de Spark que proporcione.

Para asignar un objeto al elemento de esta propiedad, use FromObjectAsJson<T>(T, JsonSerializerOptions).

Para asignar una cadena json ya con formato a esta propiedad, use FromString(String).

Ejemplos:

  • BinaryData.FromObjectAsJson("foo")Crea una carga de "foo".
  • BinaryData.FromString("\"foo\"")Crea una carga de "foo".
  • BinaryData.FromObjectAsJson(new { key = "value" })Crea una carga de { "key": "value" }.
  • BinaryData.FromString("{\"key\": \"value\"}")Crea una carga de { "key": "value" }.

FilesV2

Archivos adicionales que se usan como referencia en el archivo de definición principal, que invalidará los archivos "jar" y "files" de la definición de trabajo de Spark que proporcione.

Para asignar un objeto al elemento de esta propiedad, use FromObjectAsJson<T>(T, JsonSerializerOptions).

Para asignar una cadena json ya con formato a esta propiedad, use FromString(String).

Ejemplos:

  • BinaryData.FromObjectAsJson("foo")Crea una carga de "foo".
  • BinaryData.FromString("\"foo\"")Crea una carga de "foo".
  • BinaryData.FromObjectAsJson(new { key = "value" })Crea una carga de { "key": "value" }.
  • BinaryData.FromString("{\"key\": \"value\"}")Crea una carga de { "key": "value" }.

LinkedServiceName

Referencia de servicio vinculado.

(Heredado de ExecutionActivity)
Name

Nombre de la actividad.

(Heredado de PipelineActivity)
NumExecutors

Número de ejecutores que se van a iniciar para este trabajo, lo que invalidará los "numExecutors" de la definición de trabajo de Spark que proporcione. Tipo: entero (o Expresión con resultType entero).

OnInactiveMarkAs

Resultado del estado de la actividad cuando el estado se establece en Inactivo. Se trata de una propiedad opcional y, si no se proporciona cuando la actividad está inactiva, el estado será Correcto de forma predeterminada.

(Heredado de PipelineActivity)
Policy

Directiva de actividad.

(Heredado de ExecutionActivity)
PythonCodeReference

Archivos de código de Python adicionales que se usan como referencia en el archivo de definición principal, que invalidará los "pyFiles" de la definición de trabajo de Spark que proporcione.

Para asignar un objeto al elemento de esta propiedad, use FromObjectAsJson<T>(T, JsonSerializerOptions).

Para asignar una cadena json ya con formato a esta propiedad, use FromString(String).

Ejemplos:

  • BinaryData.FromObjectAsJson("foo")Crea una carga de "foo".
  • BinaryData.FromString("\"foo\"")Crea una carga de "foo".
  • BinaryData.FromObjectAsJson(new { key = "value" })Crea una carga de { "key": "value" }.
  • BinaryData.FromString("{\"key\": \"value\"}")Crea una carga de { "key": "value" }.

ScanFolder

Examinar subcarpetas desde la carpeta raíz del archivo de definición principal, estos archivos se agregarán como archivos de referencia. Las carpetas denominadas "jars", "pyFiles", "files" o "archives" se analizarán y el nombre de las carpetas distingue mayúsculas de minúsculas. Tipo: booleano (o Expresión con resultType boolean).

SparkConfig

Propiedad de configuración de Spark.

Para asignar un objeto al valor de esta propiedad, use FromObjectAsJson<T>(T, JsonSerializerOptions).

Para asignar una cadena json ya con formato a esta propiedad, use FromString(String).

Ejemplos:

  • BinaryData.FromObjectAsJson("foo")Crea una carga de "foo".
  • BinaryData.FromString("\"foo\"")Crea una carga de "foo".
  • BinaryData.FromObjectAsJson(new { key = "value" })Crea una carga de { "key": "value" }.
  • BinaryData.FromString("{\"key\": \"value\"}")Crea una carga de { "key": "value" }.

SparkJob

Referencia del trabajo de Spark de Synapse.

State

Estado de la actividad. Se trata de una propiedad opcional y, si no se proporciona, el estado será Activo de forma predeterminada.

(Heredado de PipelineActivity)
TargetBigDataPool

Nombre del grupo de macrodatos que se usará para ejecutar el trabajo por lotes de Spark, que invalidará el "targetBigDataPool" de la definición de trabajo de Spark que proporcione.

TargetSparkConfiguration

Configuración de Spark del trabajo de Spark.

UserProperties

Propiedades de usuario de actividad.

(Heredado de PipelineActivity)

Se aplica a