client

Documentation

Index

• type XdataClient
  • func NewXdataClient(credential *core.Credential) *XdataClient
  • func (c *XdataClient) CancelPySparkJob(request *xdata.CancelPySparkJobRequest) (*xdata.CancelPySparkJobResponse, error)
  • func (c *XdataClient) CancelRasQuery(request *xdata.CancelRasQueryRequest) (*xdata.CancelRasQueryResponse, error)
  • func (c *XdataClient) CreateDatabase(request *xdata.CreateDatabaseRequest) (*xdata.CreateDatabaseResponse, error)
  • func (c *XdataClient) CreateTable(request *xdata.CreateTableRequest) (*xdata.CreateTableResponse, error)
  • func (c *XdataClient) DeleteDatabase(request *xdata.DeleteDatabaseRequest) (*xdata.DeleteDatabaseResponse, error)
  • func (c *XdataClient) DeleteTable(request *xdata.DeleteTableRequest) (*xdata.DeleteTableResponse, error)
  • func (c *XdataClient) ExecutePySparkQuery(request *xdata.ExecutePySparkQueryRequest) (*xdata.ExecutePySparkQueryResponse, error)
  • func (c *XdataClient) ExecuteRasQuery(request *xdata.ExecuteRasQueryRequest) (*xdata.ExecuteRasQueryResponse, error)
  • func (c *XdataClient) GetDatabaseInfo(request *xdata.GetDatabaseInfoRequest) (*xdata.GetDatabaseInfoResponse, error)
  • func (c *XdataClient) GetPySparkExecuteResult(request *xdata.GetPySparkExecuteResultRequest) (*xdata.GetPySparkExecuteResultResponse, error)
  • func (c *XdataClient) GetPySparkExecuteState(request *xdata.GetPySparkExecuteStateRequest) (*xdata.GetPySparkExecuteStateResponse, error)
  • func (c *XdataClient) GetRasQueryLog(request *xdata.GetRasQueryLogRequest) (*xdata.GetRasQueryLogResponse, error)
  • func (c *XdataClient) GetRasQueryResult(request *xdata.GetRasQueryResultRequest) (*xdata.GetRasQueryResultResponse, error)
  • func (c *XdataClient) GetRasQueryState(request *xdata.GetRasQueryStateRequest) (*xdata.GetRasQueryStateResponse, error)
  • func (c *XdataClient) GetTableInfo(request *xdata.GetTableInfoRequest) (*xdata.GetTableInfoResponse, error)
  • func (c *XdataClient) ListDatabaseInfo(request *xdata.ListDatabaseInfoRequest) (*xdata.ListDatabaseInfoResponse, error)
  • func (c *XdataClient) ListInstanceInfo(request *xdata.ListInstanceInfoRequest) (*xdata.ListInstanceInfoResponse, error)
  • func (c *XdataClient) ListTableInfo(request *xdata.ListTableInfoRequest) (*xdata.ListTableInfoResponse, error)
  • func (c *XdataClient) SetConfig(config *core.Config)
  • func (c *XdataClient) SetLogger(logger core.Logger)

Types

type XdataClient

type XdataClient struct {
	core.JDCloudClient
}

func NewXdataClient

func NewXdataClient(credential *core.Credential) *XdataClient

func (*XdataClient) CancelPySparkJob

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

终止用户PySpark脚本任务

func (*XdataClient) CancelRasQuery

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

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

执行用户编写的PySpark脚本

func (*XdataClient) ExecuteRasQuery

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

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

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

func (*XdataClient) GetPySparkExecuteState

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

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

func (*XdataClient) GetRasQueryLog

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

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

func (*XdataClient) GetRasQueryResult

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

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

func (*XdataClient) GetRasQueryState

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)