Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Sign up
Appearance settings

Commit edfa4c4

Browse files
committed
Support API GetTableCompaction.
1 parent 6b94cc4 commit edfa4c4

File tree

7 files changed

+284
-28
lines changed

7 files changed

+284
-28
lines changed

‎dlfnext-20250310/ChangeLog.txt‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
2025年10月29日 Version: v3.4.0
2+
- Support API GetTableCompaction.
3+
4+
15
2025年10月20日 Version: v3.3.0
26
- Support API ListPartitions.
37

‎dlfnext-20250310/client/client.go‎

Lines changed: 50 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2256,6 +2256,56 @@ func (client *Client) GetTable(catalogId *string, database *string, table *strin
22562256
return _result, _err
22572257
}
22582258

2259+
// Summary:
2260+
//
2261+
// 查看表Compaction详情
2262+
//
2263+
// @param headers - map
2264+
//
2265+
// @param runtime - runtime options for this request RuntimeOptions
2266+
//
2267+
// @return GetTableCompactionResponse
2268+
func (client *Client) GetTableCompactionWithOptions(catalogId *string, database *string, table *string, headers map[string]*string, runtime *dara.RuntimeOptions) (_result *GetTableCompactionResponse, _err error) {
2269+
req := &openapiutil.OpenApiRequest{
2270+
Headers: headers,
2271+
}
2272+
params := &openapiutil.Params{
2273+
Action: dara.String("GetTableCompaction"),
2274+
Version: dara.String("2025年03月10日"),
2275+
Protocol: dara.String("HTTPS"),
2276+
Pathname: dara.String("/dlf/v1/" + dara.PercentEncode(dara.StringValue(catalogId)) + "/databases/" + dara.PercentEncode(dara.StringValue(database)) + "/tables/" + dara.PercentEncode(dara.StringValue(table)) + "/compaction"),
2277+
Method: dara.String("GET"),
2278+
AuthType: dara.String("AK"),
2279+
Style: dara.String("ROA"),
2280+
ReqBodyType: dara.String("json"),
2281+
BodyType: dara.String("json"),
2282+
}
2283+
_result = &GetTableCompactionResponse{}
2284+
_body, _err := client.CallApi(params, req, runtime)
2285+
if _err != nil {
2286+
return _result, _err
2287+
}
2288+
_err = dara.Convert(_body, &_result)
2289+
return _result, _err
2290+
}
2291+
2292+
// Summary:
2293+
//
2294+
// 查看表Compaction详情
2295+
//
2296+
// @return GetTableCompactionResponse
2297+
func (client *Client) GetTableCompaction(catalogId *string, database *string, table *string) (_result *GetTableCompactionResponse, _err error) {
2298+
runtime := &dara.RuntimeOptions{}
2299+
headers := make(map[string]*string)
2300+
_result = &GetTableCompactionResponse{}
2301+
_body, _err := client.GetTableCompactionWithOptions(catalogId, database, table, headers, runtime)
2302+
if _err != nil {
2303+
return _result, _err
2304+
}
2305+
_result = _body
2306+
return _result, _err
2307+
}
2308+
22592309
// Summary:
22602310
//
22612311
// 查看表快照

‎dlfnext-20250310/client/client_context_func.go‎

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1555,6 +1555,39 @@ func (client *Client) GetTableWithContext(ctx context.Context, catalogId *string
15551555
return _result, _err
15561556
}
15571557

