diff --git a/src/Dataproc/Batch.php b/src/Dataproc/Batch.php index e8a854e3ae..628f7950f8 100644 --- a/src/Dataproc/Batch.php +++ b/src/Dataproc/Batch.php @@ -87,6 +87,8 @@ class Batch extends \Google\Collection public $operation; protected $pysparkBatchType = PySparkBatch::class; protected $pysparkBatchDataType = ''; + protected $pysparkNotebookBatchType = PySparkNotebookBatch::class; + protected $pysparkNotebookBatchDataType = ''; protected $runtimeConfigType = RuntimeConfig::class; protected $runtimeConfigDataType = ''; protected $runtimeInfoType = RuntimeInfo::class; @@ -243,6 +245,22 @@ public function getPysparkBatch() { return $this->pysparkBatch; } + /** + * Optional. PySpark notebook batch config. + * + * @param PySparkNotebookBatch $pysparkNotebookBatch + */ + public function setPysparkNotebookBatch(PySparkNotebookBatch $pysparkNotebookBatch) + { + $this->pysparkNotebookBatch = $pysparkNotebookBatch; + } + /** + * @return PySparkNotebookBatch + */ + public function getPysparkNotebookBatch() + { + return $this->pysparkNotebookBatch; + } /** * Optional. Runtime configuration for the batch execution. * diff --git a/src/Dataproc/PySparkNotebookBatch.php b/src/Dataproc/PySparkNotebookBatch.php new file mode 100644 index 0000000000..983e17262a --- /dev/null +++ b/src/Dataproc/PySparkNotebookBatch.php @@ -0,0 +1,165 @@ +archiveUris = $archiveUris; + } + /** + * @return string[] + */ + public function getArchiveUris() + { + return $this->archiveUris; + } + /** + * Optional. HCFS URIs of files to be placed in the working directory of each + * executor + * + * @param string[] $fileUris + */ + public function setFileUris($fileUris) + { + $this->fileUris = $fileUris; + } + /** + * @return string[] + */ + public function getFileUris() + { + return $this->fileUris; + } + /** + * Optional. HCFS URIs of jar files to be added to the Spark CLASSPATH. + * + * @param string[] $jarFileUris + */ + public function setJarFileUris($jarFileUris) + { + $this->jarFileUris = $jarFileUris; + } + /** + * @return string[] + */ + public function getJarFileUris() + { + return $this->jarFileUris; + } + /** + * Required. The HCFS URI of the notebook file to execute. + * + * @param string $notebookFileUri + */ + public function setNotebookFileUri($notebookFileUri) + { + $this->notebookFileUri = $notebookFileUri; + } + /** + * @return string + */ + public function getNotebookFileUri() + { + return $this->notebookFileUri; + } + /** + * Optional. The parameters to pass to the notebook. + * + * @param string[] $params + */ + public function setParams($params) + { + $this->params = $params; + } + /** + * @return string[] + */ + public function getParams() + { + return $this->params; + } + /** + * Optional. HCFS URIs of Python files to pass to the PySpark framework. + * + * @param string[] $pythonFileUris + */ + public function setPythonFileUris($pythonFileUris) + { + $this->pythonFileUris = $pythonFileUris; + } + /** + * @return string[] + */ + public function getPythonFileUris() + { + return $this->pythonFileUris; + } +} + +// Adding a class alias for backwards compatibility with the previous class name. +class_alias(PySparkNotebookBatch::class, 'Google_Service_Dataproc_PySparkNotebookBatch');