metastore_update_table.go 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123
  1. package emr
  2. //Licensed under the Apache License, Version 2.0 (the "License");
  3. //you may not use this file except in compliance with the License.
  4. //You may obtain a copy of the License at
  5. //
  6. //http://www.apache.org/licenses/LICENSE-2.0
  7. //
  8. //Unless required by applicable law or agreed to in writing, software
  9. //distributed under the License is distributed on an "AS IS" BASIS,
  10. //WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  11. //See the License for the specific language governing permissions and
  12. //limitations under the License.
  13. //
  14. // Code generated by Alibaba Cloud SDK Code Generator.
  15. // Changes may cause incorrect behavior and will be lost if the code is regenerated.
  16. import (
  17. "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
  18. "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
  19. )
  20. // MetastoreUpdateTable invokes the emr.MetastoreUpdateTable API synchronously
  21. // api document: https://help.aliyun.com/api/emr/metastoreupdatetable.html
  22. func (client *Client) MetastoreUpdateTable(request *MetastoreUpdateTableRequest) (response *MetastoreUpdateTableResponse, err error) {
  23. response = CreateMetastoreUpdateTableResponse()
  24. err = client.DoAction(request, response)
  25. return
  26. }
  27. // MetastoreUpdateTableWithChan invokes the emr.MetastoreUpdateTable API asynchronously
  28. // api document: https://help.aliyun.com/api/emr/metastoreupdatetable.html
  29. // asynchronous document: https://help.aliyun.com/document_detail/66220.html
  30. func (client *Client) MetastoreUpdateTableWithChan(request *MetastoreUpdateTableRequest) (<-chan *MetastoreUpdateTableResponse, <-chan error) {
  31. responseChan := make(chan *MetastoreUpdateTableResponse, 1)
  32. errChan := make(chan error, 1)
  33. err := client.AddAsyncTask(func() {
  34. defer close(responseChan)
  35. defer close(errChan)
  36. response, err := client.MetastoreUpdateTable(request)
  37. if err != nil {
  38. errChan <- err
  39. } else {
  40. responseChan <- response
  41. }
  42. })
  43. if err != nil {
  44. errChan <- err
  45. close(responseChan)
  46. close(errChan)
  47. }
  48. return responseChan, errChan
  49. }
  50. // MetastoreUpdateTableWithCallback invokes the emr.MetastoreUpdateTable API asynchronously
  51. // api document: https://help.aliyun.com/api/emr/metastoreupdatetable.html
  52. // asynchronous document: https://help.aliyun.com/document_detail/66220.html
  53. func (client *Client) MetastoreUpdateTableWithCallback(request *MetastoreUpdateTableRequest, callback func(response *MetastoreUpdateTableResponse, err error)) <-chan int {
  54. result := make(chan int, 1)
  55. err := client.AddAsyncTask(func() {
  56. var response *MetastoreUpdateTableResponse
  57. var err error
  58. defer close(result)
  59. response, err = client.MetastoreUpdateTable(request)
  60. callback(response, err)
  61. result <- 1
  62. })
  63. if err != nil {
  64. defer close(result)
  65. callback(nil, err)
  66. result <- 0
  67. }
  68. return result
  69. }
  70. // MetastoreUpdateTableRequest is the request struct for api MetastoreUpdateTable
  71. type MetastoreUpdateTableRequest struct {
  72. *requests.RpcRequest
  73. ResourceOwnerId requests.Integer `position:"Query" name:"ResourceOwnerId"`
  74. AddColumn *[]MetastoreUpdateTableAddColumn `position:"Query" name:"AddColumn" type:"Repeated"`
  75. AddPartition *[]MetastoreUpdateTableAddPartition `position:"Query" name:"AddPartition" type:"Repeated"`
  76. DeleteColumnName *[]string `position:"Query" name:"DeleteColumnName" type:"Repeated"`
  77. TableId string `position:"Query" name:"TableId"`
  78. DeletePartitionName *[]string `position:"Query" name:"DeletePartitionName" type:"Repeated"`
  79. }
  80. // MetastoreUpdateTableAddColumn is a repeated param struct in MetastoreUpdateTableRequest
  81. type MetastoreUpdateTableAddColumn struct {
  82. Name string `name:"Name"`
  83. Comment string `name:"Comment"`
  84. Type string `name:"Type"`
  85. }
  86. // MetastoreUpdateTableAddPartition is a repeated param struct in MetastoreUpdateTableRequest
  87. type MetastoreUpdateTableAddPartition struct {
  88. Name string `name:"Name"`
  89. Comment string `name:"Comment"`
  90. Type string `name:"Type"`
  91. }
  92. // MetastoreUpdateTableResponse is the response struct for api MetastoreUpdateTable
  93. type MetastoreUpdateTableResponse struct {
  94. *responses.BaseResponse
  95. RequestId string `json:"RequestId" xml:"RequestId"`
  96. Success bool `json:"success" xml:"success"`
  97. }
  98. // CreateMetastoreUpdateTableRequest creates a request to invoke MetastoreUpdateTable API
  99. func CreateMetastoreUpdateTableRequest() (request *MetastoreUpdateTableRequest) {
  100. request = &MetastoreUpdateTableRequest{
  101. RpcRequest: &requests.RpcRequest{},
  102. }
  103. request.InitWithApiInfo("Emr", "2016-04-08", "MetastoreUpdateTable", "emr", "openAPI")
  104. return
  105. }
  106. // CreateMetastoreUpdateTableResponse creates a response to parse from MetastoreUpdateTable response
  107. func CreateMetastoreUpdateTableResponse() (response *MetastoreUpdateTableResponse) {
  108. response = &MetastoreUpdateTableResponse{
  109. BaseResponse: &responses.BaseResponse{},
  110. }
  111. return
  112. }