Skip to content

Commit

Permalink
feat(client-neptune-graph): Add 4 new APIs to support new Export feat…
Browse files Browse the repository at this point in the history
…ures, 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
  • Loading branch information
awstools committed Nov 22, 2024
1 parent 0ca3da3 commit 48054dc
Show file tree
Hide file tree
Showing 21 changed files with 2,802 additions and 126 deletions.
32 changes: 32 additions & 0 deletions clients/client-neptune-graph/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -205,6 +205,14 @@ see LICENSE for more information.

## Client Commands (Operations List)

<details>
<summary>
CancelExportTask
</summary>

[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/)

</details>
<details>
<summary>
CancelImportTask
Expand Down Expand Up @@ -284,6 +292,14 @@ ExecuteQuery

[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/)

</details>
<details>
<summary>
GetExportTask
</summary>

[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/)

</details>
<details>
<summary>
Expand Down Expand Up @@ -332,6 +348,14 @@ GetQuery

[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/)

</details>
<details>
<summary>
ListExportTasks
</summary>

[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/)

</details>
<details>
<summary>
Expand Down Expand Up @@ -396,6 +420,14 @@ RestoreGraphFromSnapshot

[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/)

</details>
<details>
<summary>
StartExportTask
</summary>

[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/)

</details>
<details>
<summary>
Expand Down
81 changes: 81 additions & 0 deletions clients/client-neptune-graph/src/NeptuneGraph.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,11 @@
import { createAggregatedClient } from "@smithy/smithy-client";
import { HttpHandlerOptions as __HttpHandlerOptions } from "@smithy/types";