1558+
// Summary:
1559+
//
1560+
// 查看表Compaction详情
1561+
//
1562+
// @param headers - map
1563+
//
1564+
// @param runtime - runtime options for this request RuntimeOptions
1565+
//
1566+
// @return GetTableCompactionResponse
1567+
func (client *Client) GetTableCompactionWithContext(ctx context.Context, catalogId *string, database *string, table *string, headers map[string]*string, runtime *dara.RuntimeOptions) (_result *GetTableCompactionResponse, _err error) {
1568+
req := &openapiutil.OpenApiRequest{
1569+
Headers: headers,
1570+
}
1571+
params := &openapiutil.Params{
1572+
Action: dara.String("GetTableCompaction"),
1573+
Version: dara.String("2025年03月10日"),
1574+
Protocol: dara.String("HTTPS"),
1575+
Pathname: dara.String("/dlf/v1/" + dara.PercentEncode(dara.StringValue(catalogId)) + "/databases/" + dara.PercentEncode(dara.StringValue(database)) + "/tables/" + dara.PercentEncode(dara.StringValue(table)) + "/compaction"),
1576+
Method: dara.String("GET"),
1577+
AuthType: dara.String("AK"),
1578+
Style: dara.String("ROA"),
1579+
ReqBodyType: dara.String("json"),
1580+
BodyType: dara.String("json"),
1581+
}
1582+
_result = &GetTableCompactionResponse{}
1583+
_body, _err := client.CallApiWithCtx(ctx, params, req, runtime)
1584+
if _err != nil {
1585+
return _result, _err
1586+
}
1587+
_err = dara.Convert(_body, &_result)
1588+
return _result, _err
1589+
}
1590+
15581591
// Summary:
15591592
//
15601593
// 查看表快照
Lines changed: 68 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,68 @@
1+
// This file is auto-generated, don't edit it. Thanks.
2+
package client
3+
4+
import (
5+
"github.com/alibabacloud-go/tea/dara"
6+
)
7+
8+
type iGetTableCompactionResponse interface {
9+
dara.Model
10+
String() string
11+
GoString() string
12+
SetHeaders(v map[string]*string) *GetTableCompactionResponse
13+
GetHeaders() map[string]*string
14+
SetStatusCode(v int32) *GetTableCompactionResponse
15+
GetStatusCode() *int32
16+
SetBody(v *TableCompaction) *GetTableCompactionResponse
17+
GetBody() *TableCompaction
18+
}
19+
20+
type GetTableCompactionResponse struct {
21+
Headers map[string]*string `json:"headers,omitempty" xml:"headers,omitempty"`
22+
StatusCode *int32 `json:"statusCode,omitempty" xml:"statusCode,omitempty"`
23+
Body *TableCompaction `json:"body,omitempty" xml:"body,omitempty"`
24+
}
25+
26+
func (s GetTableCompactionResponse) String() string {
27+
return dara.Prettify(s)
28+
}
29+
30+
func (s GetTableCompactionResponse) GoString() string {
31+
return s.String()
32+
}
33+
34+
func (s *GetTableCompactionResponse) GetHeaders() map[string]*string {
35+
return s.Headers
36+
}
37+
38+
func (s *GetTableCompactionResponse) GetStatusCode() *int32 {
39+
return s.StatusCode
40+
}
41+
42+
func (s *GetTableCompactionResponse) GetBody() *TableCompaction {
43+
return s.Body
44+
}
45+
46+
func (s *GetTableCompactionResponse) SetHeaders(v map[string]*string) *GetTableCompactionResponse {
47+
s.Headers = v
48+
return s
49+
}
50+
51+
func (s *GetTableCompactionResponse) SetStatusCode(v int32) *GetTableCompactionResponse {
52+
s.StatusCode = &v
53+
return s
54+
}
55+
56+
func (s *GetTableCompactionResponse) SetBody(v *TableCompaction) *GetTableCompactionResponse {
57+
s.Body = v
58+
return s
59+
}
60+
61+
func (s *GetTableCompactionResponse) Validate() error {
62+
if s.Body != nil {
63+
if err := s.Body.Validate(); err != nil {
64+
return err
65+
}
66+
}
67+
return nil
68+
}

