Skip to content

Commit 48054dc

Browse files
author
awstools
committed
feat(client-neptune-graph): Add 4 new APIs to support new Export features, allowing Parquet and CSV formats. Add new arguments in Import APIs to support Parquet import. Add a new query "neptune.read" to run algorithms without loading data into database
1 parent 0ca3da3 commit 48054dc

21 files changed

+2802
-126
lines changed

clients/client-neptune-graph/README.md

+32
Original file line numberDiff line numberDiff line change
@@ -205,6 +205,14 @@ see LICENSE for more information.
205205

206206
## Client Commands (Operations List)
207207

208+
<details>
209+
<summary>
210+
CancelExportTask
211+
</summary>
212+
213+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/neptune-graph/command/CancelExportTaskCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/CancelExportTaskCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/CancelExportTaskCommandOutput/)
214+
215+
</details>
208216
<details>
209217
<summary>
210218
CancelImportTask
@@ -284,6 +292,14 @@ ExecuteQuery
284292

285293
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/neptune-graph/command/ExecuteQueryCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/ExecuteQueryCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/ExecuteQueryCommandOutput/)
286294

295+
</details>
296+
<details>
297+
<summary>
298+
GetExportTask
299+
</summary>
300+
301+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/neptune-graph/command/GetExportTaskCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/GetExportTaskCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/GetExportTaskCommandOutput/)
302+
287303
</details>
288304
<details>
289305
<summary>
@@ -332,6 +348,14 @@ GetQuery
332348

333349
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/neptune-graph/command/GetQueryCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/GetQueryCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/GetQueryCommandOutput/)
334350

351+
</details>
352+
<details>
353+
<summary>
354+
ListExportTasks
355+
</summary>
356+
357+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/neptune-graph/command/ListExportTasksCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/ListExportTasksCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/ListExportTasksCommandOutput/)
358+
335359
</details>
336360
<details>
337361
<summary>
@@ -396,6 +420,14 @@ RestoreGraphFromSnapshot
396420

397421
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/neptune-graph/command/RestoreGraphFromSnapshotCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/RestoreGraphFromSnapshotCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/RestoreGraphFromSnapshotCommandOutput/)
398422

423+
</details>
424+
<details>
425+
<summary>
426+
StartExportTask
427+
</summary>
428+
429+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/neptune-graph/command/StartExportTaskCommand/) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/StartExportTaskCommandInput/) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-neptune-graph/Interface/StartExportTaskCommandOutput/)
430+
399431
</details>
400432
<details>
401433
<summary>

clients/client-neptune-graph/src/NeptuneGraph.ts

+81
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,11 @@
22
import { createAggregatedClient } from "@smithy/smithy-client";
33
import { HttpHandlerOptions as __HttpHandlerOptions } from "@smithy/types";
44

