/var/runtime/node_modules/@aws-sdk/client-neptunedata/dist-cjs
This explorer reads the filesystem of the server it runs on, so /workspace/user isn't present here. Browsing and the terminal still work against this server's own disk from /.
"use strict";var __defProp = Object.defineProperty;var __getOwnPropDesc = Object.getOwnPropertyDescriptor;var __getOwnPropNames = Object.getOwnPropertyNames;var __hasOwnProp = Object.prototype.hasOwnProperty;var __name = (target, value) => __defProp(target, "name", { value, configurable: true });var __export = (target, all) => { for (var name in all) __defProp(target, name, { get: all[name], enumerable: true });};var __copyProps = (to, from, except, desc) => { if (from && typeof from === "object" || typeof from === "function") { for (let key of __getOwnPropNames(from)) if (!__hasOwnProp.call(to, key) && key !== except) __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable }); } return to;};var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod); // src/index.tsvar index_exports = {};__export(index_exports, { AccessDeniedException: () => AccessDeniedException, Action: () => Action, BadRequestException: () => BadRequestException, BulkLoadIdNotFoundException: () => BulkLoadIdNotFoundException, CancelGremlinQueryCommand: () => CancelGremlinQueryCommand, CancelLoaderJobCommand: () => CancelLoaderJobCommand, CancelMLDataProcessingJobCommand: () => CancelMLDataProcessingJobCommand, CancelMLModelTrainingJobCommand: () => CancelMLModelTrainingJobCommand, CancelMLModelTransformJobCommand: () => CancelMLModelTransformJobCommand, CancelOpenCypherQueryCommand: () => CancelOpenCypherQueryCommand, CancelledByUserException: () => CancelledByUserException, ClientTimeoutException: () => ClientTimeoutException, ConcurrentModificationException: () => ConcurrentModificationException, ConstraintViolationException: () => ConstraintViolationException, CreateMLEndpointCommand: () => CreateMLEndpointCommand, DeleteMLEndpointCommand: () => DeleteMLEndpointCommand, DeletePropertygraphStatisticsCommand: () => DeletePropertygraphStatisticsCommand, DeleteSparqlStatisticsCommand: () => DeleteSparqlStatisticsCommand, Encoding: () => Encoding, ExecuteFastResetCommand: () => ExecuteFastResetCommand, ExecuteGremlinExplainQueryCommand: () => ExecuteGremlinExplainQueryCommand, ExecuteGremlinProfileQueryCommand: () => ExecuteGremlinProfileQueryCommand, ExecuteGremlinQueryCommand: () => ExecuteGremlinQueryCommand, ExecuteOpenCypherExplainQueryCommand: () => ExecuteOpenCypherExplainQueryCommand, ExecuteOpenCypherQueryCommand: () => ExecuteOpenCypherQueryCommand, ExpiredStreamException: () => ExpiredStreamException, FailureByQueryException: () => FailureByQueryException, Format: () => Format, GetEngineStatusCommand: () => GetEngineStatusCommand, GetGremlinQueryStatusCommand: () => GetGremlinQueryStatusCommand, GetLoaderJobStatusCommand: () => GetLoaderJobStatusCommand, GetMLDataProcessingJobCommand: () => GetMLDataProcessingJobCommand, GetMLEndpointCommand: () => GetMLEndpointCommand, GetMLModelTrainingJobCommand: () => GetMLModelTrainingJobCommand, GetMLModelTransformJobCommand: () => GetMLModelTransformJobCommand, GetOpenCypherQueryStatusCommand: () => GetOpenCypherQueryStatusCommand, GetPropertygraphStatisticsCommand: () => GetPropertygraphStatisticsCommand, GetPropertygraphStreamCommand: () => GetPropertygraphStreamCommand, GetPropertygraphSummaryCommand: () => GetPropertygraphSummaryCommand, GetRDFGraphSummaryCommand: () => GetRDFGraphSummaryCommand, GetSparqlStatisticsCommand: () => GetSparqlStatisticsCommand, GetSparqlStreamCommand: () => GetSparqlStreamCommand, GraphSummaryType: () => GraphSummaryType, IllegalArgumentException: () => IllegalArgumentException, InternalFailureException: () => InternalFailureException, InvalidArgumentException: () => InvalidArgumentException, InvalidNumericDataException: () => InvalidNumericDataException, InvalidParameterException: () => InvalidParameterException, IteratorType: () => IteratorType, ListGremlinQueriesCommand: () => ListGremlinQueriesCommand, ListLoaderJobsCommand: () => ListLoaderJobsCommand, ListMLDataProcessingJobsCommand: () => ListMLDataProcessingJobsCommand, ListMLEndpointsCommand: () => ListMLEndpointsCommand, ListMLModelTrainingJobsCommand: () => ListMLModelTrainingJobsCommand, ListMLModelTransformJobsCommand: () => ListMLModelTransformJobsCommand, ListOpenCypherQueriesCommand: () => ListOpenCypherQueriesCommand, LoadUrlAccessDeniedException: () => LoadUrlAccessDeniedException, MLResourceNotFoundException: () => MLResourceNotFoundException, MalformedQueryException: () => MalformedQueryException, ManagePropertygraphStatisticsCommand: () => ManagePropertygraphStatisticsCommand, ManageSparqlStatisticsCommand: () => ManageSparqlStatisticsCommand, MemoryLimitExceededException: () => MemoryLimitExceededException, MethodNotAllowedException: () => MethodNotAllowedException, MissingParameterException: () => MissingParameterException, Mode: () => Mode, Neptunedata: () => Neptunedata, NeptunedataClient: () => NeptunedataClient, NeptunedataServiceException: () => NeptunedataServiceException, OpenCypherExplainMode: () => OpenCypherExplainMode, Parallelism: () => Parallelism, ParsingException: () => ParsingException, PreconditionsFailedException: () => PreconditionsFailedException, QueryLimitExceededException: () => QueryLimitExceededException, QueryLimitException: () => QueryLimitException, QueryTooLargeException: () => QueryTooLargeException, ReadOnlyViolationException: () => ReadOnlyViolationException, S3BucketRegion: () => S3BucketRegion, S3Exception: () => S3Exception, ServerShutdownException: () => ServerShutdownException, StartLoaderJobCommand: () => StartLoaderJobCommand, StartMLDataProcessingJobCommand: () => StartMLDataProcessingJobCommand, StartMLModelTrainingJobCommand: () => StartMLModelTrainingJobCommand, StartMLModelTransformJobCommand: () => StartMLModelTransformJobCommand, StatisticsAutoGenerationMode: () => StatisticsAutoGenerationMode, StatisticsNotAvailableException: () => StatisticsNotAvailableException, StreamRecordsNotFoundException: () => StreamRecordsNotFoundException, ThrottlingException: () => ThrottlingException, TimeLimitExceededException: () => TimeLimitExceededException, TooManyRequestsException: () => TooManyRequestsException, UnsupportedOperationException: () => UnsupportedOperationException, __Client: () => import_smithy_client.Client});module.exports = __toCommonJS(index_exports); // src/NeptunedataClient.tsvar import_middleware_host_header = require("@aws-sdk/middleware-host-header");var import_middleware_logger = require("@aws-sdk/middleware-logger");var import_middleware_recursion_detection = require("@aws-sdk/middleware-recursion-detection");var import_middleware_user_agent = require("@aws-sdk/middleware-user-agent");var import_config_resolver = require("@smithy/config-resolver");var import_core = require("@smithy/core");var import_middleware_content_length = require("@smithy/middleware-content-length");var import_middleware_endpoint = require("@smithy/middleware-endpoint");var import_middleware_retry = require("@smithy/middleware-retry"); var import_httpAuthSchemeProvider = require("./auth/httpAuthSchemeProvider"); // src/endpoint/EndpointParameters.tsvar resolveClientEndpointParameters = /* @__PURE__ */ __name((options) => { return Object.assign(options, { useDualstackEndpoint: options.useDualstackEndpoint ?? false, useFipsEndpoint: options.useFipsEndpoint ?? false, defaultSigningName: "neptune-db" });}, "resolveClientEndpointParameters");var commonParams = { UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" }, Endpoint: { type: "builtInParams", name: "endpoint" }, Region: { type: "builtInParams", name: "region" }, UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }}; // src/NeptunedataClient.tsvar import_runtimeConfig = require("././runtimeConfig"); // src/runtimeExtensions.tsvar import_region_config_resolver = require("@aws-sdk/region-config-resolver");var import_protocol_http = require("@smithy/protocol-http");var import_smithy_client = require("@smithy/smithy-client"); // src/auth/httpAuthExtensionConfiguration.tsvar getHttpAuthExtensionConfiguration = /* @__PURE__ */ __name((runtimeConfig) => { const _httpAuthSchemes = runtimeConfig.httpAuthSchemes; let _httpAuthSchemeProvider = runtimeConfig.httpAuthSchemeProvider; let _credentials = runtimeConfig.credentials; return { setHttpAuthScheme(httpAuthScheme) { const index = _httpAuthSchemes.findIndex((scheme) => scheme.schemeId === httpAuthScheme.schemeId); if (index === -1) { _httpAuthSchemes.push(httpAuthScheme); } else { _httpAuthSchemes.splice(index, 1, httpAuthScheme); } }, httpAuthSchemes() { return _httpAuthSchemes; }, setHttpAuthSchemeProvider(httpAuthSchemeProvider) { _httpAuthSchemeProvider = httpAuthSchemeProvider; }, httpAuthSchemeProvider() { return _httpAuthSchemeProvider; }, setCredentials(credentials) { _credentials = credentials; }, credentials() { return _credentials; } };}, "getHttpAuthExtensionConfiguration");var resolveHttpAuthRuntimeConfig = /* @__PURE__ */ __name((config) => { return { httpAuthSchemes: config.httpAuthSchemes(), httpAuthSchemeProvider: config.httpAuthSchemeProvider(), credentials: config.credentials() };}, "resolveHttpAuthRuntimeConfig"); // src/runtimeExtensions.tsvar resolveRuntimeExtensions = /* @__PURE__ */ __name((runtimeConfig, extensions) => { const extensionConfiguration = Object.assign( (0, import_region_config_resolver.getAwsRegionExtensionConfiguration)(runtimeConfig), (0, import_smithy_client.getDefaultExtensionConfiguration)(runtimeConfig), (0, import_protocol_http.getHttpHandlerExtensionConfiguration)(runtimeConfig), getHttpAuthExtensionConfiguration(runtimeConfig) ); extensions.forEach((extension) => extension.configure(extensionConfiguration)); return Object.assign( runtimeConfig, (0, import_region_config_resolver.resolveAwsRegionExtensionConfiguration)(extensionConfiguration), (0, import_smithy_client.resolveDefaultRuntimeConfig)(extensionConfiguration), (0, import_protocol_http.resolveHttpHandlerRuntimeConfig)(extensionConfiguration), resolveHttpAuthRuntimeConfig(extensionConfiguration) );}, "resolveRuntimeExtensions"); // src/NeptunedataClient.tsvar NeptunedataClient = class extends import_smithy_client.Client { static { __name(this, "NeptunedataClient"); } /** * The resolved configuration of NeptunedataClient class. This is resolved and normalized from the {@link NeptunedataClientConfig | constructor configuration interface}. */ config; constructor(...[configuration]) { const _config_0 = (0, import_runtimeConfig.getRuntimeConfig)(configuration || {}); super(_config_0); this.initConfig = _config_0; const _config_1 = resolveClientEndpointParameters(_config_0); const _config_2 = (0, import_middleware_user_agent.resolveUserAgentConfig)(_config_1); const _config_3 = (0, import_middleware_retry.resolveRetryConfig)(_config_2); const _config_4 = (0, import_config_resolver.resolveRegionConfig)(_config_3); const _config_5 = (0, import_middleware_host_header.resolveHostHeaderConfig)(_config_4); const _config_6 = (0, import_middleware_endpoint.resolveEndpointConfig)(_config_5); const _config_7 = (0, import_httpAuthSchemeProvider.resolveHttpAuthSchemeConfig)(_config_6); const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []); this.config = _config_8; this.middlewareStack.use((0, import_middleware_user_agent.getUserAgentPlugin)(this.config)); this.middlewareStack.use((0, import_middleware_retry.getRetryPlugin)(this.config)); this.middlewareStack.use((0, import_middleware_content_length.getContentLengthPlugin)(this.config)); this.middlewareStack.use((0, import_middleware_host_header.getHostHeaderPlugin)(this.config)); this.middlewareStack.use((0, import_middleware_logger.getLoggerPlugin)(this.config)); this.middlewareStack.use((0, import_middleware_recursion_detection.getRecursionDetectionPlugin)(this.config)); this.middlewareStack.use( (0, import_core.getHttpAuthSchemeEndpointRuleSetPlugin)(this.config, { httpAuthSchemeParametersProvider: import_httpAuthSchemeProvider.defaultNeptunedataHttpAuthSchemeParametersProvider, identityProviderConfigProvider: /* @__PURE__ */ __name(async (config) => new import_core.DefaultIdentityProviderConfig({ "aws.auth#sigv4": config.credentials }), "identityProviderConfigProvider") }) ); this.middlewareStack.use((0, import_core.getHttpSigningPlugin)(this.config)); } /** * Destroy underlying resources, like sockets. It's usually not necessary to do this. * However in Node.js, it's best to explicitly shut down the client's agent when it is no longer needed. * Otherwise, sockets might stay open for quite a long time before the server terminates them. */ destroy() { super.destroy(); }}; // src/Neptunedata.ts // src/commands/CancelGremlinQueryCommand.ts var import_middleware_serde = require("@smithy/middleware-serde"); // src/protocols/Aws_restJson1.tsvar import_core2 = require("@aws-sdk/core"); // src/models/NeptunedataServiceException.ts var NeptunedataServiceException = class _NeptunedataServiceException extends import_smithy_client.ServiceException { static { __name(this, "NeptunedataServiceException"); } /** * @internal */ constructor(options) { super(options); Object.setPrototypeOf(this, _NeptunedataServiceException.prototype); }}; // src/models/models_0.tsvar AccessDeniedException = class _AccessDeniedException extends NeptunedataServiceException { static { __name(this, "AccessDeniedException"); } name = "AccessDeniedException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "AccessDeniedException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _AccessDeniedException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var Action = { INITIALIZE_RESET: "initiateDatabaseReset", PERFORM_RESET: "performDatabaseReset"};var BadRequestException = class _BadRequestException extends NeptunedataServiceException { static { __name(this, "BadRequestException"); } name = "BadRequestException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the bad request.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "BadRequestException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _BadRequestException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var ClientTimeoutException = class _ClientTimeoutException extends NeptunedataServiceException { static { __name(this, "ClientTimeoutException"); } name = "ClientTimeoutException"; $fault = "client"; $retryable = {}; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "ClientTimeoutException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _ClientTimeoutException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var ConcurrentModificationException = class _ConcurrentModificationException extends NeptunedataServiceException { static { __name(this, "ConcurrentModificationException"); } name = "ConcurrentModificationException"; $fault = "server"; $retryable = {}; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "ConcurrentModificationException", $fault: "server", ...opts }); Object.setPrototypeOf(this, _ConcurrentModificationException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var ConstraintViolationException = class _ConstraintViolationException extends NeptunedataServiceException { static { __name(this, "ConstraintViolationException"); } name = "ConstraintViolationException"; $fault = "client"; $retryable = {}; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "ConstraintViolationException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _ConstraintViolationException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var FailureByQueryException = class _FailureByQueryException extends NeptunedataServiceException { static { __name(this, "FailureByQueryException"); } name = "FailureByQueryException"; $fault = "server"; $retryable = {}; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "FailureByQueryException", $fault: "server", ...opts }); Object.setPrototypeOf(this, _FailureByQueryException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var IllegalArgumentException = class _IllegalArgumentException extends NeptunedataServiceException { static { __name(this, "IllegalArgumentException"); } name = "IllegalArgumentException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "IllegalArgumentException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _IllegalArgumentException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var InvalidArgumentException = class _InvalidArgumentException extends NeptunedataServiceException { static { __name(this, "InvalidArgumentException"); } name = "InvalidArgumentException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "InvalidArgumentException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _InvalidArgumentException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var InvalidParameterException = class _InvalidParameterException extends NeptunedataServiceException { static { __name(this, "InvalidParameterException"); } name = "InvalidParameterException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request that includes an invalid parameter.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "InvalidParameterException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _InvalidParameterException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var MissingParameterException = class _MissingParameterException extends NeptunedataServiceException { static { __name(this, "MissingParameterException"); } name = "MissingParameterException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in which the parameter is missing.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "MissingParameterException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _MissingParameterException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var ParsingException = class _ParsingException extends NeptunedataServiceException { static { __name(this, "ParsingException"); } name = "ParsingException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "ParsingException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _ParsingException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var PreconditionsFailedException = class _PreconditionsFailedException extends NeptunedataServiceException { static { __name(this, "PreconditionsFailedException"); } name = "PreconditionsFailedException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "PreconditionsFailedException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _PreconditionsFailedException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var TimeLimitExceededException = class _TimeLimitExceededException extends NeptunedataServiceException { static { __name(this, "TimeLimitExceededException"); } name = "TimeLimitExceededException"; $fault = "server"; $retryable = {}; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request that could not be processed for this reason.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "TimeLimitExceededException", $fault: "server", ...opts }); Object.setPrototypeOf(this, _TimeLimitExceededException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var TooManyRequestsException = class _TooManyRequestsException extends NeptunedataServiceException { static { __name(this, "TooManyRequestsException"); } name = "TooManyRequestsException"; $fault = "client"; $retryable = {}; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request that could not be processed for this reason.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "TooManyRequestsException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _TooManyRequestsException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var UnsupportedOperationException = class _UnsupportedOperationException extends NeptunedataServiceException { static { __name(this, "UnsupportedOperationException"); } name = "UnsupportedOperationException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "UnsupportedOperationException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _UnsupportedOperationException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var BulkLoadIdNotFoundException = class _BulkLoadIdNotFoundException extends NeptunedataServiceException { static { __name(this, "BulkLoadIdNotFoundException"); } name = "BulkLoadIdNotFoundException"; $fault = "client"; $retryable = {}; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The bulk-load job ID that could not be found.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "BulkLoadIdNotFoundException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _BulkLoadIdNotFoundException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var InternalFailureException = class _InternalFailureException extends NeptunedataServiceException { static { __name(this, "InternalFailureException"); } name = "InternalFailureException"; $fault = "server"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "InternalFailureException", $fault: "server", ...opts }); Object.setPrototypeOf(this, _InternalFailureException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var LoadUrlAccessDeniedException = class _LoadUrlAccessDeniedException extends NeptunedataServiceException { static { __name(this, "LoadUrlAccessDeniedException"); } name = "LoadUrlAccessDeniedException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "LoadUrlAccessDeniedException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _LoadUrlAccessDeniedException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var MLResourceNotFoundException = class _MLResourceNotFoundException extends NeptunedataServiceException { static { __name(this, "MLResourceNotFoundException"); } name = "MLResourceNotFoundException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "MLResourceNotFoundException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _MLResourceNotFoundException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var InvalidNumericDataException = class _InvalidNumericDataException extends NeptunedataServiceException { static { __name(this, "InvalidNumericDataException"); } name = "InvalidNumericDataException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "InvalidNumericDataException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _InvalidNumericDataException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var ReadOnlyViolationException = class _ReadOnlyViolationException extends NeptunedataServiceException { static { __name(this, "ReadOnlyViolationException"); } name = "ReadOnlyViolationException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in which the parameter is missing.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "ReadOnlyViolationException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _ReadOnlyViolationException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var StatisticsNotAvailableException = class _StatisticsNotAvailableException extends NeptunedataServiceException { static { __name(this, "StatisticsNotAvailableException"); } name = "StatisticsNotAvailableException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "StatisticsNotAvailableException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _StatisticsNotAvailableException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var MethodNotAllowedException = class _MethodNotAllowedException extends NeptunedataServiceException { static { __name(this, "MethodNotAllowedException"); } name = "MethodNotAllowedException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "MethodNotAllowedException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _MethodNotAllowedException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var ServerShutdownException = class _ServerShutdownException extends NeptunedataServiceException { static { __name(this, "ServerShutdownException"); } name = "ServerShutdownException"; $fault = "server"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "ServerShutdownException", $fault: "server", ...opts }); Object.setPrototypeOf(this, _ServerShutdownException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var CancelledByUserException = class _CancelledByUserException extends NeptunedataServiceException { static { __name(this, "CancelledByUserException"); } name = "CancelledByUserException"; $fault = "server"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "CancelledByUserException", $fault: "server", ...opts }); Object.setPrototypeOf(this, _CancelledByUserException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var MalformedQueryException = class _MalformedQueryException extends NeptunedataServiceException { static { __name(this, "MalformedQueryException"); } name = "MalformedQueryException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the malformed query request.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "MalformedQueryException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _MalformedQueryException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var MemoryLimitExceededException = class _MemoryLimitExceededException extends NeptunedataServiceException { static { __name(this, "MemoryLimitExceededException"); } name = "MemoryLimitExceededException"; $fault = "server"; $retryable = {}; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request that failed.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "MemoryLimitExceededException", $fault: "server", ...opts }); Object.setPrototypeOf(this, _MemoryLimitExceededException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var QueryLimitExceededException = class _QueryLimitExceededException extends NeptunedataServiceException { static { __name(this, "QueryLimitExceededException"); } name = "QueryLimitExceededException"; $fault = "server"; $retryable = {}; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request which exceeded the limit.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "QueryLimitExceededException", $fault: "server", ...opts }); Object.setPrototypeOf(this, _QueryLimitExceededException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var QueryLimitException = class _QueryLimitException extends NeptunedataServiceException { static { __name(this, "QueryLimitException"); } name = "QueryLimitException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request that exceeded the limit.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "QueryLimitException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _QueryLimitException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var QueryTooLargeException = class _QueryTooLargeException extends NeptunedataServiceException { static { __name(this, "QueryTooLargeException"); } name = "QueryTooLargeException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request that is too large.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "QueryTooLargeException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _QueryTooLargeException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var OpenCypherExplainMode = { DETAILS: "details", DYNAMIC: "dynamic", STATIC: "static"};var ExpiredStreamException = class _ExpiredStreamException extends NeptunedataServiceException { static { __name(this, "ExpiredStreamException"); } name = "ExpiredStreamException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "ExpiredStreamException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _ExpiredStreamException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var Encoding = { GZIP: "gzip"};var IteratorType = { AFTER_SEQUENCE_NUMBER: "AFTER_SEQUENCE_NUMBER", AT_SEQUENCE_NUMBER: "AT_SEQUENCE_NUMBER", LATEST: "LATEST", TRIM_HORIZON: "TRIM_HORIZON"};var StreamRecordsNotFoundException = class _StreamRecordsNotFoundException extends NeptunedataServiceException { static { __name(this, "StreamRecordsNotFoundException"); } name = "StreamRecordsNotFoundException"; $fault = "client"; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "StreamRecordsNotFoundException", $fault: "client", ...opts }); Object.setPrototypeOf(this, _StreamRecordsNotFoundException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var ThrottlingException = class _ThrottlingException extends NeptunedataServiceException { static { __name(this, "ThrottlingException"); } name = "ThrottlingException"; $fault = "server"; $retryable = {}; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request that could not be processed for this reason.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "ThrottlingException", $fault: "server", ...opts }); Object.setPrototypeOf(this, _ThrottlingException.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var GraphSummaryType = { BASIC: "basic", DETAILED: "detailed"};var StatisticsAutoGenerationMode = { DISABLE_AUTOCOMPUTE: "disableAutoCompute", ENABLE_AUTOCOMPUTE: "enableAutoCompute", REFRESH: "refresh"};var S3Exception = class _S3Exception extends NeptunedataServiceException { static { __name(this, "S3Exception"); } name = "S3Exception"; $fault = "client"; $retryable = {}; /** * <p>A detailed message describing the problem.</p> * @public */ detailedMessage; /** * <p>The ID of the request in question.</p> * @public */ requestId; /** * <p>The HTTP status code returned with the exception.</p> * @public */ code; /** * @internal */ constructor(opts) { super({ name: "S3Exception", $fault: "client", ...opts }); Object.setPrototypeOf(this, _S3Exception.prototype); this.detailedMessage = opts.detailedMessage; this.requestId = opts.requestId; this.code = opts.code; }};var Format = { CSV: "csv", NQUADS: "nquads", NTRIPLES: "ntriples", OPENCYPHER: "opencypher", RDFXML: "rdfxml", TURTLE: "turtle"};var Mode = { AUTO: "AUTO", NEW: "NEW", RESUME: "RESUME"};var Parallelism = { HIGH: "HIGH", LOW: "LOW", MEDIUM: "MEDIUM", OVERSUBSCRIBE: "OVERSUBSCRIBE"};var S3BucketRegion = { AF_SOUTH_1: "af-south-1", AP_EAST_1: "ap-east-1", AP_EAST_2: "ap-east-2", AP_NORTHEAST_1: "ap-northeast-1", AP_NORTHEAST_2: "ap-northeast-2", AP_NORTHEAST_3: "ap-northeast-3", AP_SOUTHEAST_1: "ap-southeast-1", AP_SOUTHEAST_2: "ap-southeast-2", AP_SOUTHEAST_3: "ap-southeast-3", AP_SOUTHEAST_4: "ap-southeast-4", AP_SOUTHEAST_5: "ap-southeast-5", AP_SOUTHEAST_7: "ap-southeast-7", AP_SOUTH_1: "ap-south-1", AP_SOUTH_2: "ap-south-2", CA_CENTRAL_1: "ca-central-1", CA_WEST_1: "ca-west-1", CN_NORTHWEST_1: "cn-northwest-1", CN_NORTH_1: "cn-north-1", EU_CENTRAL_1: "eu-central-1", EU_CENTRAL_2: "eu-central-2", EU_NORTH_1: "eu-north-1", EU_SOUTH_2: "eu-south-2", EU_WEST_1: "eu-west-1", EU_WEST_2: "eu-west-2", EU_WEST_3: "eu-west-3", IL_CENTRAL_1: "il-central-1", ME_CENTRAL_1: "me-central-1", ME_SOUTH_1: "me-south-1", MX_CENTRAL_1: "mx-central-1", SA_EAST_1: "sa-east-1", US_EAST_1: "us-east-1", US_EAST_2: "us-east-2", US_GOV_EAST_1: "us-gov-east-1", US_GOV_WEST_1: "us-gov-west-1", US_WEST_1: "us-west-1", US_WEST_2: "us-west-2"}; // src/protocols/Aws_restJson1.tsvar se_CancelGremlinQueryCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/gremlin/status/{queryId}"); b.p("queryId", () => input.queryId, "{queryId}", false); let body; b.m("DELETE").h(headers).b(body); return b.build();}, "se_CancelGremlinQueryCommand");var se_CancelLoaderJobCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/loader/{loadId}"); b.p("loadId", () => input.loadId, "{loadId}", false); let body; b.m("DELETE").h(headers).b(body); return b.build();}, "se_CancelLoaderJobCommand");var se_CancelMLDataProcessingJobCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/dataprocessing/{id}"); b.p("id", () => input.id, "{id}", false); const query = (0, import_smithy_client.map)({ [_nIRA]: [, input[_nIRA]], [_c]: [() => input.clean !== void 0, () => input[_c].toString()] }); let body; b.m("DELETE").h(headers).q(query).b(body); return b.build();}, "se_CancelMLDataProcessingJobCommand");var se_CancelMLModelTrainingJobCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/modeltraining/{id}"); b.p("id", () => input.id, "{id}", false); const query = (0, import_smithy_client.map)({ [_nIRA]: [, input[_nIRA]], [_c]: [() => input.clean !== void 0, () => input[_c].toString()] }); let body; b.m("DELETE").h(headers).q(query).b(body); return b.build();}, "se_CancelMLModelTrainingJobCommand");var se_CancelMLModelTransformJobCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/modeltransform/{id}"); b.p("id", () => input.id, "{id}", false); const query = (0, import_smithy_client.map)({ [_nIRA]: [, input[_nIRA]], [_c]: [() => input.clean !== void 0, () => input[_c].toString()] }); let body; b.m("DELETE").h(headers).q(query).b(body); return b.build();}, "se_CancelMLModelTransformJobCommand");var se_CancelOpenCypherQueryCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/opencypher/status/{queryId}"); b.p("queryId", () => input.queryId, "{queryId}", false); const query = (0, import_smithy_client.map)({ [_s]: [() => input.silent !== void 0, () => input[_s].toString()] }); let body; b.m("DELETE").h(headers).q(query).b(body); return b.build();}, "se_CancelOpenCypherQueryCommand");var se_CreateMLEndpointCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/ml/endpoints"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { id: [], instanceCount: [], instanceType: [], mlModelTrainingJobId: [], mlModelTransformJobId: [], modelName: [], neptuneIamRoleArn: [], update: [], volumeEncryptionKMSKey: [] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_CreateMLEndpointCommand");var se_DeleteMLEndpointCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/endpoints/{id}"); b.p("id", () => input.id, "{id}", false); const query = (0, import_smithy_client.map)({ [_nIRA]: [, input[_nIRA]], [_c]: [() => input.clean !== void 0, () => input[_c].toString()] }); let body; b.m("DELETE").h(headers).q(query).b(body); return b.build();}, "se_DeleteMLEndpointCommand");var se_DeletePropertygraphStatisticsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/propertygraph/statistics"); let body; b.m("DELETE").h(headers).b(body); return b.build();}, "se_DeletePropertygraphStatisticsCommand");var se_DeleteSparqlStatisticsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/sparql/statistics"); let body; b.m("DELETE").h(headers).b(body); return b.build();}, "se_DeleteSparqlStatisticsCommand");var se_ExecuteFastResetCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/system"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { action: [], token: [] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_ExecuteFastResetCommand");var se_ExecuteGremlinExplainQueryCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/gremlin/explain"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { gremlin: [, , `gremlinQuery`] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_ExecuteGremlinExplainQueryCommand");var se_ExecuteGremlinProfileQueryCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/gremlin/profile"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { "profile.chop": [, , `chop`], gremlin: [, , `gremlinQuery`], "profile.indexOps": [, , `indexOps`], "profile.results": [, , `results`], "profile.serializer": [, , `serializer`] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_ExecuteGremlinProfileQueryCommand");var se_ExecuteGremlinQueryCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = (0, import_smithy_client.map)({}, import_smithy_client.isSerializableHeaderValue, { "content-type": "application/json", [_a]: input[_se] }); b.bp("/gremlin"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { gremlin: [, , `gremlinQuery`] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_ExecuteGremlinQueryCommand");var se_ExecuteOpenCypherExplainQueryCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/opencypher/explain"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { explain: [, , `explainMode`], query: [, , `openCypherQuery`], parameters: [] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_ExecuteOpenCypherExplainQueryCommand");var se_ExecuteOpenCypherQueryCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/opencypher"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { query: [, , `openCypherQuery`], parameters: [] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_ExecuteOpenCypherQueryCommand");var se_GetEngineStatusCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/status"); let body; b.m("GET").h(headers).b(body); return b.build();}, "se_GetEngineStatusCommand");var se_GetGremlinQueryStatusCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/gremlin/status/{queryId}"); b.p("queryId", () => input.queryId, "{queryId}", false); let body; b.m("GET").h(headers).b(body); return b.build();}, "se_GetGremlinQueryStatusCommand");var se_GetLoaderJobStatusCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/loader/{loadId}"); b.p("loadId", () => input.loadId, "{loadId}", false); const query = (0, import_smithy_client.map)({ [_d]: [() => input.details !== void 0, () => input[_d].toString()], [_e]: [() => input.errors !== void 0, () => input[_e].toString()], [_p]: [() => input.page !== void 0, () => input[_p].toString()], [_ePP]: [() => input.errorsPerPage !== void 0, () => input[_ePP].toString()] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_GetLoaderJobStatusCommand");var se_GetMLDataProcessingJobCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/dataprocessing/{id}"); b.p("id", () => input.id, "{id}", false); const query = (0, import_smithy_client.map)({ [_nIRA]: [, input[_nIRA]] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_GetMLDataProcessingJobCommand");var se_GetMLEndpointCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/endpoints/{id}"); b.p("id", () => input.id, "{id}", false); const query = (0, import_smithy_client.map)({ [_nIRA]: [, input[_nIRA]] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_GetMLEndpointCommand");var se_GetMLModelTrainingJobCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/modeltraining/{id}"); b.p("id", () => input.id, "{id}", false); const query = (0, import_smithy_client.map)({ [_nIRA]: [, input[_nIRA]] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_GetMLModelTrainingJobCommand");var se_GetMLModelTransformJobCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/modeltransform/{id}"); b.p("id", () => input.id, "{id}", false); const query = (0, import_smithy_client.map)({ [_nIRA]: [, input[_nIRA]] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_GetMLModelTransformJobCommand");var se_GetOpenCypherQueryStatusCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/opencypher/status/{queryId}"); b.p("queryId", () => input.queryId, "{queryId}", false); let body; b.m("GET").h(headers).b(body); return b.build();}, "se_GetOpenCypherQueryStatusCommand");var se_GetPropertygraphStatisticsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/propertygraph/statistics"); let body; b.m("GET").h(headers).b(body); return b.build();}, "se_GetPropertygraphStatisticsCommand");var se_GetPropertygraphStreamCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = (0, import_smithy_client.map)({}, import_smithy_client.isSerializableHeaderValue, { [_ae]: input[_en] }); b.bp("/propertygraph/stream"); const query = (0, import_smithy_client.map)({ [_l]: [() => input.limit !== void 0, () => input[_l].toString()], [_iT]: [, input[_iT]], [_cN]: [() => input.commitNum !== void 0, () => input[_cN].toString()], [_oN]: [() => input.opNum !== void 0, () => input[_oN].toString()] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_GetPropertygraphStreamCommand");var se_GetPropertygraphSummaryCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/propertygraph/statistics/summary"); const query = (0, import_smithy_client.map)({ [_m]: [, input[_m]] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_GetPropertygraphSummaryCommand");var se_GetRDFGraphSummaryCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/rdf/statistics/summary"); const query = (0, import_smithy_client.map)({ [_m]: [, input[_m]] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_GetRDFGraphSummaryCommand");var se_GetSparqlStatisticsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/sparql/statistics"); let body; b.m("GET").h(headers).b(body); return b.build();}, "se_GetSparqlStatisticsCommand");var se_GetSparqlStreamCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = (0, import_smithy_client.map)({}, import_smithy_client.isSerializableHeaderValue, { [_ae]: input[_en] }); b.bp("/sparql/stream"); const query = (0, import_smithy_client.map)({ [_l]: [() => input.limit !== void 0, () => input[_l].toString()], [_iT]: [, input[_iT]], [_cN]: [() => input.commitNum !== void 0, () => input[_cN].toString()], [_oN]: [() => input.opNum !== void 0, () => input[_oN].toString()] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_GetSparqlStreamCommand");var se_ListGremlinQueriesCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/gremlin/status"); const query = (0, import_smithy_client.map)({ [_iW]: [() => input.includeWaiting !== void 0, () => input[_iW].toString()] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_ListGremlinQueriesCommand");var se_ListLoaderJobsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/loader"); const query = (0, import_smithy_client.map)({ [_l]: [() => input.limit !== void 0, () => input[_l].toString()], [_iQL]: [() => input.includeQueuedLoads !== void 0, () => input[_iQL].toString()] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_ListLoaderJobsCommand");var se_ListMLDataProcessingJobsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/dataprocessing"); const query = (0, import_smithy_client.map)({ [_mI]: [() => input.maxItems !== void 0, () => input[_mI].toString()], [_nIRA]: [, input[_nIRA]] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_ListMLDataProcessingJobsCommand");var se_ListMLEndpointsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/endpoints"); const query = (0, import_smithy_client.map)({ [_mI]: [() => input.maxItems !== void 0, () => input[_mI].toString()], [_nIRA]: [, input[_nIRA]] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_ListMLEndpointsCommand");var se_ListMLModelTrainingJobsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/modeltraining"); const query = (0, import_smithy_client.map)({ [_mI]: [() => input.maxItems !== void 0, () => input[_mI].toString()], [_nIRA]: [, input[_nIRA]] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_ListMLModelTrainingJobsCommand");var se_ListMLModelTransformJobsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/ml/modeltransform"); const query = (0, import_smithy_client.map)({ [_mI]: [() => input.maxItems !== void 0, () => input[_mI].toString()], [_nIRA]: [, input[_nIRA]] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_ListMLModelTransformJobsCommand");var se_ListOpenCypherQueriesCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = {}; b.bp("/opencypher/status"); const query = (0, import_smithy_client.map)({ [_iW]: [() => input.includeWaiting !== void 0, () => input[_iW].toString()] }); let body; b.m("GET").h(headers).q(query).b(body); return b.build();}, "se_ListOpenCypherQueriesCommand");var se_ManagePropertygraphStatisticsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/propertygraph/statistics"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { mode: [] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_ManagePropertygraphStatisticsCommand");var se_ManageSparqlStatisticsCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/sparql/statistics"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { mode: [] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_ManageSparqlStatisticsCommand");var se_StartLoaderJobCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/loader"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { dependencies: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "dependencies"), failOnError: [], format: [], iamRoleArn: [], mode: [], parallelism: [], parserConfiguration: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "parserConfiguration"), queueRequest: [], region: [, , `s3BucketRegion`], source: [], updateSingleCardinalityProperties: [], userProvidedEdgeIds: [] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_StartLoaderJobCommand");var se_StartMLDataProcessingJobCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/ml/dataprocessing"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { configFileName: [], id: [], inputDataS3Location: [], modelType: [], neptuneIamRoleArn: [], previousDataProcessingJobId: [], processedDataS3Location: [], processingInstanceType: [], processingInstanceVolumeSizeInGB: [], processingTimeOutInSeconds: [], s3OutputEncryptionKMSKey: [], sagemakerIamRoleArn: [], securityGroupIds: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "securityGroupIds"), subnets: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "subnets"), volumeEncryptionKMSKey: [] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_StartMLDataProcessingJobCommand");var se_StartMLModelTrainingJobCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/ml/modeltraining"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { baseProcessingInstanceType: [], customModelTrainingParameters: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "customModelTrainingParameters"), dataProcessingJobId: [], enableManagedSpotTraining: [], id: [], maxHPONumberOfTrainingJobs: [], maxHPOParallelTrainingJobs: [], neptuneIamRoleArn: [], previousModelTrainingJobId: [], s3OutputEncryptionKMSKey: [], sagemakerIamRoleArn: [], securityGroupIds: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "securityGroupIds"), subnets: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "subnets"), trainModelS3Location: [], trainingInstanceType: [], trainingInstanceVolumeSizeInGB: [], trainingTimeOutInSeconds: [], volumeEncryptionKMSKey: [] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_StartMLModelTrainingJobCommand");var se_StartMLModelTransformJobCommand = /* @__PURE__ */ __name(async (input, context) => { const b = (0, import_core.requestBuilder)(input, context); const headers = { "content-type": "application/json" }; b.bp("/ml/modeltransform"); let body; body = JSON.stringify( (0, import_smithy_client.take)(input, { baseProcessingInstanceType: [], baseProcessingInstanceVolumeSizeInGB: [], customModelTransformParameters: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "customModelTransformParameters"), dataProcessingJobId: [], id: [], mlModelTrainingJobId: [], modelTransformOutputS3Location: [], neptuneIamRoleArn: [], s3OutputEncryptionKMSKey: [], sagemakerIamRoleArn: [], securityGroupIds: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "securityGroupIds"), subnets: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "subnets"), trainingJobName: [], volumeEncryptionKMSKey: [] }) ); b.m("POST").h(headers).b(body); return b.build();}, "se_StartMLModelTransformJobCommand");var de_CancelGremlinQueryCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_CancelGremlinQueryCommand");var de_CancelLoaderJobCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_CancelLoaderJobCommand");var de_CancelMLDataProcessingJobCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_CancelMLDataProcessingJobCommand");var de_CancelMLModelTrainingJobCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_CancelMLModelTrainingJobCommand");var de_CancelMLModelTransformJobCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_CancelMLModelTransformJobCommand");var de_CancelOpenCypherQueryCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: import_smithy_client.expectBoolean, status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_CancelOpenCypherQueryCommand");var de_CreateMLEndpointCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { arn: import_smithy_client.expectString, creationTimeInMillis: import_smithy_client.expectLong, id: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_CreateMLEndpointCommand");var de_DeleteMLEndpointCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_DeleteMLEndpointCommand");var de_DeletePropertygraphStatisticsCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: import_smithy_client._json, status: import_smithy_client.expectString }); Object.assign(contents, doc); (0, import_smithy_client.map)(contents, { statusCode: [, output.statusCode] }); return contents;}, "de_DeletePropertygraphStatisticsCommand");var de_DeleteSparqlStatisticsCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: import_smithy_client._json, status: import_smithy_client.expectString }); Object.assign(contents, doc); (0, import_smithy_client.map)(contents, { statusCode: [, output.statusCode] }); return contents;}, "de_DeleteSparqlStatisticsCommand");var de_ExecuteFastResetCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: import_smithy_client._json, status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_ExecuteFastResetCommand");var de_ExecuteGremlinExplainQueryCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = await (0, import_smithy_client.collectBody)(output.body, context); contents.output = data; return contents;}, "de_ExecuteGremlinExplainQueryCommand");var de_ExecuteGremlinProfileQueryCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = await (0, import_smithy_client.collectBody)(output.body, context); contents.output = data; return contents;}, "de_ExecuteGremlinProfileQueryCommand");var de_ExecuteGremlinQueryCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { meta: /* @__PURE__ */ __name((_) => de_Document(_, context), "meta"), requestId: import_smithy_client.expectString, result: /* @__PURE__ */ __name((_) => de_Document(_, context), "result"), status: /* @__PURE__ */ __name((_) => de_GremlinQueryStatusAttributes(_, context), "status") }); Object.assign(contents, doc); return contents;}, "de_ExecuteGremlinQueryCommand");var de_ExecuteOpenCypherExplainQueryCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = await (0, import_smithy_client.collectBody)(output.body, context); contents.results = data; return contents;}, "de_ExecuteOpenCypherExplainQueryCommand");var de_ExecuteOpenCypherQueryCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { results: /* @__PURE__ */ __name((_) => de_Document(_, context), "results") }); Object.assign(contents, doc); return contents;}, "de_ExecuteOpenCypherQueryCommand");var de_GetEngineStatusCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { dbEngineVersion: import_smithy_client.expectString, dfeQueryEngine: import_smithy_client.expectString, features: /* @__PURE__ */ __name((_) => de_DocumentValuedMap(_, context), "features"), gremlin: import_smithy_client._json, labMode: import_smithy_client._json, opencypher: import_smithy_client._json, role: import_smithy_client.expectString, rollingBackTrxCount: import_smithy_client.expectInt32, rollingBackTrxEarliestStartTime: import_smithy_client.expectString, settings: import_smithy_client._json, sparql: import_smithy_client._json, startTime: import_smithy_client.expectString, status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_GetEngineStatusCommand");var de_GetGremlinQueryStatusCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { queryEvalStats: /* @__PURE__ */ __name((_) => de_QueryEvalStats(_, context), "queryEvalStats"), queryId: import_smithy_client.expectString, queryString: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_GetGremlinQueryStatusCommand");var de_GetLoaderJobStatusCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: /* @__PURE__ */ __name((_) => de_Document(_, context), "payload"), status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_GetLoaderJobStatusCommand");var de_GetMLDataProcessingJobCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { id: import_smithy_client.expectString, processingJob: import_smithy_client._json, status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_GetMLDataProcessingJobCommand");var de_GetMLEndpointCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { endpoint: import_smithy_client._json, endpointConfig: import_smithy_client._json, id: import_smithy_client.expectString, status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_GetMLEndpointCommand");var de_GetMLModelTrainingJobCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { hpoJob: import_smithy_client._json, id: import_smithy_client.expectString, mlModels: import_smithy_client._json, modelTransformJob: import_smithy_client._json, processingJob: import_smithy_client._json, status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_GetMLModelTrainingJobCommand");var de_GetMLModelTransformJobCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { baseProcessingJob: import_smithy_client._json, id: import_smithy_client.expectString, models: import_smithy_client._json, remoteModelTransformJob: import_smithy_client._json, status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_GetMLModelTransformJobCommand");var de_GetOpenCypherQueryStatusCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { queryEvalStats: /* @__PURE__ */ __name((_) => de_QueryEvalStats(_, context), "queryEvalStats"), queryId: import_smithy_client.expectString, queryString: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_GetOpenCypherQueryStatusCommand");var de_GetPropertygraphStatisticsCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: /* @__PURE__ */ __name((_) => de_Statistics(_, context), "payload"), status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_GetPropertygraphStatisticsCommand");var de_GetPropertygraphStreamCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { format: import_smithy_client.expectString, lastEventId: import_smithy_client._json, lastTrxTimestampInMillis: [, import_smithy_client.expectLong, `lastTrxTimestamp`], records: /* @__PURE__ */ __name((_) => de_PropertygraphRecordsList(_, context), "records"), totalRecords: import_smithy_client.expectInt32 }); Object.assign(contents, doc); return contents;}, "de_GetPropertygraphStreamCommand");var de_GetPropertygraphSummaryCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: /* @__PURE__ */ __name((_) => de_PropertygraphSummaryValueMap(_, context), "payload") }); Object.assign(contents, doc); (0, import_smithy_client.map)(contents, { statusCode: [, output.statusCode] }); return contents;}, "de_GetPropertygraphSummaryCommand");var de_GetRDFGraphSummaryCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: /* @__PURE__ */ __name((_) => de_RDFGraphSummaryValueMap(_, context), "payload") }); Object.assign(contents, doc); (0, import_smithy_client.map)(contents, { statusCode: [, output.statusCode] }); return contents;}, "de_GetRDFGraphSummaryCommand");var de_GetSparqlStatisticsCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: /* @__PURE__ */ __name((_) => de_Statistics(_, context), "payload"), status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_GetSparqlStatisticsCommand");var de_GetSparqlStreamCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { format: import_smithy_client.expectString, lastEventId: import_smithy_client._json, lastTrxTimestampInMillis: [, import_smithy_client.expectLong, `lastTrxTimestamp`], records: /* @__PURE__ */ __name((_) => de_SparqlRecordsList(_, context), "records"), totalRecords: import_smithy_client.expectInt32 }); Object.assign(contents, doc); return contents;}, "de_GetSparqlStreamCommand");var de_ListGremlinQueriesCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { acceptedQueryCount: import_smithy_client.expectInt32, queries: /* @__PURE__ */ __name((_) => de_GremlinQueries(_, context), "queries"), runningQueryCount: import_smithy_client.expectInt32 }); Object.assign(contents, doc); return contents;}, "de_ListGremlinQueriesCommand");var de_ListLoaderJobsCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: import_smithy_client._json, status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_ListLoaderJobsCommand");var de_ListMLDataProcessingJobsCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { ids: import_smithy_client._json }); Object.assign(contents, doc); return contents;}, "de_ListMLDataProcessingJobsCommand");var de_ListMLEndpointsCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { ids: import_smithy_client._json }); Object.assign(contents, doc); return contents;}, "de_ListMLEndpointsCommand");var de_ListMLModelTrainingJobsCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { ids: import_smithy_client._json }); Object.assign(contents, doc); return contents;}, "de_ListMLModelTrainingJobsCommand");var de_ListMLModelTransformJobsCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { ids: import_smithy_client._json }); Object.assign(contents, doc); return contents;}, "de_ListMLModelTransformJobsCommand");var de_ListOpenCypherQueriesCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { acceptedQueryCount: import_smithy_client.expectInt32, queries: /* @__PURE__ */ __name((_) => de_OpenCypherQueries(_, context), "queries"), runningQueryCount: import_smithy_client.expectInt32 }); Object.assign(contents, doc); return contents;}, "de_ListOpenCypherQueriesCommand");var de_ManagePropertygraphStatisticsCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: import_smithy_client._json, status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_ManagePropertygraphStatisticsCommand");var de_ManageSparqlStatisticsCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: import_smithy_client._json, status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_ManageSparqlStatisticsCommand");var de_StartLoaderJobCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { payload: import_smithy_client._json, status: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_StartLoaderJobCommand");var de_StartMLDataProcessingJobCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { arn: import_smithy_client.expectString, creationTimeInMillis: import_smithy_client.expectLong, id: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_StartMLDataProcessingJobCommand");var de_StartMLModelTrainingJobCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { arn: import_smithy_client.expectString, creationTimeInMillis: import_smithy_client.expectLong, id: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_StartMLModelTrainingJobCommand");var de_StartMLModelTransformJobCommand = /* @__PURE__ */ __name(async (output, context) => { if (output.statusCode !== 200 && output.statusCode >= 300) { return de_CommandError(output, context); } const contents = (0, import_smithy_client.map)({ $metadata: deserializeMetadata(output) }); const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body"); const doc = (0, import_smithy_client.take)(data, { arn: import_smithy_client.expectString, creationTimeInMillis: import_smithy_client.expectLong, id: import_smithy_client.expectString }); Object.assign(contents, doc); return contents;}, "de_StartMLModelTransformJobCommand");var de_CommandError = /* @__PURE__ */ __name(async (output, context) => { const parsedOutput = { ...output, body: await (0, import_core2.parseJsonErrorBody)(output.body, context) }; const errorCode = (0, import_core2.loadRestJsonErrorCode)(output, parsedOutput.body); switch (errorCode) { case "BadRequestException": case "com.amazonaws.neptunedata#BadRequestException": throw await de_BadRequestExceptionRes(parsedOutput, context); case "ClientTimeoutException": case "com.amazonaws.neptunedata#ClientTimeoutException": throw await de_ClientTimeoutExceptionRes(parsedOutput, context); case "ConcurrentModificationException": case "com.amazonaws.neptunedata#ConcurrentModificationException": throw await de_ConcurrentModificationExceptionRes(parsedOutput, context); case "ConstraintViolationException": case "com.amazonaws.neptunedata#ConstraintViolationException": throw await de_ConstraintViolationExceptionRes(parsedOutput, context); case "FailureByQueryException": case "com.amazonaws.neptunedata#FailureByQueryException": throw await de_FailureByQueryExceptionRes(parsedOutput, context); case "IllegalArgumentException": case "com.amazonaws.neptunedata#IllegalArgumentException": throw await de_IllegalArgumentExceptionRes(parsedOutput, context); case "InvalidArgumentException": case "com.amazonaws.neptunedata#InvalidArgumentException": throw await de_InvalidArgumentExceptionRes(parsedOutput, context); case "InvalidParameterException": case "com.amazonaws.neptunedata#InvalidParameterException": throw await de_InvalidParameterExceptionRes(parsedOutput, context); case "MissingParameterException": case "com.amazonaws.neptunedata#MissingParameterException": throw await de_MissingParameterExceptionRes(parsedOutput, context); case "ParsingException": case "com.amazonaws.neptunedata#ParsingException": throw await de_ParsingExceptionRes(parsedOutput, context); case "PreconditionsFailedException": case "com.amazonaws.neptunedata#PreconditionsFailedException": throw await de_PreconditionsFailedExceptionRes(parsedOutput, context); case "TimeLimitExceededException": case "com.amazonaws.neptunedata#TimeLimitExceededException": throw await de_TimeLimitExceededExceptionRes(parsedOutput, context); case "TooManyRequestsException": case "com.amazonaws.neptunedata#TooManyRequestsException": throw await de_TooManyRequestsExceptionRes(parsedOutput, context); case "UnsupportedOperationException": case "com.amazonaws.neptunedata#UnsupportedOperationException": throw await de_UnsupportedOperationExceptionRes(parsedOutput, context); case "BulkLoadIdNotFoundException": case "com.amazonaws.neptunedata#BulkLoadIdNotFoundException": throw await de_BulkLoadIdNotFoundExceptionRes(parsedOutput, context); case "InternalFailureException": case "com.amazonaws.neptunedata#InternalFailureException": throw await de_InternalFailureExceptionRes(parsedOutput, context); case "LoadUrlAccessDeniedException": case "com.amazonaws.neptunedata#LoadUrlAccessDeniedException": throw await de_LoadUrlAccessDeniedExceptionRes(parsedOutput, context); case "MLResourceNotFoundException": case "com.amazonaws.neptunedata#MLResourceNotFoundException": throw await de_MLResourceNotFoundExceptionRes(parsedOutput, context); case "InvalidNumericDataException": case "com.amazonaws.neptunedata#InvalidNumericDataException": throw await de_InvalidNumericDataExceptionRes(parsedOutput, context); case "AccessDeniedException": case "com.amazonaws.neptunedata#AccessDeniedException": throw await de_AccessDeniedExceptionRes(parsedOutput, context); case "ReadOnlyViolationException": case "com.amazonaws.neptunedata#ReadOnlyViolationException": throw await de_ReadOnlyViolationExceptionRes(parsedOutput, context); case "StatisticsNotAvailableException": case "com.amazonaws.neptunedata#StatisticsNotAvailableException": throw await de_StatisticsNotAvailableExceptionRes(parsedOutput, context); case "MethodNotAllowedException": case "com.amazonaws.neptunedata#MethodNotAllowedException": throw await de_MethodNotAllowedExceptionRes(parsedOutput, context); case "ServerShutdownException": case "com.amazonaws.neptunedata#ServerShutdownException": throw await de_ServerShutdownExceptionRes(parsedOutput, context); case "CancelledByUserException": case "com.amazonaws.neptunedata#CancelledByUserException": throw await de_CancelledByUserExceptionRes(parsedOutput, context); case "MalformedQueryException": case "com.amazonaws.neptunedata#MalformedQueryException": throw await de_MalformedQueryExceptionRes(parsedOutput, context); case "MemoryLimitExceededException": case "com.amazonaws.neptunedata#MemoryLimitExceededException": throw await de_MemoryLimitExceededExceptionRes(parsedOutput, context); case "QueryLimitExceededException": case "com.amazonaws.neptunedata#QueryLimitExceededException": throw await de_QueryLimitExceededExceptionRes(parsedOutput, context); case "QueryLimitException": case "com.amazonaws.neptunedata#QueryLimitException": throw await de_QueryLimitExceptionRes(parsedOutput, context); case "QueryTooLargeException": case "com.amazonaws.neptunedata#QueryTooLargeException": throw await de_QueryTooLargeExceptionRes(parsedOutput, context); case "ExpiredStreamException": case "com.amazonaws.neptunedata#ExpiredStreamException": throw await de_ExpiredStreamExceptionRes(parsedOutput, context); case "StreamRecordsNotFoundException": case "com.amazonaws.neptunedata#StreamRecordsNotFoundException": throw await de_StreamRecordsNotFoundExceptionRes(parsedOutput, context); case "ThrottlingException": case "com.amazonaws.neptunedata#ThrottlingException": throw await de_ThrottlingExceptionRes(parsedOutput, context); case "S3Exception": case "com.amazonaws.neptunedata#S3Exception": throw await de_S3ExceptionRes(parsedOutput, context); default: const parsedBody = parsedOutput.body; return throwDefaultError({ output, parsedBody, errorCode }); }}, "de_CommandError");var throwDefaultError = (0, import_smithy_client.withBaseException)(NeptunedataServiceException);var de_AccessDeniedExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new AccessDeniedException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_AccessDeniedExceptionRes");var de_BadRequestExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new BadRequestException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_BadRequestExceptionRes");var de_BulkLoadIdNotFoundExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new BulkLoadIdNotFoundException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_BulkLoadIdNotFoundExceptionRes");var de_CancelledByUserExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new CancelledByUserException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_CancelledByUserExceptionRes");var de_ClientTimeoutExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new ClientTimeoutException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ClientTimeoutExceptionRes");var de_ConcurrentModificationExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new ConcurrentModificationException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ConcurrentModificationExceptionRes");var de_ConstraintViolationExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new ConstraintViolationException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ConstraintViolationExceptionRes");var de_ExpiredStreamExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new ExpiredStreamException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ExpiredStreamExceptionRes");var de_FailureByQueryExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new FailureByQueryException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_FailureByQueryExceptionRes");var de_IllegalArgumentExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new IllegalArgumentException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_IllegalArgumentExceptionRes");var de_InternalFailureExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new InternalFailureException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_InternalFailureExceptionRes");var de_InvalidArgumentExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new InvalidArgumentException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_InvalidArgumentExceptionRes");var de_InvalidNumericDataExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new InvalidNumericDataException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_InvalidNumericDataExceptionRes");var de_InvalidParameterExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new InvalidParameterException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_InvalidParameterExceptionRes");var de_LoadUrlAccessDeniedExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new LoadUrlAccessDeniedException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_LoadUrlAccessDeniedExceptionRes");var de_MalformedQueryExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new MalformedQueryException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_MalformedQueryExceptionRes");var de_MemoryLimitExceededExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new MemoryLimitExceededException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_MemoryLimitExceededExceptionRes");var de_MethodNotAllowedExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new MethodNotAllowedException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_MethodNotAllowedExceptionRes");var de_MissingParameterExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new MissingParameterException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_MissingParameterExceptionRes");var de_MLResourceNotFoundExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new MLResourceNotFoundException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_MLResourceNotFoundExceptionRes");var de_ParsingExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new ParsingException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ParsingExceptionRes");var de_PreconditionsFailedExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new PreconditionsFailedException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_PreconditionsFailedExceptionRes");var de_QueryLimitExceededExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new QueryLimitExceededException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_QueryLimitExceededExceptionRes");var de_QueryLimitExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new QueryLimitException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_QueryLimitExceptionRes");var de_QueryTooLargeExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new QueryTooLargeException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_QueryTooLargeExceptionRes");var de_ReadOnlyViolationExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new ReadOnlyViolationException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ReadOnlyViolationExceptionRes");var de_S3ExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new S3Exception({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_S3ExceptionRes");var de_ServerShutdownExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new ServerShutdownException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ServerShutdownExceptionRes");var de_StatisticsNotAvailableExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new StatisticsNotAvailableException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_StatisticsNotAvailableExceptionRes");var de_StreamRecordsNotFoundExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new StreamRecordsNotFoundException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_StreamRecordsNotFoundExceptionRes");var de_ThrottlingExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new ThrottlingException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ThrottlingExceptionRes");var de_TimeLimitExceededExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new TimeLimitExceededException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_TimeLimitExceededExceptionRes");var de_TooManyRequestsExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new TooManyRequestsException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_TooManyRequestsExceptionRes");var de_UnsupportedOperationExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => { const contents = (0, import_smithy_client.map)({}); const data = parsedOutput.body; const doc = (0, import_smithy_client.take)(data, { code: import_smithy_client.expectString, detailedMessage: import_smithy_client.expectString, requestId: import_smithy_client.expectString }); Object.assign(contents, doc); const exception = new UnsupportedOperationException({ $metadata: deserializeMetadata(parsedOutput), ...contents }); return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_UnsupportedOperationExceptionRes");var de_DocumentValuedMap = /* @__PURE__ */ __name((output, context) => { return Object.entries(output).reduce((acc, [key, value]) => { if (value === null) { return acc; } acc[key] = de_Document(value, context); return acc; }, {});}, "de_DocumentValuedMap");var de_GremlinQueries = /* @__PURE__ */ __name((output, context) => { const retVal = (output || []).filter((e) => e != null).map((entry) => { return de_GremlinQueryStatus(entry, context); }); return retVal;}, "de_GremlinQueries");var de_GremlinQueryStatus = /* @__PURE__ */ __name((output, context) => { return (0, import_smithy_client.take)(output, { queryEvalStats: /* @__PURE__ */ __name((_) => de_QueryEvalStats(_, context), "queryEvalStats"), queryId: import_smithy_client.expectString, queryString: import_smithy_client.expectString });}, "de_GremlinQueryStatus");var de_GremlinQueryStatusAttributes = /* @__PURE__ */ __name((output, context) => { return (0, import_smithy_client.take)(output, { attributes: /* @__PURE__ */ __name((_) => de_Document(_, context), "attributes"), code: import_smithy_client.expectInt32, message: import_smithy_client.expectString });}, "de_GremlinQueryStatusAttributes");var de_OpenCypherQueries = /* @__PURE__ */ __name((output, context) => { const retVal = (output || []).filter((e) => e != null).map((entry) => { return de_GremlinQueryStatus(entry, context); }); return retVal;}, "de_OpenCypherQueries");var de_PropertygraphData = /* @__PURE__ */ __name((output, context) => { return (0, import_smithy_client.take)(output, { from: import_smithy_client.expectString, id: import_smithy_client.expectString, key: import_smithy_client.expectString, to: import_smithy_client.expectString, type: import_smithy_client.expectString, value: /* @__PURE__ */ __name((_) => de_Document(_, context), "value") });}, "de_PropertygraphData");var de_PropertygraphRecord = /* @__PURE__ */ __name((output, context) => { return (0, import_smithy_client.take)(output, { commitTimestampInMillis: [, import_smithy_client.expectLong, `commitTimestamp`], data: /* @__PURE__ */ __name((_) => de_PropertygraphData(_, context), "data"), eventId: import_smithy_client._json, isLastOp: import_smithy_client.expectBoolean, op: import_smithy_client.expectString });}, "de_PropertygraphRecord");var de_PropertygraphRecordsList = /* @__PURE__ */ __name((output, context) => { const retVal = (output || []).filter((e) => e != null).map((entry) => { return de_PropertygraphRecord(entry, context); }); return retVal;}, "de_PropertygraphRecordsList");var de_PropertygraphSummaryValueMap = /* @__PURE__ */ __name((output, context) => { return (0, import_smithy_client.take)(output, { graphSummary: import_smithy_client._json, lastStatisticsComputationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "lastStatisticsComputationTime"), version: import_smithy_client.expectString });}, "de_PropertygraphSummaryValueMap");var de_QueryEvalStats = /* @__PURE__ */ __name((output, context) => { return (0, import_smithy_client.take)(output, { cancelled: import_smithy_client.expectBoolean, elapsed: import_smithy_client.expectInt32, subqueries: /* @__PURE__ */ __name((_) => de_Document(_, context), "subqueries"), waited: import_smithy_client.expectInt32 });}, "de_QueryEvalStats");var de_RDFGraphSummaryValueMap = /* @__PURE__ */ __name((output, context) => { return (0, import_smithy_client.take)(output, { graphSummary: import_smithy_client._json, lastStatisticsComputationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "lastStatisticsComputationTime"), version: import_smithy_client.expectString });}, "de_RDFGraphSummaryValueMap");var de_SparqlRecord = /* @__PURE__ */ __name((output, context) => { return (0, import_smithy_client.take)(output, { commitTimestampInMillis: [, import_smithy_client.expectLong, `commitTimestamp`], data: import_smithy_client._json, eventId: import_smithy_client._json, isLastOp: import_smithy_client.expectBoolean, op: import_smithy_client.expectString });}, "de_SparqlRecord");var de_SparqlRecordsList = /* @__PURE__ */ __name((output, context) => { const retVal = (output || []).filter((e) => e != null).map((entry) => { return de_SparqlRecord(entry, context); }); return retVal;}, "de_SparqlRecordsList");var de_Statistics = /* @__PURE__ */ __name((output, context) => { return (0, import_smithy_client.take)(output, { active: import_smithy_client.expectBoolean, autoCompute: import_smithy_client.expectBoolean, date: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "date"), note: import_smithy_client.expectString, signatureInfo: import_smithy_client._json, statisticsId: import_smithy_client.expectString });}, "de_Statistics");var de_Document = /* @__PURE__ */ __name((output, context) => { return output;}, "de_Document");var deserializeMetadata = /* @__PURE__ */ __name((output) => ({ httpStatusCode: output.statusCode, requestId: output.headers["x-amzn-requestid"] ?? output.headers["x-amzn-request-id"] ?? output.headers["x-amz-request-id"], extendedRequestId: output.headers["x-amz-id-2"], cfId: output.headers["x-amz-cf-id"]}), "deserializeMetadata");var _a = "accept";var _ae = "accept-encoding";var _c = "clean";var _cN = "commitNum";var _d = "details";var _e = "errors";var _ePP = "errorsPerPage";var _en = "encoding";var _iQL = "includeQueuedLoads";var _iT = "iteratorType";var _iW = "includeWaiting";var _l = "limit";var _m = "mode";var _mI = "maxItems";var _nIRA = "neptuneIamRoleArn";var _oN = "opNum";var _p = "page";var _s = "silent";var _se = "serializer"; // src/commands/CancelGremlinQueryCommand.tsvar CancelGremlinQueryCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "CancelGremlinQuery", {}).n("NeptunedataClient", "CancelGremlinQueryCommand").f(void 0, void 0).ser(se_CancelGremlinQueryCommand).de(de_CancelGremlinQueryCommand).build() { static { __name(this, "CancelGremlinQueryCommand"); }}; // src/commands/CancelLoaderJobCommand.ts var CancelLoaderJobCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "CancelLoaderJob", {}).n("NeptunedataClient", "CancelLoaderJobCommand").f(void 0, void 0).ser(se_CancelLoaderJobCommand).de(de_CancelLoaderJobCommand).build() { static { __name(this, "CancelLoaderJobCommand"); }}; // src/commands/CancelMLDataProcessingJobCommand.ts var CancelMLDataProcessingJobCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "CancelMLDataProcessingJob", {}).n("NeptunedataClient", "CancelMLDataProcessingJobCommand").f(void 0, void 0).ser(se_CancelMLDataProcessingJobCommand).de(de_CancelMLDataProcessingJobCommand).build() { static { __name(this, "CancelMLDataProcessingJobCommand"); }}; // src/commands/CancelMLModelTrainingJobCommand.ts var CancelMLModelTrainingJobCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "CancelMLModelTrainingJob", {}).n("NeptunedataClient", "CancelMLModelTrainingJobCommand").f(void 0, void 0).ser(se_CancelMLModelTrainingJobCommand).de(de_CancelMLModelTrainingJobCommand).build() { static { __name(this, "CancelMLModelTrainingJobCommand"); }}; // src/commands/CancelMLModelTransformJobCommand.ts var CancelMLModelTransformJobCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "CancelMLModelTransformJob", {}).n("NeptunedataClient", "CancelMLModelTransformJobCommand").f(void 0, void 0).ser(se_CancelMLModelTransformJobCommand).de(de_CancelMLModelTransformJobCommand).build() { static { __name(this, "CancelMLModelTransformJobCommand"); }}; // src/commands/CancelOpenCypherQueryCommand.ts var CancelOpenCypherQueryCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "CancelOpenCypherQuery", {}).n("NeptunedataClient", "CancelOpenCypherQueryCommand").f(void 0, void 0).ser(se_CancelOpenCypherQueryCommand).de(de_CancelOpenCypherQueryCommand).build() { static { __name(this, "CancelOpenCypherQueryCommand"); }}; // src/commands/CreateMLEndpointCommand.ts var CreateMLEndpointCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "CreateMLEndpoint", {}).n("NeptunedataClient", "CreateMLEndpointCommand").f(void 0, void 0).ser(se_CreateMLEndpointCommand).de(de_CreateMLEndpointCommand).build() { static { __name(this, "CreateMLEndpointCommand"); }}; // src/commands/DeleteMLEndpointCommand.ts var DeleteMLEndpointCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "DeleteMLEndpoint", {}).n("NeptunedataClient", "DeleteMLEndpointCommand").f(void 0, void 0).ser(se_DeleteMLEndpointCommand).de(de_DeleteMLEndpointCommand).build() { static { __name(this, "DeleteMLEndpointCommand"); }}; // src/commands/DeletePropertygraphStatisticsCommand.ts var DeletePropertygraphStatisticsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "DeletePropertygraphStatistics", {}).n("NeptunedataClient", "DeletePropertygraphStatisticsCommand").f(void 0, void 0).ser(se_DeletePropertygraphStatisticsCommand).de(de_DeletePropertygraphStatisticsCommand).build() { static { __name(this, "DeletePropertygraphStatisticsCommand"); }}; // src/commands/DeleteSparqlStatisticsCommand.ts var DeleteSparqlStatisticsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "DeleteSparqlStatistics", {}).n("NeptunedataClient", "DeleteSparqlStatisticsCommand").f(void 0, void 0).ser(se_DeleteSparqlStatisticsCommand).de(de_DeleteSparqlStatisticsCommand).build() { static { __name(this, "DeleteSparqlStatisticsCommand"); }}; // src/commands/ExecuteFastResetCommand.ts var ExecuteFastResetCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ExecuteFastReset", {}).n("NeptunedataClient", "ExecuteFastResetCommand").f(void 0, void 0).ser(se_ExecuteFastResetCommand).de(de_ExecuteFastResetCommand).build() { static { __name(this, "ExecuteFastResetCommand"); }}; // src/commands/ExecuteGremlinExplainQueryCommand.ts var ExecuteGremlinExplainQueryCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ExecuteGremlinExplainQuery", {}).n("NeptunedataClient", "ExecuteGremlinExplainQueryCommand").f(void 0, void 0).ser(se_ExecuteGremlinExplainQueryCommand).de(de_ExecuteGremlinExplainQueryCommand).build() { static { __name(this, "ExecuteGremlinExplainQueryCommand"); }}; // src/commands/ExecuteGremlinProfileQueryCommand.ts var ExecuteGremlinProfileQueryCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ExecuteGremlinProfileQuery", {}).n("NeptunedataClient", "ExecuteGremlinProfileQueryCommand").f(void 0, void 0).ser(se_ExecuteGremlinProfileQueryCommand).de(de_ExecuteGremlinProfileQueryCommand).build() { static { __name(this, "ExecuteGremlinProfileQueryCommand"); }}; // src/commands/ExecuteGremlinQueryCommand.ts var ExecuteGremlinQueryCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ExecuteGremlinQuery", {}).n("NeptunedataClient", "ExecuteGremlinQueryCommand").f(void 0, void 0).ser(se_ExecuteGremlinQueryCommand).de(de_ExecuteGremlinQueryCommand).build() { static { __name(this, "ExecuteGremlinQueryCommand"); }}; // src/commands/ExecuteOpenCypherExplainQueryCommand.ts var ExecuteOpenCypherExplainQueryCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ExecuteOpenCypherExplainQuery", {}).n("NeptunedataClient", "ExecuteOpenCypherExplainQueryCommand").f(void 0, void 0).ser(se_ExecuteOpenCypherExplainQueryCommand).de(de_ExecuteOpenCypherExplainQueryCommand).build() { static { __name(this, "ExecuteOpenCypherExplainQueryCommand"); }}; // src/commands/ExecuteOpenCypherQueryCommand.ts var ExecuteOpenCypherQueryCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ExecuteOpenCypherQuery", {}).n("NeptunedataClient", "ExecuteOpenCypherQueryCommand").f(void 0, void 0).ser(se_ExecuteOpenCypherQueryCommand).de(de_ExecuteOpenCypherQueryCommand).build() { static { __name(this, "ExecuteOpenCypherQueryCommand"); }}; // src/commands/GetEngineStatusCommand.ts var GetEngineStatusCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetEngineStatus", {}).n("NeptunedataClient", "GetEngineStatusCommand").f(void 0, void 0).ser(se_GetEngineStatusCommand).de(de_GetEngineStatusCommand).build() { static { __name(this, "GetEngineStatusCommand"); }}; // src/commands/GetGremlinQueryStatusCommand.ts var GetGremlinQueryStatusCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetGremlinQueryStatus", {}).n("NeptunedataClient", "GetGremlinQueryStatusCommand").f(void 0, void 0).ser(se_GetGremlinQueryStatusCommand).de(de_GetGremlinQueryStatusCommand).build() { static { __name(this, "GetGremlinQueryStatusCommand"); }}; // src/commands/GetLoaderJobStatusCommand.ts var GetLoaderJobStatusCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetLoaderJobStatus", {}).n("NeptunedataClient", "GetLoaderJobStatusCommand").f(void 0, void 0).ser(se_GetLoaderJobStatusCommand).de(de_GetLoaderJobStatusCommand).build() { static { __name(this, "GetLoaderJobStatusCommand"); }}; // src/commands/GetMLDataProcessingJobCommand.ts var GetMLDataProcessingJobCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetMLDataProcessingJob", {}).n("NeptunedataClient", "GetMLDataProcessingJobCommand").f(void 0, void 0).ser(se_GetMLDataProcessingJobCommand).de(de_GetMLDataProcessingJobCommand).build() { static { __name(this, "GetMLDataProcessingJobCommand"); }}; // src/commands/GetMLEndpointCommand.ts var GetMLEndpointCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetMLEndpoint", {}).n("NeptunedataClient", "GetMLEndpointCommand").f(void 0, void 0).ser(se_GetMLEndpointCommand).de(de_GetMLEndpointCommand).build() { static { __name(this, "GetMLEndpointCommand"); }}; // src/commands/GetMLModelTrainingJobCommand.ts var GetMLModelTrainingJobCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetMLModelTrainingJob", {}).n("NeptunedataClient", "GetMLModelTrainingJobCommand").f(void 0, void 0).ser(se_GetMLModelTrainingJobCommand).de(de_GetMLModelTrainingJobCommand).build() { static { __name(this, "GetMLModelTrainingJobCommand"); }}; // src/commands/GetMLModelTransformJobCommand.ts var GetMLModelTransformJobCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetMLModelTransformJob", {}).n("NeptunedataClient", "GetMLModelTransformJobCommand").f(void 0, void 0).ser(se_GetMLModelTransformJobCommand).de(de_GetMLModelTransformJobCommand).build() { static { __name(this, "GetMLModelTransformJobCommand"); }}; // src/commands/GetOpenCypherQueryStatusCommand.ts var GetOpenCypherQueryStatusCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetOpenCypherQueryStatus", {}).n("NeptunedataClient", "GetOpenCypherQueryStatusCommand").f(void 0, void 0).ser(se_GetOpenCypherQueryStatusCommand).de(de_GetOpenCypherQueryStatusCommand).build() { static { __name(this, "GetOpenCypherQueryStatusCommand"); }}; // src/commands/GetPropertygraphStatisticsCommand.ts var GetPropertygraphStatisticsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetPropertygraphStatistics", {}).n("NeptunedataClient", "GetPropertygraphStatisticsCommand").f(void 0, void 0).ser(se_GetPropertygraphStatisticsCommand).de(de_GetPropertygraphStatisticsCommand).build() { static { __name(this, "GetPropertygraphStatisticsCommand"); }}; // src/commands/GetPropertygraphStreamCommand.ts var GetPropertygraphStreamCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetPropertygraphStream", {}).n("NeptunedataClient", "GetPropertygraphStreamCommand").f(void 0, void 0).ser(se_GetPropertygraphStreamCommand).de(de_GetPropertygraphStreamCommand).build() { static { __name(this, "GetPropertygraphStreamCommand"); }}; // src/commands/GetPropertygraphSummaryCommand.ts var GetPropertygraphSummaryCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetPropertygraphSummary", {}).n("NeptunedataClient", "GetPropertygraphSummaryCommand").f(void 0, void 0).ser(se_GetPropertygraphSummaryCommand).de(de_GetPropertygraphSummaryCommand).build() { static { __name(this, "GetPropertygraphSummaryCommand"); }}; // src/commands/GetRDFGraphSummaryCommand.ts var GetRDFGraphSummaryCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetRDFGraphSummary", {}).n("NeptunedataClient", "GetRDFGraphSummaryCommand").f(void 0, void 0).ser(se_GetRDFGraphSummaryCommand).de(de_GetRDFGraphSummaryCommand).build() { static { __name(this, "GetRDFGraphSummaryCommand"); }}; // src/commands/GetSparqlStatisticsCommand.ts var GetSparqlStatisticsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetSparqlStatistics", {}).n("NeptunedataClient", "GetSparqlStatisticsCommand").f(void 0, void 0).ser(se_GetSparqlStatisticsCommand).de(de_GetSparqlStatisticsCommand).build() { static { __name(this, "GetSparqlStatisticsCommand"); }}; // src/commands/GetSparqlStreamCommand.ts var GetSparqlStreamCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "GetSparqlStream", {}).n("NeptunedataClient", "GetSparqlStreamCommand").f(void 0, void 0).ser(se_GetSparqlStreamCommand).de(de_GetSparqlStreamCommand).build() { static { __name(this, "GetSparqlStreamCommand"); }}; // src/commands/ListGremlinQueriesCommand.ts var ListGremlinQueriesCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ListGremlinQueries", {}).n("NeptunedataClient", "ListGremlinQueriesCommand").f(void 0, void 0).ser(se_ListGremlinQueriesCommand).de(de_ListGremlinQueriesCommand).build() { static { __name(this, "ListGremlinQueriesCommand"); }}; // src/commands/ListLoaderJobsCommand.ts var ListLoaderJobsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ListLoaderJobs", {}).n("NeptunedataClient", "ListLoaderJobsCommand").f(void 0, void 0).ser(se_ListLoaderJobsCommand).de(de_ListLoaderJobsCommand).build() { static { __name(this, "ListLoaderJobsCommand"); }}; // src/commands/ListMLDataProcessingJobsCommand.ts var ListMLDataProcessingJobsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ListMLDataProcessingJobs", {}).n("NeptunedataClient", "ListMLDataProcessingJobsCommand").f(void 0, void 0).ser(se_ListMLDataProcessingJobsCommand).de(de_ListMLDataProcessingJobsCommand).build() { static { __name(this, "ListMLDataProcessingJobsCommand"); }}; // src/commands/ListMLEndpointsCommand.ts var ListMLEndpointsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ListMLEndpoints", {}).n("NeptunedataClient", "ListMLEndpointsCommand").f(void 0, void 0).ser(se_ListMLEndpointsCommand).de(de_ListMLEndpointsCommand).build() { static { __name(this, "ListMLEndpointsCommand"); }}; // src/commands/ListMLModelTrainingJobsCommand.ts var ListMLModelTrainingJobsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ListMLModelTrainingJobs", {}).n("NeptunedataClient", "ListMLModelTrainingJobsCommand").f(void 0, void 0).ser(se_ListMLModelTrainingJobsCommand).de(de_ListMLModelTrainingJobsCommand).build() { static { __name(this, "ListMLModelTrainingJobsCommand"); }}; // src/commands/ListMLModelTransformJobsCommand.ts var ListMLModelTransformJobsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ListMLModelTransformJobs", {}).n("NeptunedataClient", "ListMLModelTransformJobsCommand").f(void 0, void 0).ser(se_ListMLModelTransformJobsCommand).de(de_ListMLModelTransformJobsCommand).build() { static { __name(this, "ListMLModelTransformJobsCommand"); }}; // src/commands/ListOpenCypherQueriesCommand.ts var ListOpenCypherQueriesCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ListOpenCypherQueries", {}).n("NeptunedataClient", "ListOpenCypherQueriesCommand").f(void 0, void 0).ser(se_ListOpenCypherQueriesCommand).de(de_ListOpenCypherQueriesCommand).build() { static { __name(this, "ListOpenCypherQueriesCommand"); }}; // src/commands/ManagePropertygraphStatisticsCommand.ts var ManagePropertygraphStatisticsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ManagePropertygraphStatistics", {}).n("NeptunedataClient", "ManagePropertygraphStatisticsCommand").f(void 0, void 0).ser(se_ManagePropertygraphStatisticsCommand).de(de_ManagePropertygraphStatisticsCommand).build() { static { __name(this, "ManagePropertygraphStatisticsCommand"); }}; // src/commands/ManageSparqlStatisticsCommand.ts var ManageSparqlStatisticsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "ManageSparqlStatistics", {}).n("NeptunedataClient", "ManageSparqlStatisticsCommand").f(void 0, void 0).ser(se_ManageSparqlStatisticsCommand).de(de_ManageSparqlStatisticsCommand).build() { static { __name(this, "ManageSparqlStatisticsCommand"); }}; // src/commands/StartLoaderJobCommand.ts var StartLoaderJobCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "StartLoaderJob", {}).n("NeptunedataClient", "StartLoaderJobCommand").f(void 0, void 0).ser(se_StartLoaderJobCommand).de(de_StartLoaderJobCommand).build() { static { __name(this, "StartLoaderJobCommand"); }}; // src/commands/StartMLDataProcessingJobCommand.ts var StartMLDataProcessingJobCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "StartMLDataProcessingJob", {}).n("NeptunedataClient", "StartMLDataProcessingJobCommand").f(void 0, void 0).ser(se_StartMLDataProcessingJobCommand).de(de_StartMLDataProcessingJobCommand).build() { static { __name(this, "StartMLDataProcessingJobCommand"); }}; // src/commands/StartMLModelTrainingJobCommand.ts var StartMLModelTrainingJobCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "StartMLModelTrainingJob", {}).n("NeptunedataClient", "StartMLModelTrainingJobCommand").f(void 0, void 0).ser(se_StartMLModelTrainingJobCommand).de(de_StartMLModelTrainingJobCommand).build() { static { __name(this, "StartMLModelTrainingJobCommand"); }}; // src/commands/StartMLModelTransformJobCommand.ts var StartMLModelTransformJobCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) { return [ (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize), (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions()) ];}).s("AmazonNeptuneDataplane", "StartMLModelTransformJob", {}).n("NeptunedataClient", "StartMLModelTransformJobCommand").f(void 0, void 0).ser(se_StartMLModelTransformJobCommand).de(de_StartMLModelTransformJobCommand).build() { static { __name(this, "StartMLModelTransformJobCommand"); }}; // src/Neptunedata.tsvar commands = { CancelGremlinQueryCommand, CancelLoaderJobCommand, CancelMLDataProcessingJobCommand, CancelMLModelTrainingJobCommand, CancelMLModelTransformJobCommand, CancelOpenCypherQueryCommand, CreateMLEndpointCommand, DeleteMLEndpointCommand, DeletePropertygraphStatisticsCommand, DeleteSparqlStatisticsCommand, ExecuteFastResetCommand, ExecuteGremlinExplainQueryCommand, ExecuteGremlinProfileQueryCommand, ExecuteGremlinQueryCommand, ExecuteOpenCypherExplainQueryCommand, ExecuteOpenCypherQueryCommand, GetEngineStatusCommand, GetGremlinQueryStatusCommand, GetLoaderJobStatusCommand, GetMLDataProcessingJobCommand, GetMLEndpointCommand, GetMLModelTrainingJobCommand, GetMLModelTransformJobCommand, GetOpenCypherQueryStatusCommand, GetPropertygraphStatisticsCommand, GetPropertygraphStreamCommand, GetPropertygraphSummaryCommand, GetRDFGraphSummaryCommand, GetSparqlStatisticsCommand, GetSparqlStreamCommand, ListGremlinQueriesCommand, ListLoaderJobsCommand, ListMLDataProcessingJobsCommand, ListMLEndpointsCommand, ListMLModelTrainingJobsCommand, ListMLModelTransformJobsCommand, ListOpenCypherQueriesCommand, ManagePropertygraphStatisticsCommand, ManageSparqlStatisticsCommand, StartLoaderJobCommand, StartMLDataProcessingJobCommand, StartMLModelTrainingJobCommand, StartMLModelTransformJobCommand};var Neptunedata = class extends NeptunedataClient { static { __name(this, "Neptunedata"); }};(0, import_smithy_client.createAggregatedClient)(commands, Neptunedata);// Annotate the CommonJS export names for ESM import in node: 0 && (module.exports = { NeptunedataServiceException, __Client, NeptunedataClient, Neptunedata, $Command, CancelGremlinQueryCommand, CancelLoaderJobCommand, CancelMLDataProcessingJobCommand, CancelMLModelTrainingJobCommand, CancelMLModelTransformJobCommand, CancelOpenCypherQueryCommand, CreateMLEndpointCommand, DeleteMLEndpointCommand, DeletePropertygraphStatisticsCommand, DeleteSparqlStatisticsCommand, ExecuteFastResetCommand, ExecuteGremlinExplainQueryCommand, ExecuteGremlinProfileQueryCommand, ExecuteGremlinQueryCommand, ExecuteOpenCypherExplainQueryCommand, ExecuteOpenCypherQueryCommand, GetEngineStatusCommand, GetGremlinQueryStatusCommand, GetLoaderJobStatusCommand, GetMLDataProcessingJobCommand, GetMLEndpointCommand, GetMLModelTrainingJobCommand, GetMLModelTransformJobCommand, GetOpenCypherQueryStatusCommand, GetPropertygraphStatisticsCommand, GetPropertygraphStreamCommand, GetPropertygraphSummaryCommand, GetRDFGraphSummaryCommand, GetSparqlStatisticsCommand, GetSparqlStreamCommand, ListGremlinQueriesCommand, ListLoaderJobsCommand, ListMLDataProcessingJobsCommand, ListMLEndpointsCommand, ListMLModelTrainingJobsCommand, ListMLModelTransformJobsCommand, ListOpenCypherQueriesCommand, ManagePropertygraphStatisticsCommand, ManageSparqlStatisticsCommand, StartLoaderJobCommand, StartMLDataProcessingJobCommand, StartMLModelTrainingJobCommand, StartMLModelTransformJobCommand, AccessDeniedException, Action, BadRequestException, ClientTimeoutException, ConcurrentModificationException, ConstraintViolationException, FailureByQueryException, IllegalArgumentException, InvalidArgumentException, InvalidParameterException, MissingParameterException, ParsingException, PreconditionsFailedException, TimeLimitExceededException, TooManyRequestsException, UnsupportedOperationException, BulkLoadIdNotFoundException, InternalFailureException, LoadUrlAccessDeniedException, MLResourceNotFoundException, InvalidNumericDataException, ReadOnlyViolationException, StatisticsNotAvailableException, MethodNotAllowedException, ServerShutdownException, CancelledByUserException, MalformedQueryException, MemoryLimitExceededException, QueryLimitExceededException, QueryLimitException, QueryTooLargeException, OpenCypherExplainMode, ExpiredStreamException, Encoding, IteratorType, StreamRecordsNotFoundException, ThrottlingException, GraphSummaryType, StatisticsAutoGenerationMode, S3Exception, Format, Mode, Parallelism, S3BucketRegion});