Data Processing Jobs

Defines the connection profile for the job.

Rules:

• Characters: 1−30

• Case Sensitive: Yes

• Invalid Characters: Spaces

Defines the name of the AWS EMR cluster to connect to the Notebook.

In the EMR API, this field is called the Execution Engine ID.

Determines which Notebook ID executes the script.

In the EMR API, this field is called the Editor ID.

Defines the full path and name of the script file in the Notebook.

Defines the job execution name.

Defines the service role to connect to the Notebook.

Enables you to provide Notebook execution information through JSON code.

This JSON Body parameter replaces the values of the following parameters (Cluster ID, Notebook ID, Relative Path, Notebook Execution Name, and Service Role).

Defines the name of a connection profile to use to connect to Google Cloud Platform.

Defines the project ID for your Google Cloud project.

Defines the Google Compute Engine region to create the job.

Defines one of the following types of Google Dataflow templates:

• Classic Template: Developers run the pipeline and create a template. The Apache Beam SDK stages files in Cloud Storage, creates a template file (similar to job request), and saves the template file in Cloud Storage.

• Flex Template: Developers package the pipeline into a Docker image and then use the Google Cloud CLI to build and save the Flex Template spec file in Cloud Storage.

Defines the path for temporary files. This must be a valid Google Cloud Storage URL that begins with gs://.

The pipeline option tempLocation is used as the default value, if it has been set.

Defines input parameters to be passed on to job execution, in JSON format (name:value pairs).

This JSON must include the jobname and parameters elements, as in the following example:

{ 

    "jobName": "wordcount", 

    "parameters": { 

        "inputFile": "gs://dataflow-samples/shakespeare/kinglear.txt", 

        "output": "gs://controlmbucket/counts" 

    } 

} 

(Optional) Defines the number of seconds to wait before checking the status of the job.

Default: 10

Defines the name of a connection profile to use to connect to Google Cloud Platform.

Defines the project ID for your Google Cloud project.

Defines the Google Compute Engine region to create the job.

Defines one of the following Dataproc task types to execute:

• Workflow Template: Reusable workflow configuration that defines a graph of jobs with information on where to run those jobs.

• Job: A single Dataproc job.

(For a Workflow Template task type) Defines the ID of a Workflow Template.

(For a Job task type) Defines input parameters to be passed on to job execution, in JSON format.

You retrieve this JSON content from the GCP Dataproc UI, using the EQUIVALENT REST option in job settings.

(Optional) Defines the number of seconds to wait before checking the status of the job.

Default: 20

Defines the connection profile for the job.

Rules:

• Characters: 1−30

• Case Sensitive: Yes

• Invalid Characters: Spaces

Variable Name: %%HDP-ACCOUNT

Determines the execution type for Hadoop job execution, as follows:

• DistCp Job

• Distributed Shell Job

• HDFS Commands Job

• HDFS File Watcher Job

• Impala Job

• Hive Job

• Java-Map-Reduce Job

• Oozie Job

• Pig Job

• Spark Job

• Sqoop Job

• Streaming Job

• Tajo Job

Variable Name: %%HDP-EXEC_TYPE

Defines the Pre commands performed before job execution (not for HDFS Commands jobs and Oozie Extractor jobs), and the argument for each command.

Determines whether the entire job fails if any of the Pre commands fail (not for HDFS Commands jobs and Oozie Extractor jobs).

Defines the Post commands performed before job execution (not for HDFS Commands jobs and Oozie Extractor jobs), and the argument for each command.

Defines the absolute destination path.

Variable Name: %%HDP-DISTCP_TARGET_PATH

Defines the source paths.

Variable Name: %%HDP-DISTCP_SOURCE_PATH-Nxxx_ARG

Defines the sets of attributes and values that are added to the command line.

Variable Names:

• Name: %%HDP-DISTCP_OPTION-Nxxx-NAME

• Value: %%HDP- DISTCP_OPTION-Nxxx-VAL

Determines what the Distributed Shell job runs, as follows:

• Command: Runs a shell command entry as defined by Command.

• Script File: Runs a script file as defined by Command, Script Full Path, and Shell Script Arguments.

Variable Name: %%HDP-SHELL_TYPE

Defines the shell command entry to run for the job execution.

Variable Name: %%HDP-SHELL_COMMAND

Defines the full path to the script file which is executed. The script file is located in the HDFS.

Variable Name: %%HDP-SHELL_SCRIPT_FULL_PATH

Defines the shell script arguments.

Variable Name: %%HDP-SHELL-Nxxx-ARG

Opens more attributes.

Defines the full path to the file or archive to upload as a dependency to the HDFS working directory.

Variable Names:

• Type: %%HDP-SHELL_FILE_DEP-Nxxx-TYPE

• Path: %%HDP-SHELL_FILE_DEP -Nxxx-PATH

Defines the additional option (Name and Value) to set when executing the job.

Variable Names:

• Name: %%HDP-SHELL_OPTION -Nxxx-NAME

• Value: %%HDP-SHELL_OPTION -Nxxx-VAL

Defines the environment variables for the shell script/command.

Variable Name: %%HDP-SHELL_ENV_VARIABLE-Nxxx-ARG

Defines the command for the argument to be performed with job execution.

Variable Name: %%HDP-HDFS_CMD_ACTION-Nxxx-CMD