5+
import {
6+
CancelExportTaskCommand,
7+
CancelExportTaskCommandInput,
8+
CancelExportTaskCommandOutput,
9+
} from "./commands/CancelExportTaskCommand";
510
import {
611
CancelImportTaskCommand,
712
CancelImportTaskCommandInput,
@@ -40,6 +45,11 @@ import {
4045
ExecuteQueryCommandInput,
4146
ExecuteQueryCommandOutput,
4247
} from "./commands/ExecuteQueryCommand";
48+
import {
49+
GetExportTaskCommand,
50+
GetExportTaskCommandInput,
51+
GetExportTaskCommandOutput,
52+
} from "./commands/GetExportTaskCommand";
4353
import { GetGraphCommand, GetGraphCommandInput, GetGraphCommandOutput } from "./commands/GetGraphCommand";
4454
import {
4555
GetGraphSnapshotCommand,
@@ -62,6 +72,11 @@ import {
6272
GetPrivateGraphEndpointCommandOutput,
6373
} from "./commands/GetPrivateGraphEndpointCommand";
6474
import { GetQueryCommand, GetQueryCommandInput, GetQueryCommandOutput } from "./commands/GetQueryCommand";
75+
import {
76+
ListExportTasksCommand,
77+
ListExportTasksCommandInput,
78+
ListExportTasksCommandOutput,
79+
} from "./commands/ListExportTasksCommand";
6580
import { ListGraphsCommand, ListGraphsCommandInput, ListGraphsCommandOutput } from "./commands/ListGraphsCommand";
6681
import {
6782
ListGraphSnapshotsCommand,
@@ -90,6 +105,11 @@ import {
90105
RestoreGraphFromSnapshotCommandInput,
91106
RestoreGraphFromSnapshotCommandOutput,
92107
} from "./commands/RestoreGraphFromSnapshotCommand";
108+
import {
109+
StartExportTaskCommand,
110+
StartExportTaskCommandInput,
111+
StartExportTaskCommandOutput,
112+
} from "./commands/StartExportTaskCommand";
93113
import {
94114
StartImportTaskCommand,
95115
StartImportTaskCommandInput,
@@ -105,6 +125,7 @@ import { UpdateGraphCommand, UpdateGraphCommandInput, UpdateGraphCommandOutput }
105125
import { NeptuneGraphClient, NeptuneGraphClientConfig } from "./NeptuneGraphClient";
106126

107127
const commands = {
128+
CancelExportTaskCommand,
108129
CancelImportTaskCommand,
109130
CancelQueryCommand,
110131
CreateGraphCommand,
@@ -115,12 +136,14 @@ const commands = {
115136
DeleteGraphSnapshotCommand,
116137
DeletePrivateGraphEndpointCommand,
117138
ExecuteQueryCommand,
139+
GetExportTaskCommand,
118140
GetGraphCommand,
119141
GetGraphSnapshotCommand,
120142
GetGraphSummaryCommand,
121143
GetImportTaskCommand,
122144
GetPrivateGraphEndpointCommand,
123145
GetQueryCommand,
146+
ListExportTasksCommand,
124147
ListGraphsCommand,
125148
ListGraphSnapshotsCommand,
126149
ListImportTasksCommand,
@@ -129,13 +152,31 @@ const commands = {
129152
ListTagsForResourceCommand,
130153
ResetGraphCommand,
131154
RestoreGraphFromSnapshotCommand,
155+
StartExportTaskCommand,
132156
StartImportTaskCommand,
133157
TagResourceCommand,
134158
UntagResourceCommand,
135159
UpdateGraphCommand,
136160
};
137161

138162
export interface NeptuneGraph {
163+
/**
164+
* @see {@link CancelExportTaskCommand}
165+
*/
166+
cancelExportTask(
167+
args: CancelExportTaskCommandInput,
168+
options?: __HttpHandlerOptions
169+
): Promise<CancelExportTaskCommandOutput>;
170+
cancelExportTask(
171+
args: CancelExportTaskCommandInput,
172+
cb: (err: any, data?: CancelExportTaskCommandOutput) => void
173+
): void;
174+
cancelExportTask(
175+
args: CancelExportTaskCommandInput,
176+
options: __HttpHandlerOptions,
177+
cb: (err: any, data?: CancelExportTaskCommandOutput) => void
178+
): void;
179+
139180
/**
140181
* @see {@link CancelImportTaskCommand}
141182
*/
@@ -282,6 +323,17 @@ export interface NeptuneGraph {
282323
cb: (err: any, data?: ExecuteQueryCommandOutput) => void
283324
): void;
284325

326+
/**
327+
* @see {@link GetExportTaskCommand}
328+
*/
329+
getExportTask(args: GetExportTaskCommandInput, options?: __HttpHandlerOptions): Promise<GetExportTaskCommandOutput>;
330+
getExportTask(args: GetExportTaskCommandInput, cb: (err: any, data?: GetExportTaskCommandOutput) => void): void;
331+
getExportTask(
332+
args: GetExportTaskCommandInput,
333+
options: __HttpHandlerOptions,
334+
cb: (err: any, data?: GetExportTaskCommandOutput) => void
335+
): void;
336+
285337
/**
286338
* @see {@link GetGraphCommand}
287339
*/
@@ -363,6 +415,21 @@ export interface NeptuneGraph {
363415
cb: (err: any, data?: GetQueryCommandOutput) => void
364416
): void;
365417

418+
/**
419+
* @see {@link ListExportTasksCommand}
420+
*/
421+
listExportTasks(): Promise<ListExportTasksCommandOutput>;
422+
listExportTasks(
423+
args: ListExportTasksCommandInput,
424+
options?: __HttpHandlerOptions
425+
): Promise<ListExportTasksCommandOutput>;
426+
listExportTasks(args: ListExportTasksCommandInput, cb: (err: any, data?: ListExportTasksCommandOutput) => void): void;
427+
listExportTasks(
428+
args: ListExportTasksCommandInput,
429+
options: __HttpHandlerOptions,
430+
cb: (err: any, data?: ListExportTasksCommandOutput) => void
431+
): void;
432+
366433
/**
367434
* @see {@link ListGraphsCommand}
368435
*/
@@ -481,6 +548,20 @@ export interface NeptuneGraph {
481548
cb: (err: any, data?: RestoreGraphFromSnapshotCommandOutput) => void
482549
): void;
483550

551+
/**
552+
* @see {@link StartExportTaskCommand}
553+
*/
554+
startExportTask(
555+
args: StartExportTaskCommandInput,
556+
options?: __HttpHandlerOptions
557+
): Promise<StartExportTaskCommandOutput>;
558+
startExportTask(args: StartExportTaskCommandInput, cb: (err: any, data?: StartExportTaskCommandOutput) => void): void;
559+
startExportTask(
560+
args: StartExportTaskCommandInput,
561+
options: __HttpHandlerOptions,
562+
cb: (err: any, data?: StartExportTaskCommandOutput) => void
563+
): void;
564+
484565
/**
485566
* @see {@link StartImportTaskCommand}
486567
*/

clients/client-neptune-graph/src/NeptuneGraphClient.ts

+12
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,7 @@ import {
5454
HttpAuthSchemeResolvedConfig,
5555
resolveHttpAuthSchemeConfig,
5656
} from "./auth/httpAuthSchemeProvider";
57+
import { CancelExportTaskCommandInput, CancelExportTaskCommandOutput } from "./commands/CancelExportTaskCommand";
5758
import { CancelImportTaskCommandInput, CancelImportTaskCommandOutput } from "./commands/CancelImportTaskCommand";
5859
import { CancelQueryCommandInput, CancelQueryCommandOutput } from "./commands/CancelQueryCommand";
5960
import { CreateGraphCommandInput, CreateGraphCommandOutput } from "./commands/CreateGraphCommand";
@@ -79,6 +80,7 @@ import {
7980
DeletePrivateGraphEndpointCommandOutput,
8081
} from "./commands/DeletePrivateGraphEndpointCommand";
8182
import { ExecuteQueryCommandInput, ExecuteQueryCommandOutput } from "./commands/ExecuteQueryCommand";
83+
import { GetExportTaskCommandInput, GetExportTaskCommandOutput } from "./commands/GetExportTaskCommand";
8284
import { GetGraphCommandInput, GetGraphCommandOutput } from "./commands/GetGraphCommand";
8385
import { GetGraphSnapshotCommandInput, GetGraphSnapshotCommandOutput } from "./commands/GetGraphSnapshotCommand";
8486
import { GetGraphSummaryCommandInput, GetGraphSummaryCommandOutput } from "./commands/GetGraphSummaryCommand";
@@ -88,6 +90,7 @@ import {
8890
GetPrivateGraphEndpointCommandOutput,
8991
} from "./commands/GetPrivateGraphEndpointCommand";
9092
import { GetQueryCommandInput, GetQueryCommandOutput } from "./commands/GetQueryCommand";
93+
import { ListExportTasksCommandInput, ListExportTasksCommandOutput } from "./commands/ListExportTasksCommand";
9194
import { ListGraphsCommandInput, ListGraphsCommandOutput } from "./commands/ListGraphsCommand";
9295
import { ListGraphSnapshotsCommandInput, ListGraphSnapshotsCommandOutput } from "./commands/ListGraphSnapshotsCommand";
9396
import { ListImportTasksCommandInput, ListImportTasksCommandOutput } from "./commands/ListImportTasksCommand";
@@ -105,6 +108,7 @@ import {
105108
RestoreGraphFromSnapshotCommandInput,
106109
RestoreGraphFromSnapshotCommandOutput,
107110
} from "./commands/RestoreGraphFromSnapshotCommand";
111+
import { StartExportTaskCommandInput, StartExportTaskCommandOutput } from "./commands/StartExportTaskCommand";
108112
import { StartImportTaskCommandInput, StartImportTaskCommandOutput } from "./commands/StartImportTaskCommand";
109113
import { TagResourceCommandInput, TagResourceCommandOutput } from "./commands/TagResourceCommand";
110114
import { UntagResourceCommandInput, UntagResourceCommandOutput } from "./commands/UntagResourceCommand";
@@ -124,6 +128,7 @@ export { __Client };
124128
* @public
125129
*/
126130
export type ServiceInputTypes =
131+
| CancelExportTaskCommandInput
127132
| CancelImportTaskCommandInput
128133
| CancelQueryCommandInput
129134
| CreateGraphCommandInput
@@ -134,12 +139,14 @@ export type ServiceInputTypes =
134139
| DeleteGraphSnapshotCommandInput
135140
| DeletePrivateGraphEndpointCommandInput
136141
| ExecuteQueryCommandInput
142+
| GetExportTaskCommandInput
137143
| GetGraphCommandInput
138144
| GetGraphSnapshotCommandInput
139145
| GetGraphSummaryCommandInput
140146
| GetImportTaskCommandInput
141147
| GetPrivateGraphEndpointCommandInput
142148
| GetQueryCommandInput
149+
| ListExportTasksCommandInput
143150
| ListGraphSnapshotsCommandInput
144151
| ListGraphsCommandInput
145152
| ListImportTasksCommandInput
@@ -148,6 +155,7 @@ export type ServiceInputTypes =
148155
| ListTagsForResourceCommandInput
149156
| ResetGraphCommandInput
150157
| RestoreGraphFromSnapshotCommandInput
158+
| StartExportTaskCommandInput
151159
| StartImportTaskCommandInput
152160
| TagResourceCommandInput
153161
| UntagResourceCommandInput
@@ -157,6 +165,7 @@ export type ServiceInputTypes =
157165
* @public
158166
*/
159167
export type ServiceOutputTypes =
168+
| CancelExportTaskCommandOutput
160169
| CancelImportTaskCommandOutput
161170
| CancelQueryCommandOutput
162171
| CreateGraphCommandOutput
@@ -167,12 +176,14 @@ export type ServiceOutputTypes =
167176
| DeleteGraphSnapshotCommandOutput
168177
| DeletePrivateGraphEndpointCommandOutput
169178
| ExecuteQueryCommandOutput
179+
| GetExportTaskCommandOutput
170180
| GetGraphCommandOutput
171181
| GetGraphSnapshotCommandOutput
172182
| GetGraphSummaryCommandOutput
173183
| GetImportTaskCommandOutput
174184
| GetPrivateGraphEndpointCommandOutput
175185
| GetQueryCommandOutput
186+
| ListExportTasksCommandOutput
176187
| ListGraphSnapshotsCommandOutput
177188
| ListGraphsCommandOutput
178189
| ListImportTasksCommandOutput
@@ -181,6 +192,7 @@ export type ServiceOutputTypes =
181192
| ListTagsForResourceCommandOutput
182193
| ResetGraphCommandOutput
183194
| RestoreGraphFromSnapshotCommandOutput
195+
| StartExportTaskCommandOutput
184196
| StartImportTaskCommandOutput
185197
| TagResourceCommandOutput
186198
| UntagResourceCommandOutput

0 commit comments

Comments
 (0)