client

func (*XdataClient) CancelPySparkJob ¶ added in v1.0.3

func (c *XdataClient) CancelPySparkJob(request *xdata.CancelPySparkJobRequest) (*xdata.CancelPySparkJobResponse, error)

终止用户PySpark脚本任务

func (*XdataClient) CancelRasQuery ¶ added in v1.0.3

func (c *XdataClient) CancelRasQuery(request *xdata.CancelRasQueryRequest) (*xdata.CancelRasQueryResponse, error)

终止用户Spark SQL脚本查询

func (*XdataClient) CreateDatabase ¶

func (c *XdataClient) CreateDatabase(request *xdata.CreateDatabaseRequest) (*xdata.CreateDatabaseResponse, error)

创建属于用户实例的数据库

func (*XdataClient) CreateTable ¶

func (c *XdataClient) CreateTable(request *xdata.CreateTableRequest) (*xdata.CreateTableResponse, error)

创建用户实例的数据表

func (*XdataClient) DeleteDatabase ¶

func (c *XdataClient) DeleteDatabase(request *xdata.DeleteDatabaseRequest) (*xdata.DeleteDatabaseResponse, error)

删除用户实例的指定数据库

func (*XdataClient) DeleteTable ¶

func (c *XdataClient) DeleteTable(request *xdata.DeleteTableRequest) (*xdata.DeleteTableResponse, error)

删除用户实例的指定数据表

func (*XdataClient) ExecutePySparkQuery ¶ added in v1.0.3

func (c *XdataClient) ExecutePySparkQuery(request *xdata.ExecutePySparkQueryRequest) (*xdata.ExecutePySparkQueryResponse, error)

执行用户编写的PySpark脚本

func (*XdataClient) ExecuteRasQuery ¶ added in v1.0.3

func (c *XdataClient) ExecuteRasQuery(request *xdata.ExecuteRasQueryRequest) (*xdata.ExecuteRasQueryResponse, error)

执行用户编写的Spark SQL脚本

func (*XdataClient) GetDatabaseInfo ¶

func (c *XdataClient) GetDatabaseInfo(request *xdata.GetDatabaseInfoRequest) (*xdata.GetDatabaseInfoResponse, error)

查询用户实例的指定数据库信息

func (*XdataClient) GetPySparkExecuteResult ¶ added in v1.0.3

func (c *XdataClient) GetPySparkExecuteResult(request *xdata.GetPySparkExecuteResultRequest) (*xdata.GetPySparkExecuteResultResponse, error)

获取用户PySpark脚本的执行结果

func (*XdataClient) GetPySparkExecuteState ¶ added in v1.0.3

func (c *XdataClient) GetPySparkExecuteState(request *xdata.GetPySparkExecuteStateRequest) (*xdata.GetPySparkExecuteStateResponse, error)

获取用户PySpark脚本的执行状态

func (*XdataClient) GetRasQueryLog ¶ added in v1.0.3

func (c *XdataClient) GetRasQueryLog(request *xdata.GetRasQueryLogRequest) (*xdata.GetRasQueryLogResponse, error)

获取用户Spark SQL脚本的查询日志

func (*XdataClient) GetRasQueryResult ¶ added in v1.0.3

func (c *XdataClient) GetRasQueryResult(request *xdata.GetRasQueryResultRequest) (*xdata.GetRasQueryResultResponse, error)

获取用户Spark SQL脚本的查询结果

func (*XdataClient) GetRasQueryState ¶ added in v1.0.3

func (c *XdataClient) GetRasQueryState(request *xdata.GetRasQueryStateRequest) (*xdata.GetRasQueryStateResponse, error)

获取用户Spark SQL脚本的查询状态

func (*XdataClient) GetTableInfo ¶

func (c *XdataClient) GetTableInfo(request *xdata.GetTableInfoRequest) (*xdata.GetTableInfoResponse, error)

查询用户实例的指定数据表信息

func (*XdataClient) ListDatabaseInfo ¶

func (c *XdataClient) ListDatabaseInfo(request *xdata.ListDatabaseInfoRequest) (*xdata.ListDatabaseInfoResponse, error)

查询用户实例的所有数据库信息

func (*XdataClient) ListInstanceInfo ¶

func (c *XdataClient) ListInstanceInfo(request *xdata.ListInstanceInfoRequest) (*xdata.ListInstanceInfoResponse, error)

查询用户所属的实例信息

func (*XdataClient) ListTableInfo ¶

func (c *XdataClient) ListTableInfo(request *xdata.ListTableInfoRequest) (*xdata.ListTableInfoResponse, error)

查询用户实例指定数据库下的所有数据表信息

func (*XdataClient) SetConfig ¶

func (c *XdataClient) SetConfig(config *core.Config)

func (*XdataClient) SetLogger ¶

func (c *XdataClient) SetLogger(logger core.Logger)