Defines the full path of the file being watched.

Variable Name: %%HDP-HDFS_FILE_PATH

Determines the minimum file size in bytes to meet the criteria and finish the job as OK. If the file arrives, but the size is not met, the job continues to watch the file.

Variable Name: %%HDP-MIN_DETECTED_SIZE

Determines the maximum number of minutes to wait for the file to meet the watching criteria. If criteria are not met (file did not arrive, or minimum size was not reached) the job fails after this maximum number of minutes.

Variable Name: %%HDP-MAX_WAIT_TIME

Determines the source type to run the queries, as follows:

• Query File: Runs a query file as defined by Query File Full Path.

• Open Query: Runs an open query command as defined by Query.

Variable Name: %%HDP-IMPALA_QUERY_SOURCE

Defines the location of the file used to run the queries.

Variable Name: %%HDP-IMPALA_QUERY_FILE_PATH

Defines the query command used to run the queries.

Variable Name: %%HDP-IMPALA_OPEN_QUERY

Defines the full path to the Hive script on the Hadoop host.

Variable Name: %%HDP-HIVE_SCRIPT_NAME

Defines the list of parameters for the script.

Variable Names:

• Name: %%HDP-HIVE_SCRIPT_PARAM_Nxxx-NAME

• Value: %%HDP-HIVE_SCRIPT_PARAM-Nxxx-VAL

Defines the full path to the jar containing the Map Reduce Java program on the Hadoop host.

Variable Name: %%HDP-JAVA_JAR_NAME

Defines the class that is included in the jar containing a main function and the map reduce implementation.

Variable Name: %%HDP-JAVA_MAIN_CLASS

Defines the argument used by the command.

Variable Name: %%HDP-JAVA_Nxxx_ARG

Defines the job properties file path.

Variable Name: %%HDP-OOZIE_JOB_PROPERTIES_FILE

Defines the Oozie job properties.

A set of properties is comprised of the following:

• Key: Defines a key name associated with each property.

  Variable Name: %%HDP-OOZIE_PROPERTY-Nxxx-KEY

• Value: Defines a value associated with each property.

  Variable Name: %%HDP-OOZIE_PROPERTY-Nxxx-VAL

You can add new properties or override property values defined in the Job Properties File.

Defines the full path to the Pig program on the Hadoop host.

Variable Name: %%HDP-PIG_PROG_NAME

Defines the list of program parameters.

Determines whether to add Yarn aggregated logs to the job output.

Defines a list of properties (Name and Value) to be executed with the job.

These properties override the Hadoop defaults.

Defines the location of the Hadoop archives.

Determines the Spark program type, as follows:

• Python Script: As defined by Full Path to Script.

• Java / Scala Application: As defined by Application Jar File and Full Path to Script.

Variable Name: %%HDP-SPARK_PROG_TYPE

Defines the full path to the python script to execute.

Variable Name: %%HDP-SPARK_FULL_PATH_TO_PYTHON_SCRIPT

Defines the path to the jar including your application and all the dependencies.

Variable Name: %%HDP-SPARK_APP_JAR_FULL_PATH

Defines the main class of the application.

Variable Name: %%HDP-SPARK_MAIN_CLASS_TO_RUN

Defines the attribute arguments that are added at the end of the Spark command line either after the main class for Java / Scala Applications or after the script of the Python Script.

Variable Name: %%HDP-SPARK_Nxxx_ARG

Defines the sets of attributes and values that are added to the command line.

Variable Names:

• Name: %%HDP-SPARK_OPTION -Nxxx-NAME

• Value: %%HDP-SPARK_OPTION -Nxxx-VAL

Defines any valid Sqoop command necessary for job execution. Sqoop can only be used for job execution if defined in Sqoop connection attributes.

HDP-SQOOP_COMMAND

Determines whether to add Yarn aggregated logs to the job output.

Defines a list of properties (Name and Value) to be executed with the job.

These properties override the Hadoop defaults.

Defines the location of the Hadoop archives.

Defines the input file for the Mapper step.

Variable Name: %%HDP-INPUT_PATH

Defines the HDFS output path for the Reducer step.

Variable Name: %%HDP-OUTPUT_PATH

Defines the command that runs as a mapper.

Variable Name: %%HDP-MAPPER_COMMAND

Defines the command that runs as a reducer.

Variable Name: %%HDP-REDUCER_COMMAND

Defines the sets of attributes (Name and Value) that are added to the end of the Streaming command line.

Variable Names:

• Name: %%HDP-STREAMING_PARAM-Nxxx-NAME

• Value: %%HDP-STREAMING_PARAM-Nxxx-VAL

Defines the sets of attributes (Name and Value) that are added to the Streaming command line.

Variable Names:

• Name: %%HDP-GENERIC_PARAM-Nxxx-NAME

• Value: %%HDP-GENERIC_PARAM-Nxxx-VAL

Determines the source of the Tajo command, as follows:

• Input File: Runs the Tajo command from an input file as defined by the Full File Path.

  Variable Name: %%HDP-TAJO_INPUT_FILE

• Open Query: Runs an open query as the Tajo command, as defined by Open Query.

  Variable Name: %%HDP-TAJO_OPEN_QUERY

Defines the file path of the input file that runs the Tajo command.