BatchPysparkBatch

data class BatchPysparkBatch(val archiveUris: List<String>? = null, val args: List<String>? = null, val fileUris: List<String>? = null, val jarFileUris: List<String>? = null, val mainPythonFileUri: String? = null, val pythonFileUris: List<String>? = null)

Constructors

Link copied to clipboard
constructor(archiveUris: List<String>? = null, args: List<String>? = null, fileUris: List<String>? = null, jarFileUris: List<String>? = null, mainPythonFileUri: String? = null, pythonFileUris: List<String>? = null)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
val archiveUris: List<String>? = null

HCFS URIs of archives to be extracted into the working directory of each executor. Supported file types: .jar, .tar, .tar.gz, .tgz, and .zip.

Link copied to clipboard
val args: List<String>? = null

The arguments to pass to the driver. Do not include arguments that can be set as batch properties, such as --conf, since a collision can occur that causes an incorrect batch submission.

Link copied to clipboard
val fileUris: List<String>? = null

HCFS URIs of files to be placed in the working directory of each executor.

Link copied to clipboard
val jarFileUris: List<String>? = null

HCFS URIs of jar files to add to the classpath of the Spark driver and tasks.

Link copied to clipboard

The HCFS URI of the main Python file to use as the Spark driver. Must be a .py file.

Link copied to clipboard
val pythonFileUris: List<String>? = null

HCFS file URIs of Python files to pass to the PySpark framework. Supported file types: .py, .egg, and .zip.