‎dlfnext-20250310/client/iceberg_snapshot_model.go‎

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,10 +13,14 @@ type iIcebergSnapshot interface {
1313
GetAddedRows() *int64
1414
SetId(v int64) *IcebergSnapshot
1515
GetId() *int64
16+
SetIdString(v string) *IcebergSnapshot
17+
GetIdString() *string
1618
SetOperation(v string) *IcebergSnapshot
1719
GetOperation() *string
1820
SetParentId(v int64) *IcebergSnapshot
1921
GetParentId() *int64
22+
SetParentIdString(v string) *IcebergSnapshot
23+
GetParentIdString() *string
2024
SetSchemaId(v int64) *IcebergSnapshot
2125
GetSchemaId() *int64
2226
SetSequenceNumber(v int64) *IcebergSnapshot
@@ -30,8 +34,10 @@ type iIcebergSnapshot interface {
3034
type IcebergSnapshot struct {
3135
AddedRows *int64 `json:"addedRows,omitempty" xml:"addedRows,omitempty"`
3236
Id *int64 `json:"id,omitempty" xml:"id,omitempty"`
37+
IdString *string `json:"idString,omitempty" xml:"idString,omitempty"`
3338
Operation *string `json:"operation,omitempty" xml:"operation,omitempty"`
3439
ParentId *int64 `json:"parentId,omitempty" xml:"parentId,omitempty"`
40+
ParentIdString *string `json:"parentIdString,omitempty" xml:"parentIdString,omitempty"`
3541
SchemaId *int64 `json:"schemaId,omitempty" xml:"schemaId,omitempty"`
3642
SequenceNumber *int64 `json:"sequenceNumber,omitempty" xml:"sequenceNumber,omitempty"`
3743
Summary map[string]*string `json:"summary,omitempty" xml:"summary,omitempty"`
@@ -54,6 +60,10 @@ func (s *IcebergSnapshot) GetId() *int64 {
5460
return s.Id
5561
}
5662

63+
func (s *IcebergSnapshot) GetIdString() *string {
64+
return s.IdString
65+
}
66+
5767
func (s *IcebergSnapshot) GetOperation() *string {
5868
return s.Operation
5969
}
@@ -62,6 +72,10 @@ func (s *IcebergSnapshot) GetParentId() *int64 {
6272
return s.ParentId
6373
}
6474

75+
func (s *IcebergSnapshot) GetParentIdString() *string {
76+
return s.ParentIdString
77+
}
78+
6579
func (s *IcebergSnapshot) GetSchemaId() *int64 {
6680
return s.SchemaId
6781
}
@@ -88,6 +102,11 @@ func (s *IcebergSnapshot) SetId(v int64) *IcebergSnapshot {
88102
return s
89103
}
90104

105+
func (s *IcebergSnapshot) SetIdString(v string) *IcebergSnapshot {
106+
s.IdString = &v
107+
return s
108+
}
109+
91110
func (s *IcebergSnapshot) SetOperation(v string) *IcebergSnapshot {
92111
s.Operation = &v
93112
return s
@@ -98,6 +117,11 @@ func (s *IcebergSnapshot) SetParentId(v int64) *IcebergSnapshot {
98117
return s
99118
}
100119

120+
func (s *IcebergSnapshot) SetParentIdString(v string) *IcebergSnapshot {
121+
s.ParentIdString = &v
122+
return s
123+
}
124+
101125
func (s *IcebergSnapshot) SetSchemaId(v int64) *IcebergSnapshot {
102126
s.SchemaId = &v
103127
return s

‎dlfnext-20250310/client/snapshot_model.go‎

Lines changed: 62 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -27,14 +27,22 @@ type iSnapshot interface {
2727
GetDeltaRecordCount() *int64
2828
SetId(v int64) *Snapshot
2929
GetId() *int64
30+
SetIdString(v string) *Snapshot
31+
GetIdString() *string
3032
SetIndexManifest(v string) *Snapshot
3133
GetIndexManifest() *string
3234
SetLogOffsets(v map[string]*int64) *Snapshot
3335
GetLogOffsets() map[string]*int64
36+
SetParentIdString(v string) *Snapshot
37+
GetParentIdString() *string
3438
SetSchemaId(v int64) *Snapshot
3539
GetSchemaId() *int64
40+
SetSequenceNumber(v int64) *Snapshot
41+
GetSequenceNumber() *int64
3642
SetStatistics(v string) *Snapshot
3743
GetStatistics() *string
44+
SetSummary(v map[string]*string) *Snapshot
45+
GetSummary() map[string]*string
3846
SetTimeMillis(v int64) *Snapshot
3947
GetTimeMillis() *int64
4048
SetTotalRecordCount(v int64) *Snapshot
@@ -49,20 +57,24 @@ type Snapshot struct {
4957
BaseManifestList *string `json:"baseManifestList,omitempty" xml:"baseManifestList,omitempty"`
5058
// if can be null:
5159
// true
52-
ChangelogManifestList *string `json:"changelogManifestList,omitempty" xml:"changelogManifestList,omitempty"`
53-
ChangelogRecordCount *int64 `json:"changelogRecordCount,omitempty" xml:"changelogRecordCount,omitempty"`
54-
CommitIdentifier *int64 `json:"commitIdentifier,omitempty" xml:"commitIdentifier,omitempty"`
55-
CommitKind *string `json:"commitKind,omitempty" xml:"commitKind,omitempty"`
56-
CommitUser *string `json:"commitUser,omitempty" xml:"commitUser,omitempty"`
57-
DeltaManifestList *string `json:"deltaManifestList,omitempty" xml:"deltaManifestList,omitempty"`
58-
DeltaRecordCount *int64 `json:"deltaRecordCount,omitempty" xml:"deltaRecordCount,omitempty"`
59-
Id *int64 `json:"id,omitempty" xml:"id,omitempty"`
60-
IndexManifest *string `json:"indexManifest,omitempty" xml:"indexManifest,omitempty"`
61-
LogOffsets map[string]*int64 `json:"logOffsets,omitempty" xml:"logOffsets,omitempty"`
62-
SchemaId *int64 `json:"schemaId,omitempty" xml:"schemaId,omitempty"`
63-
Statistics *string `json:"statistics,omitempty" xml:"statistics,omitempty"`
64-
TimeMillis *int64 `json:"timeMillis,omitempty" xml:"timeMillis,omitempty"`
65-
TotalRecordCount *int64 `json:"totalRecordCount,omitempty" xml:"totalRecordCount,omitempty"`
60+
ChangelogManifestList *string `json:"changelogManifestList,omitempty" xml:"changelogManifestList,omitempty"`
61+
ChangelogRecordCount *int64 `json:"changelogRecordCount,omitempty" xml:"changelogRecordCount,omitempty"`
62+
CommitIdentifier *int64 `json:"commitIdentifier,omitempty" xml:"commitIdentifier,omitempty"`
63+
CommitKind *string `json:"commitKind,omitempty" xml:"commitKind,omitempty"`
64+
CommitUser *string `json:"commitUser,omitempty" xml:"commitUser,omitempty"`
65+
DeltaManifestList *string `json:"deltaManifestList,omitempty" xml:"deltaManifestList,omitempty"`
66+
DeltaRecordCount *int64 `json:"deltaRecordCount,omitempty" xml:"deltaRecordCount,omitempty"`
67+
Id *int64 `json:"id,omitempty" xml:"id,omitempty"`
68+
IdString *string `json:"idString,omitempty" xml:"idString,omitempty"`
69+
IndexManifest *string `json:"indexManifest,omitempty" xml:"indexManifest,omitempty"`
70+
LogOffsets map[string]*int64 `json:"logOffsets,omitempty" xml:"logOffsets,omitempty"`
71+
ParentIdString *string `json:"parentIdString,omitempty" xml:"parentIdString,omitempty"`
72+
SchemaId *int64 `json:"schemaId,omitempty" xml:"schemaId,omitempty"`
73+
SequenceNumber *int64 `json:"sequenceNumber,omitempty" xml:"sequenceNumber,omitempty"`
74+
Statistics *string `json:"statistics,omitempty" xml:"statistics,omitempty"`
75+
Summary map[string]*string `json:"summary,omitempty" xml:"summary,omitempty"`
76+
TimeMillis *int64 `json:"timeMillis,omitempty" xml:"timeMillis,omitempty"`
77+
TotalRecordCount *int64 `json:"totalRecordCount,omitempty" xml:"totalRecordCount,omitempty"`
6678
// if can be null:
6779
// true
6880
Version *int32 `json:"version,omitempty" xml:"version,omitempty"`
@@ -113,6 +125,10 @@ func (s *Snapshot) GetId() *int64 {
113125
return s.Id
114126
}
115127

128+
func (s *Snapshot) GetIdString() *string {
129+
return s.IdString
130+
}
131+
116132
func (s *Snapshot) GetIndexManifest() *string {
117133
return s.IndexManifest
118134
}
@@ -121,14 +137,26 @@ func (s *Snapshot) GetLogOffsets() map[string]*int64 {
121137
return s.LogOffsets
122138
}
123139

140+
func (s *Snapshot) GetParentIdString() *string {
141+
return s.ParentIdString
142+
}
143+
124144
func (s *Snapshot) GetSchemaId() *int64 {
125145
return s.SchemaId
126146
}
127147

148+
func (s *Snapshot) GetSequenceNumber() *int64 {
149+
return s.SequenceNumber
150+
}
151+
128152
func (s *Snapshot) GetStatistics() *string {
129153
return s.Statistics
130154
}
131155

156+
func (s *Snapshot) GetSummary() map[string]*string {
157+
return s.Summary
158+
}
159+
132160
func (s *Snapshot) GetTimeMillis() *int64 {
133161
return s.TimeMillis
134162
}
@@ -190,6 +218,11 @@ func (s *Snapshot) SetId(v int64) *Snapshot {
190218
return s
191219
}
192220

221+
func (s *Snapshot) SetIdString(v string) *Snapshot {
222+
s.IdString = &v
223+
return s
224+
}
225+
193226
func (s *Snapshot) SetIndexManifest(v string) *Snapshot {
194227
s.IndexManifest = &v
195228
return s
@@ -200,16 +233,31 @@ func (s *Snapshot) SetLogOffsets(v map[string]*int64) *Snapshot {
200233
return s
201234
}
202235

236+
func (s *Snapshot) SetParentIdString(v string) *Snapshot {
237+
s.ParentIdString = &v
238+
return s
239+
}
240+
203241
func (s *Snapshot) SetSchemaId(v int64) *Snapshot {
204242
s.SchemaId = &v
205243
return s
206244
}
207245

246+
func (s *Snapshot) SetSequenceNumber(v int64) *Snapshot {
247+
s.SequenceNumber = &v
248+
return s
249+
}
250+
208251
func (s *Snapshot) SetStatistics(v string) *Snapshot {
209252
s.Statistics = &v
210253
return s
211254
}
212255

256+
func (s *Snapshot) SetSummary(v map[string]*string) *Snapshot {
257+
s.Summary = v
258+
return s
259+
}
260+
213261
func (s *Snapshot) SetTimeMillis(v int64) *Snapshot {
214262
s.TimeMillis = &v
215263
return s

0 commit comments

Comments
(0)

AltStyle によって変換されたページ (->オリジナル) /