com.edmunds.rest.databricks.service

Class WorkspaceServiceImpl

java.lang.Object

com.edmunds.rest.databricks.service.DatabricksService

com.edmunds.rest.databricks.service.WorkspaceServiceImpl

All Implemented Interfaces:

WorkspaceService

public class WorkspaceServiceImpl
extends DatabricksService
implements WorkspaceService

Implementation of the Workspace Service.

Field Summary

Fields inherited from class com.edmunds.rest.databricks.service.DatabricksService

client, mapper

Constructor Summary

Constructors

Constructor and Description
WorkspaceServiceImpl(DatabricksRestClient client)

Method Summary

Modifier and Type	Method and Description
void	delete(String path, boolean recursive) Deletes a specific workspace path.
byte[]	exportWorkspace(ExportWorkspaceRequest exportWorkspaceRequest) Exports a workspace path FROM databricks to local machine.
ObjectInfoDTO	getStatus(String path) Gets the status of a specific workspace path.
void	importWorkspace(ImportWorkspaceRequest importWorkspaceRequest) Imports files INTO databricks from local machine.
ObjectInfoDTO[]	listStatus(String path) Lists all objects in a specific db workspace path.
void	mkdirs(String path) Makes a path (and any parent paths if they do not exist) on db workspace.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkspaceServiceImpl

public WorkspaceServiceImpl(DatabricksRestClient client)

Method Detail

delete

public void delete(String path,
                   boolean recursive)
            throws IOException,
                   DatabricksRestException

Description copied from interface: WorkspaceService

Deletes a specific workspace path.

Specified by:

delete in interface WorkspaceService

Parameters:

path - the workspace path to delete

recursive - whether or not its recursive

Throws:

IOException - any other errors

DatabricksRestException - databricks specific errors

See Also:

https://docs.databricks.com/api/latest/workspace.html#delete

exportWorkspace

public byte[] exportWorkspace(ExportWorkspaceRequest exportWorkspaceRequest)
                       throws IOException,
                              DatabricksRestException

Description copied from interface: WorkspaceService

Exports a workspace path FROM databricks to local machine.

Specified by:

exportWorkspace in interface WorkspaceService

Parameters:

exportWorkspaceRequest - the request object

Returns:

the bytes of the export

Throws:

IOException - any other errors

DatabricksRestException - any specific db errors

See Also:

https://docs.databricks.com/api/latest/workspace.html#export

getStatus

public ObjectInfoDTO getStatus(String path)
                        throws IOException,
                               DatabricksRestException

Description copied from interface: WorkspaceService

Gets the status of a specific workspace path.

Specified by:

getStatus in interface WorkspaceService

Parameters:

path - the workspace path

Returns:

the workspace info object

Throws:

IOException - any other errors

DatabricksRestException - any specific db errors

See Also:

https://docs.databricks.com/api/latest/workspace.html#get-status

importWorkspace

public void importWorkspace(ImportWorkspaceRequest importWorkspaceRequest)
                     throws IOException,
                            DatabricksRestException

Description copied from interface: WorkspaceService

Imports files INTO databricks from local machine.

Specified by:

importWorkspace in interface WorkspaceService

Parameters:

importWorkspaceRequest - the import workspace request

Throws:

IOException - any other errors

DatabricksRestException - specific db exceptions

See Also:

https://docs.databricks.com/api/latest/workspace.html#import

listStatus

public ObjectInfoDTO[] listStatus(String path)
                           throws IOException,
                                  DatabricksRestException

Description copied from interface: WorkspaceService

Lists all objects in a specific db workspace path.

Specified by:

listStatus in interface WorkspaceService

Parameters:

path - the db workspace path

Returns:

the array of objects

Throws:

IOException - any other errors

DatabricksRestException - specific db exceptions

See Also:

https://docs.databricks.com/api/latest/workspace.html#list

mkdirs

public void mkdirs(String path)
            throws IOException,
                   DatabricksRestException

Description copied from interface: WorkspaceService

Makes a path (and any parent paths if they do not exist) on db workspace.

Specified by:

mkdirs in interface WorkspaceService

Parameters:

path - the db workspace path to create

Throws:

IOException - any other errors

DatabricksRestException - any specific db exceptions

See Also:

https://docs.databricks.com/api/latest/workspace.html#mkdirs