import {
CancelExportTaskCommand,
CancelExportTaskCommandInput,
CancelExportTaskCommandOutput,
} from "./commands/CancelExportTaskCommand";
import {
CancelImportTaskCommand,
CancelImportTaskCommandInput,
Expand Down Expand Up @@ -40,6 +45,11 @@ import {
ExecuteQueryCommandInput,
ExecuteQueryCommandOutput,
} from "./commands/ExecuteQueryCommand";
import {
GetExportTaskCommand,
GetExportTaskCommandInput,
GetExportTaskCommandOutput,
} from "./commands/GetExportTaskCommand";
import { GetGraphCommand, GetGraphCommandInput, GetGraphCommandOutput } from "./commands/GetGraphCommand";
import {
GetGraphSnapshotCommand,
Expand All @@ -62,6 +72,11 @@ import {
GetPrivateGraphEndpointCommandOutput,
} from "./commands/GetPrivateGraphEndpointCommand";
import { GetQueryCommand, GetQueryCommandInput, GetQueryCommandOutput } from "./commands/GetQueryCommand";
import {
ListExportTasksCommand,
ListExportTasksCommandInput,
ListExportTasksCommandOutput,
} from "./commands/ListExportTasksCommand";
import { ListGraphsCommand, ListGraphsCommandInput, ListGraphsCommandOutput } from "./commands/ListGraphsCommand";
import {
ListGraphSnapshotsCommand,
Expand Down Expand Up @@ -90,6 +105,11 @@ import {
RestoreGraphFromSnapshotCommandInput,
RestoreGraphFromSnapshotCommandOutput,
} from "./commands/RestoreGraphFromSnapshotCommand";
import {
StartExportTaskCommand,
StartExportTaskCommandInput,
StartExportTaskCommandOutput,
} from "./commands/StartExportTaskCommand";
import {
StartImportTaskCommand,
StartImportTaskCommandInput,
Expand All @@ -105,6 +125,7 @@ import { UpdateGraphCommand, UpdateGraphCommandInput, UpdateGraphCommandOutput }
import { NeptuneGraphClient, NeptuneGraphClientConfig } from "./NeptuneGraphClient";

const commands = {
CancelExportTaskCommand,
CancelImportTaskCommand,
CancelQueryCommand,
CreateGraphCommand,
Expand All @@ -115,12 +136,14 @@ const commands = {
DeleteGraphSnapshotCommand,
DeletePrivateGraphEndpointCommand,
ExecuteQueryCommand,
GetExportTaskCommand,
GetGraphCommand,
GetGraphSnapshotCommand,
GetGraphSummaryCommand,
GetImportTaskCommand,
GetPrivateGraphEndpointCommand,
GetQueryCommand,
ListExportTasksCommand,
ListGraphsCommand,
ListGraphSnapshotsCommand,
ListImportTasksCommand,
Expand All @@ -129,13 +152,31 @@ const commands = {
ListTagsForResourceCommand,
ResetGraphCommand,
RestoreGraphFromSnapshotCommand,
StartExportTaskCommand,
StartImportTaskCommand,
TagResourceCommand,
UntagResourceCommand,
UpdateGraphCommand,
};

export interface NeptuneGraph {
/**
* @see {@link CancelExportTaskCommand}
*/
cancelExportTask(
args: CancelExportTaskCommandInput,
options?: __HttpHandlerOptions
): Promise<CancelExportTaskCommandOutput>;
cancelExportTask(
args: CancelExportTaskCommandInput,
cb: (err: any, data?: CancelExportTaskCommandOutput) => void
): void;
cancelExportTask(
args: CancelExportTaskCommandInput,
options: __HttpHandlerOptions,
cb: (err: any, data?: CancelExportTaskCommandOutput) => void
): void;

/**
* @see {@link CancelImportTaskCommand}
*/
Expand Down Expand Up @@ -282,6 +323,17 @@ export interface NeptuneGraph {
cb: (err: any, data?: ExecuteQueryCommandOutput) => void
): void;

/**
* @see {@link GetExportTaskCommand}
*/
getExportTask(args: GetExportTaskCommandInput, options?: __HttpHandlerOptions): Promise<GetExportTaskCommandOutput>;
getExportTask(args: GetExportTaskCommandInput, cb: (err: any, data?: GetExportTaskCommandOutput) => void): void;
getExportTask(
args: GetExportTaskCommandInput,
options: __HttpHandlerOptions,
cb: (err: any, data?: GetExportTaskCommandOutput) => void
): void;

/**
* @see {@link GetGraphCommand}
*/
Expand Down Expand Up @@ -363,6 +415,21 @@ export interface NeptuneGraph {
cb: (err: any, data?: GetQueryCommandOutput) => void
): void;

/**
* @see {@link ListExportTasksCommand}
*/
listExportTasks(): Promise<ListExportTasksCommandOutput>;
listExportTasks(
args: ListExportTasksCommandInput,
options?: __HttpHandlerOptions
): Promise<ListExportTasksCommandOutput>;
listExportTasks(args: ListExportTasksCommandInput, cb: (err: any, data?: ListExportTasksCommandOutput) => void): void;
listExportTasks(
args: ListExportTasksCommandInput,
options: __HttpHandlerOptions,
cb: (err: any, data?: ListExportTasksCommandOutput) => void
): void;

/**
* @see {@link ListGraphsCommand}
*/
Expand Down Expand Up @@ -481,6 +548,20 @@ export interface NeptuneGraph {
cb: (err: any, data?: RestoreGraphFromSnapshotCommandOutput) => void
): void;

/**
* @see {@link StartExportTaskCommand}
*/
startExportTask(
args: StartExportTaskCommandInput,
options?: __HttpHandlerOptions
): Promise<StartExportTaskCommandOutput>;
startExportTask(args: StartExportTaskCommandInput, cb: (err: any, data?: StartExportTaskCommandOutput) => void): void;
startExportTask(
args: StartExportTaskCommandInput,
options: __HttpHandlerOptions,
cb: (err: any, data?: StartExportTaskCommandOutput) => void
): void;

/**
* @see {@link StartImportTaskCommand}
*/
Expand Down
12 changes: 12 additions & 0 deletions clients/client-neptune-graph/src/NeptuneGraphClient.ts
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,7 @@ import {
HttpAuthSchemeResolvedConfig,
resolveHttpAuthSchemeConfig,
} from "./auth/httpAuthSchemeProvider";
import { CancelExportTaskCommandInput, CancelExportTaskCommandOutput } from "./commands/CancelExportTaskCommand";
import { CancelImportTaskCommandInput, CancelImportTaskCommandOutput } from "./commands/CancelImportTaskCommand";
import { CancelQueryCommandInput, CancelQueryCommandOutput } from "./commands/CancelQueryCommand";
import { CreateGraphCommandInput, CreateGraphCommandOutput } from "./commands/CreateGraphCommand";
Expand All @@ -79,6 +80,7 @@ import {
DeletePrivateGraphEndpointCommandOutput,
} from "./commands/DeletePrivateGraphEndpointCommand";
import { ExecuteQueryCommandInput, ExecuteQueryCommandOutput } from "./commands/ExecuteQueryCommand";
import { GetExportTaskCommandInput, GetExportTaskCommandOutput } from "./commands/GetExportTaskCommand";
import { GetGraphCommandInput, GetGraphCommandOutput } from "./commands/GetGraphCommand";
import { GetGraphSnapshotCommandInput, GetGraphSnapshotCommandOutput } from "./commands/GetGraphSnapshotCommand";
import { GetGraphSummaryCommandInput, GetGraphSummaryCommandOutput } from "./commands/GetGraphSummaryCommand";
Expand All @@ -88,6 +90,7 @@ import {
GetPrivateGraphEndpointCommandOutput,
} from "./commands/GetPrivateGraphEndpointCommand";
import { GetQueryCommandInput, GetQueryCommandOutput } from "./commands/GetQueryCommand";
import { ListExportTasksCommandInput, ListExportTasksCommandOutput } from "./commands/ListExportTasksCommand";
import { ListGraphsCommandInput, ListGraphsCommandOutput } from "./commands/ListGraphsCommand";
import { ListGraphSnapshotsCommandInput, ListGraphSnapshotsCommandOutput } from "./commands/ListGraphSnapshotsCommand";
import { ListImportTasksCommandInput, ListImportTasksCommandOutput } from "./commands/ListImportTasksCommand";
Expand All @@ -105,6 +108,7 @@ import {
RestoreGraphFromSnapshotCommandInput,
RestoreGraphFromSnapshotCommandOutput,
} from "./commands/RestoreGraphFromSnapshotCommand";
import { StartExportTaskCommandInput, StartExportTaskCommandOutput } from "./commands/StartExportTaskCommand";
import { StartImportTaskCommandInput, StartImportTaskCommandOutput } from "./commands/StartImportTaskCommand";
import { TagResourceCommandInput, TagResourceCommandOutput } from "./commands/TagResourceCommand";
import { UntagResourceCommandInput, UntagResourceCommandOutput } from "./commands/UntagResourceCommand";
Expand All @@ -124,6 +128,7 @@ export { __Client };
* @public
*/
export type ServiceInputTypes =
| CancelExportTaskCommandInput
| CancelImportTaskCommandInput
| CancelQueryCommandInput
| CreateGraphCommandInput
Expand All @@ -134,12 +139,14 @@ export type ServiceInputTypes =
| DeleteGraphSnapshotCommandInput
| DeletePrivateGraphEndpointCommandInput
| ExecuteQueryCommandInput
| GetExportTaskCommandInput
| GetGraphCommandInput
| GetGraphSnapshotCommandInput
| GetGraphSummaryCommandInput
| GetImportTaskCommandInput
| GetPrivateGraphEndpointCommandInput
| GetQueryCommandInput
| ListExportTasksCommandInput
| ListGraphSnapshotsCommandInput
| ListGraphsCommandInput
| ListImportTasksCommandInput
Expand All @@ -148,6 +155,7 @@ export type ServiceInputTypes =
| ListTagsForResourceCommandInput
| ResetGraphCommandInput
| RestoreGraphFromSnapshotCommandInput
| StartExportTaskCommandInput
| StartImportTaskCommandInput
| TagResourceCommandInput
| UntagResourceCommandInput
Expand All @@ -157,6 +165,7 @@ export type ServiceInputTypes =
* @public
*/
export type ServiceOutputTypes =
| CancelExportTaskCommandOutput
| CancelImportTaskCommandOutput
| CancelQueryCommandOutput
| CreateGraphCommandOutput
Expand All @@ -167,12 +176,14 @@ export type ServiceOutputTypes =
| DeleteGraphSnapshotCommandOutput
| DeletePrivateGraphEndpointCommandOutput
| ExecuteQueryCommandOutput
| GetExportTaskCommandOutput
| GetGraphCommandOutput
| GetGraphSnapshotCommandOutput
| GetGraphSummaryCommandOutput
| GetImportTaskCommandOutput
| GetPrivateGraphEndpointCommandOutput
| GetQueryCommandOutput
| ListExportTasksCommandOutput
| ListGraphSnapshotsCommandOutput
| ListGraphsCommandOutput
| ListImportTasksCommandOutput
Expand All @@ -181,6 +192,7 @@ export type ServiceOutputTypes =
| ListTagsForResourceCommandOutput
| ResetGraphCommandOutput
| RestoreGraphFromSnapshotCommandOutput
| StartExportTaskCommandOutput
| StartImportTaskCommandOutput
| TagResourceCommandOutput
| UntagResourceCommandOutput
Expand Down
Loading

0 comments on commit 48054dc

Please sign in to comment.