From 5f9af076dedd64da4cb5dae9de9da6220ad2e923 Mon Sep 17 00:00:00 2001
From: awstools <awstools@amazon.com>
Date: Wed, 26 Jul 2023 18:30:39 +0000
Subject: [PATCH] feat(client-glue): Release Glue Studio Snowflake Connector
 Node for SDK/CLI

---
 .../src/commands/BatchGetJobsCommand.ts       |  56 ++++
 .../src/commands/CreateJobCommand.ts          |  58 +++-
 .../client-glue/src/commands/GetJobCommand.ts |  56 ++++
 .../src/commands/GetJobsCommand.ts            |  56 ++++
 .../GetUnfilteredPartitionMetadataCommand.ts  |   3 +-
 .../GetUnfilteredPartitionsMetadataCommand.ts |   3 +-
 .../src/commands/UpdateJobCommand.ts          |  56 ++++
 clients/client-glue/src/models/models_0.ts    | 234 +++++++++++-----
 clients/client-glue/src/models/models_1.ts    | 263 +++++-------------
 clients/client-glue/src/models/models_2.ts    | 211 ++++++++++++++
 .../client-glue/src/protocols/Aws_json1_1.ts  |  27 +-
 codegen/sdk-codegen/aws-models/glue.json      | 206 +++++++++++++-
 12 files changed, 956 insertions(+), 273 deletions(-)

diff --git a/clients/client-glue/src/commands/BatchGetJobsCommand.ts b/clients/client-glue/src/commands/BatchGetJobsCommand.ts
index da2c8b30df4f..49553dfd6ce3 100644
--- a/clients/client-glue/src/commands/BatchGetJobsCommand.ts
+++ b/clients/client-glue/src/commands/BatchGetJobsCommand.ts
@@ -1042,6 +1042,62 @@ export interface BatchGetJobsCommandOutput extends BatchGetJobsResponse, __Metad
  * //               RecipeVersion: "STRING_VALUE", // required
  * //             },
  * //           },
+ * //           SnowflakeSource: { // SnowflakeSource
+ * //             Name: "STRING_VALUE", // required
+ * //             Data: { // SnowflakeNodeData
+ * //               SourceType: "STRING_VALUE",
+ * //               Connection: "<Option>",
+ * //               Schema: "STRING_VALUE",
+ * //               Table: "STRING_VALUE",
+ * //               Database: "STRING_VALUE",
+ * //               TempDir: "STRING_VALUE",
+ * //               IamRole: "<Option>",
+ * //               AdditionalOptions: "<AdditionalOptions>",
+ * //               SampleQuery: "STRING_VALUE",
+ * //               PreAction: "STRING_VALUE",
+ * //               PostAction: "STRING_VALUE",
+ * //               Action: "STRING_VALUE",
+ * //               Upsert: true || false,
+ * //               MergeAction: "STRING_VALUE",
+ * //               MergeWhenMatched: "STRING_VALUE",
+ * //               MergeWhenNotMatched: "STRING_VALUE",
+ * //               MergeClause: "STRING_VALUE",
+ * //               StagingTable: "STRING_VALUE",
+ * //               SelectedColumns: [
+ * //                 "<Option>",
+ * //               ],
+ * //               AutoPushdown: true || false,
+ * //               TableSchema: "<OptionList>",
+ * //             },
+ * //             OutputSchemas: "<GlueSchemas>",
+ * //           },
+ * //           SnowflakeTarget: { // SnowflakeTarget
+ * //             Name: "STRING_VALUE", // required
+ * //             Data: {
+ * //               SourceType: "STRING_VALUE",
+ * //               Connection: "<Option>",
+ * //               Schema: "STRING_VALUE",
+ * //               Table: "STRING_VALUE",
+ * //               Database: "STRING_VALUE",
+ * //               TempDir: "STRING_VALUE",
+ * //               IamRole: "<Option>",
+ * //               AdditionalOptions: "<AdditionalOptions>",
+ * //               SampleQuery: "STRING_VALUE",
+ * //               PreAction: "STRING_VALUE",
+ * //               PostAction: "STRING_VALUE",
+ * //               Action: "STRING_VALUE",
+ * //               Upsert: true || false,
+ * //               MergeAction: "STRING_VALUE",
+ * //               MergeWhenMatched: "STRING_VALUE",
+ * //               MergeWhenNotMatched: "STRING_VALUE",
+ * //               MergeClause: "STRING_VALUE",
+ * //               StagingTable: "STRING_VALUE",
+ * //               SelectedColumns: "<OptionList>",
+ * //               AutoPushdown: true || false,
+ * //               TableSchema: "<OptionList>",
+ * //             },
+ * //             Inputs: "<OneInput>",
+ * //           },
  * //         },
  * //       },
  * //       ExecutionClass: "FLEX" || "STANDARD",
diff --git a/clients/client-glue/src/commands/CreateJobCommand.ts b/clients/client-glue/src/commands/CreateJobCommand.ts
index 1e61176cc7c6..5d7c8f0bcad2 100644
--- a/clients/client-glue/src/commands/CreateJobCommand.ts
+++ b/clients/client-glue/src/commands/CreateJobCommand.ts
@@ -14,7 +14,7 @@ import {
 } from "@smithy/types";
 
 import { GlueClientResolvedConfig, ServiceInputTypes, ServiceOutputTypes } from "../GlueClient";
-import { CreateJobResponse } from "../models/models_0";
+import { CreateJobResponse } from "../models/models_1";
 import { CreateJobRequest, CreateJobRequestFilterSensitiveLog } from "../models/models_2";
 import { de_CreateJobCommand, se_CreateJobCommand } from "../protocols/Aws_json1_1";
 
@@ -1033,6 +1033,62 @@ export interface CreateJobCommandOutput extends CreateJobResponse, __MetadataBea
  *           RecipeVersion: "STRING_VALUE", // required
  *         },
  *       },
+ *       SnowflakeSource: { // SnowflakeSource
+ *         Name: "STRING_VALUE", // required
+ *         Data: { // SnowflakeNodeData
+ *           SourceType: "STRING_VALUE",
+ *           Connection: "<Option>",
+ *           Schema: "STRING_VALUE",
+ *           Table: "STRING_VALUE",
+ *           Database: "STRING_VALUE",
+ *           TempDir: "STRING_VALUE",
+ *           IamRole: "<Option>",
+ *           AdditionalOptions: "<AdditionalOptions>",
+ *           SampleQuery: "STRING_VALUE",
+ *           PreAction: "STRING_VALUE",
+ *           PostAction: "STRING_VALUE",
+ *           Action: "STRING_VALUE",
+ *           Upsert: true || false,
+ *           MergeAction: "STRING_VALUE",
+ *           MergeWhenMatched: "STRING_VALUE",
+ *           MergeWhenNotMatched: "STRING_VALUE",
+ *           MergeClause: "STRING_VALUE",
+ *           StagingTable: "STRING_VALUE",
+ *           SelectedColumns: [
+ *             "<Option>",
+ *           ],
+ *           AutoPushdown: true || false,
+ *           TableSchema: "<OptionList>",
+ *         },
+ *         OutputSchemas: "<GlueSchemas>",
+ *       },
+ *       SnowflakeTarget: { // SnowflakeTarget
+ *         Name: "STRING_VALUE", // required
+ *         Data: {
+ *           SourceType: "STRING_VALUE",
+ *           Connection: "<Option>",
+ *           Schema: "STRING_VALUE",
+ *           Table: "STRING_VALUE",
+ *           Database: "STRING_VALUE",
+ *           TempDir: "STRING_VALUE",
+ *           IamRole: "<Option>",
+ *           AdditionalOptions: "<AdditionalOptions>",
+ *           SampleQuery: "STRING_VALUE",
+ *           PreAction: "STRING_VALUE",
+ *           PostAction: "STRING_VALUE",
+ *           Action: "STRING_VALUE",
+ *           Upsert: true || false,
+ *           MergeAction: "STRING_VALUE",
+ *           MergeWhenMatched: "STRING_VALUE",
+ *           MergeWhenNotMatched: "STRING_VALUE",
+ *           MergeClause: "STRING_VALUE",
+ *           StagingTable: "STRING_VALUE",
+ *           SelectedColumns: "<OptionList>",
+ *           AutoPushdown: true || false,
+ *           TableSchema: "<OptionList>",
+ *         },
+ *         Inputs: "<OneInput>",
+ *       },
  *     },
  *   },
  *   ExecutionClass: "FLEX" || "STANDARD",
diff --git a/clients/client-glue/src/commands/GetJobCommand.ts b/clients/client-glue/src/commands/GetJobCommand.ts
index 37d5a29c5a07..32c22000f787 100644
--- a/clients/client-glue/src/commands/GetJobCommand.ts
+++ b/clients/client-glue/src/commands/GetJobCommand.ts
@@ -1038,6 +1038,62 @@ export interface GetJobCommandOutput extends GetJobResponse, __MetadataBearer {}
  * //             RecipeVersion: "STRING_VALUE", // required
  * //           },
  * //         },
+ * //         SnowflakeSource: { // SnowflakeSource
+ * //           Name: "STRING_VALUE", // required
+ * //           Data: { // SnowflakeNodeData
+ * //             SourceType: "STRING_VALUE",
+ * //             Connection: "<Option>",
+ * //             Schema: "STRING_VALUE",
+ * //             Table: "STRING_VALUE",
+ * //             Database: "STRING_VALUE",
+ * //             TempDir: "STRING_VALUE",
+ * //             IamRole: "<Option>",
+ * //             AdditionalOptions: "<AdditionalOptions>",
+ * //             SampleQuery: "STRING_VALUE",
+ * //             PreAction: "STRING_VALUE",
+ * //             PostAction: "STRING_VALUE",
+ * //             Action: "STRING_VALUE",
+ * //             Upsert: true || false,
+ * //             MergeAction: "STRING_VALUE",
+ * //             MergeWhenMatched: "STRING_VALUE",
+ * //             MergeWhenNotMatched: "STRING_VALUE",
+ * //             MergeClause: "STRING_VALUE",
+ * //             StagingTable: "STRING_VALUE",
+ * //             SelectedColumns: [
+ * //               "<Option>",
+ * //             ],
+ * //             AutoPushdown: true || false,
+ * //             TableSchema: "<OptionList>",
+ * //           },
+ * //           OutputSchemas: "<GlueSchemas>",
+ * //         },
+ * //         SnowflakeTarget: { // SnowflakeTarget
+ * //           Name: "STRING_VALUE", // required
+ * //           Data: {
+ * //             SourceType: "STRING_VALUE",
+ * //             Connection: "<Option>",
+ * //             Schema: "STRING_VALUE",
+ * //             Table: "STRING_VALUE",
+ * //             Database: "STRING_VALUE",
+ * //             TempDir: "STRING_VALUE",
+ * //             IamRole: "<Option>",
+ * //             AdditionalOptions: "<AdditionalOptions>",
+ * //             SampleQuery: "STRING_VALUE",
+ * //             PreAction: "STRING_VALUE",
+ * //             PostAction: "STRING_VALUE",
+ * //             Action: "STRING_VALUE",
+ * //             Upsert: true || false,
+ * //             MergeAction: "STRING_VALUE",
+ * //             MergeWhenMatched: "STRING_VALUE",
+ * //             MergeWhenNotMatched: "STRING_VALUE",
+ * //             MergeClause: "STRING_VALUE",
+ * //             StagingTable: "STRING_VALUE",
+ * //             SelectedColumns: "<OptionList>",
+ * //             AutoPushdown: true || false,
+ * //             TableSchema: "<OptionList>",
+ * //           },
+ * //           Inputs: "<OneInput>",
+ * //         },
  * //       },
  * //     },
  * //     ExecutionClass: "FLEX" || "STANDARD",
diff --git a/clients/client-glue/src/commands/GetJobsCommand.ts b/clients/client-glue/src/commands/GetJobsCommand.ts
index 7be6a9e098c2..b2451483d596 100644
--- a/clients/client-glue/src/commands/GetJobsCommand.ts
+++ b/clients/client-glue/src/commands/GetJobsCommand.ts
@@ -1040,6 +1040,62 @@ export interface GetJobsCommandOutput extends GetJobsResponse, __MetadataBearer
  * //               RecipeVersion: "STRING_VALUE", // required
  * //             },
  * //           },
+ * //           SnowflakeSource: { // SnowflakeSource
+ * //             Name: "STRING_VALUE", // required
+ * //             Data: { // SnowflakeNodeData
+ * //               SourceType: "STRING_VALUE",
+ * //               Connection: "<Option>",
+ * //               Schema: "STRING_VALUE",
+ * //               Table: "STRING_VALUE",
+ * //               Database: "STRING_VALUE",
+ * //               TempDir: "STRING_VALUE",
+ * //               IamRole: "<Option>",
+ * //               AdditionalOptions: "<AdditionalOptions>",
+ * //               SampleQuery: "STRING_VALUE",
+ * //               PreAction: "STRING_VALUE",
+ * //               PostAction: "STRING_VALUE",
+ * //               Action: "STRING_VALUE",
+ * //               Upsert: true || false,
+ * //               MergeAction: "STRING_VALUE",
+ * //               MergeWhenMatched: "STRING_VALUE",
+ * //               MergeWhenNotMatched: "STRING_VALUE",
+ * //               MergeClause: "STRING_VALUE",
+ * //               StagingTable: "STRING_VALUE",
+ * //               SelectedColumns: [
+ * //                 "<Option>",
+ * //               ],
+ * //               AutoPushdown: true || false,
+ * //               TableSchema: "<OptionList>",
+ * //             },
+ * //             OutputSchemas: "<GlueSchemas>",
+ * //           },
+ * //           SnowflakeTarget: { // SnowflakeTarget
+ * //             Name: "STRING_VALUE", // required
+ * //             Data: {
+ * //               SourceType: "STRING_VALUE",
+ * //               Connection: "<Option>",
+ * //               Schema: "STRING_VALUE",
+ * //               Table: "STRING_VALUE",
+ * //               Database: "STRING_VALUE",
+ * //               TempDir: "STRING_VALUE",
+ * //               IamRole: "<Option>",
+ * //               AdditionalOptions: "<AdditionalOptions>",
+ * //               SampleQuery: "STRING_VALUE",
+ * //               PreAction: "STRING_VALUE",
+ * //               PostAction: "STRING_VALUE",
+ * //               Action: "STRING_VALUE",
+ * //               Upsert: true || false,
+ * //               MergeAction: "STRING_VALUE",
+ * //               MergeWhenMatched: "STRING_VALUE",
+ * //               MergeWhenNotMatched: "STRING_VALUE",
+ * //               MergeClause: "STRING_VALUE",
+ * //               StagingTable: "STRING_VALUE",
+ * //               SelectedColumns: "<OptionList>",
+ * //               AutoPushdown: true || false,
+ * //               TableSchema: "<OptionList>",
+ * //             },
+ * //             Inputs: "<OneInput>",
+ * //           },
  * //         },
  * //       },
  * //       ExecutionClass: "FLEX" || "STANDARD",
diff --git a/clients/client-glue/src/commands/GetUnfilteredPartitionMetadataCommand.ts b/clients/client-glue/src/commands/GetUnfilteredPartitionMetadataCommand.ts
index 8305540ae91d..bf808825be7d 100644
--- a/clients/client-glue/src/commands/GetUnfilteredPartitionMetadataCommand.ts
+++ b/clients/client-glue/src/commands/GetUnfilteredPartitionMetadataCommand.ts
@@ -14,7 +14,8 @@ import {
 } from "@smithy/types";
 
 import { GlueClientResolvedConfig, ServiceInputTypes, ServiceOutputTypes } from "../GlueClient";
-import { GetUnfilteredPartitionMetadataRequest, GetUnfilteredPartitionMetadataResponse } from "../models/models_1";
+import { GetUnfilteredPartitionMetadataRequest } from "../models/models_1";
+import { GetUnfilteredPartitionMetadataResponse } from "../models/models_2";
 import {
   de_GetUnfilteredPartitionMetadataCommand,
   se_GetUnfilteredPartitionMetadataCommand,
diff --git a/clients/client-glue/src/commands/GetUnfilteredPartitionsMetadataCommand.ts b/clients/client-glue/src/commands/GetUnfilteredPartitionsMetadataCommand.ts
index 560ec65e1796..77c40b0bf9c0 100644
--- a/clients/client-glue/src/commands/GetUnfilteredPartitionsMetadataCommand.ts
+++ b/clients/client-glue/src/commands/GetUnfilteredPartitionsMetadataCommand.ts
@@ -14,8 +14,7 @@ import {
 } from "@smithy/types";
 
 import { GlueClientResolvedConfig, ServiceInputTypes, ServiceOutputTypes } from "../GlueClient";
-import { GetUnfilteredPartitionsMetadataRequest } from "../models/models_1";
-import { GetUnfilteredPartitionsMetadataResponse } from "../models/models_2";
+import { GetUnfilteredPartitionsMetadataRequest, GetUnfilteredPartitionsMetadataResponse } from "../models/models_2";
 import {
   de_GetUnfilteredPartitionsMetadataCommand,
   se_GetUnfilteredPartitionsMetadataCommand,
diff --git a/clients/client-glue/src/commands/UpdateJobCommand.ts b/clients/client-glue/src/commands/UpdateJobCommand.ts
index a2153da4d0db..a5d968bce41b 100644
--- a/clients/client-glue/src/commands/UpdateJobCommand.ts
+++ b/clients/client-glue/src/commands/UpdateJobCommand.ts
@@ -1030,6 +1030,62 @@ export interface UpdateJobCommandOutput extends UpdateJobResponse, __MetadataBea
  *             RecipeVersion: "STRING_VALUE", // required
  *           },
  *         },
+ *         SnowflakeSource: { // SnowflakeSource
+ *           Name: "STRING_VALUE", // required
+ *           Data: { // SnowflakeNodeData
+ *             SourceType: "STRING_VALUE",
+ *             Connection: "<Option>",
+ *             Schema: "STRING_VALUE",
+ *             Table: "STRING_VALUE",
+ *             Database: "STRING_VALUE",
+ *             TempDir: "STRING_VALUE",
+ *             IamRole: "<Option>",
+ *             AdditionalOptions: "<AdditionalOptions>",
+ *             SampleQuery: "STRING_VALUE",
+ *             PreAction: "STRING_VALUE",
+ *             PostAction: "STRING_VALUE",
+ *             Action: "STRING_VALUE",
+ *             Upsert: true || false,
+ *             MergeAction: "STRING_VALUE",
+ *             MergeWhenMatched: "STRING_VALUE",
+ *             MergeWhenNotMatched: "STRING_VALUE",
+ *             MergeClause: "STRING_VALUE",
+ *             StagingTable: "STRING_VALUE",
+ *             SelectedColumns: [
+ *               "<Option>",
+ *             ],
+ *             AutoPushdown: true || false,
+ *             TableSchema: "<OptionList>",
+ *           },
+ *           OutputSchemas: "<GlueSchemas>",
+ *         },
+ *         SnowflakeTarget: { // SnowflakeTarget
+ *           Name: "STRING_VALUE", // required
+ *           Data: {
+ *             SourceType: "STRING_VALUE",
+ *             Connection: "<Option>",
+ *             Schema: "STRING_VALUE",
+ *             Table: "STRING_VALUE",
+ *             Database: "STRING_VALUE",
+ *             TempDir: "STRING_VALUE",
+ *             IamRole: "<Option>",
+ *             AdditionalOptions: "<AdditionalOptions>",
+ *             SampleQuery: "STRING_VALUE",
+ *             PreAction: "STRING_VALUE",
+ *             PostAction: "STRING_VALUE",
+ *             Action: "STRING_VALUE",
+ *             Upsert: true || false,
+ *             MergeAction: "STRING_VALUE",
+ *             MergeWhenMatched: "STRING_VALUE",
+ *             MergeWhenNotMatched: "STRING_VALUE",
+ *             MergeClause: "STRING_VALUE",
+ *             StagingTable: "STRING_VALUE",
+ *             SelectedColumns: "<OptionList>",
+ *             AutoPushdown: true || false,
+ *             TableSchema: "<OptionList>",
+ *           },
+ *           Inputs: "<OneInput>",
+ *         },
  *       },
  *     },
  *     ExecutionClass: "FLEX" || "STANDARD",
diff --git a/clients/client-glue/src/models/models_0.ts b/clients/client-glue/src/models/models_0.ts
index 4ef43d42f88f..f95d3b707310 100644
--- a/clients/client-glue/src/models/models_0.ts
+++ b/clients/client-glue/src/models/models_0.ts
@@ -392,7 +392,7 @@ export interface AmazonRedshiftTarget {
   Name?: string;
 
   /**
-   * <p>Specifies the data of the Amazon Reshift target node.</p>
+   * <p>Specifies the data of the Amazon Redshift target node.</p>
    */
   Data?: AmazonRedshiftNodeData;
 
@@ -5304,6 +5304,175 @@ export interface SelectFromCollection {
   Index: number | undefined;
 }
 
+/**
+ * @public
+ * <p>Specifies configuration for Snowflake nodes in Glue Studio.</p>
+ */
+export interface SnowflakeNodeData {
+  /**
+   * <p>Specifies how retrieved data is specified. Valid values: <code>"table"</code>, <code>
+   *       "query"</code>.</p>
+   */
+  SourceType?: string;
+
+  /**
+   * <p>Specifies a Glue Data Catalog Connection to a Snowflake endpoint.</p>
+   */
+  Connection?: Option;
+
+  /**
+   * <p>Specifies a Snowflake database schema for your node to use.</p>
+   */
+  Schema?: string;
+
+  /**
+   * <p>Specifies a Snowflake table for your node to use.</p>
+   */
+  Table?: string;
+
+  /**
+   * <p>Specifies a Snowflake database for your node to use.</p>
+   */
+  Database?: string;
+
+  /**
+   * <p>Not currently used.</p>
+   */
+  TempDir?: string;
+
+  /**
+   * <p>Not currently used.</p>
+   */
+  IamRole?: Option;
+
+  /**
+   * <p>Specifies additional options passed to the Snowflake connector. If options are specified
+   *       elsewhere in this node, this will take precedence.</p>
+   */
+  AdditionalOptions?: Record<string, string>;
+
+  /**
+   * <p>A SQL string used to retrieve data with the <code>query</code> sourcetype.</p>
+   */
+  SampleQuery?: string;
+
+  /**
+   * <p>A SQL string run before the Snowflake connector performs its standard actions.</p>
+   */
+  PreAction?: string;
+
+  /**
+   * <p>A SQL string run after the Snowflake connector performs its standard actions.</p>
+   */
+  PostAction?: string;
+
+  /**
+   * <p>Specifies what action to take when writing to a table with preexisting data. Valid values: <code>
+   *       append</code>, <code>merge</code>, <code>truncate</code>, <code>drop</code>.</p>
+   */
+  Action?: string;
+
+  /**
+   * <p>Used when Action is <code>append</code>. Specifies the resolution behavior when a row
+   *       already exists. If true, preexisting rows will be updated. If false, those rows will be inserted.</p>
+   */
+  Upsert?: boolean;
+
+  /**
+   * <p>Specifies a merge action. Valid values: <code>simple</code>, <code>custom</code>. If
+   *       simple, merge behavior is defined by <code>MergeWhenMatched</code> and <code>
+   *       MergeWhenNotMatched</code>. If custom, defined by <code>MergeClause</code>.</p>
+   */
+  MergeAction?: string;
+
+  /**
+   * <p>Specifies how to resolve records that match preexisting data when merging. Valid values: <code>
+   *       update</code>, <code>delete</code>.</p>
+   */
+  MergeWhenMatched?: string;
+
+  /**
+   * <p>Specifies how to process records that do not match preexisting data when merging. Valid
+   *       values: <code>insert</code>, <code>none</code>.</p>
+   */
+  MergeWhenNotMatched?: string;
+
+  /**
+   * <p>A SQL statement that specifies a custom merge behavior.</p>
+   */
+  MergeClause?: string;
+
+  /**
+   * <p>The name of a staging table used when performing <code>merge</code> or upsert <code>append</code>
+   *       actions. Data is written to this table, then moved to <code>table</code> by a generated
+   *       postaction.</p>
+   */
+  StagingTable?: string;
+
+  /**
+   * <p>Specifies the columns combined to identify a record when detecting matches for merges and
+   *       upserts. A list of structures with <code>value</code>, <code>label</code> and <code>
+   *       description</code> keys. Each structure describes a column.</p>
+   */
+  SelectedColumns?: Option[];
+
+  /**
+   * <p>Specifies whether automatic query pushdown is enabled. If pushdown
+   *       is enabled, then when a query is run on Spark, if part of the query can be "pushed down" to
+   *       the
+   *       Snowflake server, it is pushed down. This improves performance of some queries.</p>
+   */
+  AutoPushdown?: boolean;
+
+  /**
+   * <p>Manually defines the target schema for the node. A list of structures with <code>value</code>
+   *       , <code>label</code> and <code>description</code> keys. Each structure defines a column.</p>
+   */
+  TableSchema?: Option[];
+}
+
+/**
+ * @public
+ * <p>Specifies a Snowflake data source.</p>
+ */
+export interface SnowflakeSource {
+  /**
+   * <p>The name of the Snowflake data source.</p>
+   */
+  Name: string | undefined;
+
+  /**
+   * <p>Configuration for the Snowflake data source.</p>
+   */
+  Data: SnowflakeNodeData | undefined;
+
+  /**
+   * <p>Specifies user-defined schemas for your output data.</p>
+   */
+  OutputSchemas?: GlueSchema[];
+}
+
+/**
+ * @public
+ * <p>Specifies a Snowflake target.</p>
+ */
+export interface SnowflakeTarget {
+  /**
+   * <p>The name of the Snowflake target.</p>
+   */
+  Name: string | undefined;
+
+  /**
+   * <p>Specifies the data of the Snowflake target node.</p>
+   */
+  Data: SnowflakeNodeData | undefined;
+
+  /**
+   * <p>The nodes that are inputs to the data target.</p>
+   */
+  Inputs?: string[];
+}
+
 /**
  * @public
  * <p>Specifies a connector to an Apache Spark data source.</p>
@@ -8182,66 +8351,3 @@ export class ValidationException extends __BaseException {
     this.Message = opts.Message;
   }
 }
-
-/**
- * @public
- */
-export interface CreateJobResponse {
-  /**
-   * <p>The unique name that was provided for this job definition.</p>
-   */
-  Name?: string;
-}
-
-/**
- * @public
- * <p>The parameters to configure the find matches transform.</p>
- */
-export interface FindMatchesParameters {
-  /**
-   * <p>The name of a column that uniquely identifies rows in the source table. Used to help identify matching records.</p>
-   */
-  PrimaryKeyColumnName?: string;
-
-  /**
-   * <p>The value selected when tuning your transform for a balance between precision and recall.
-   *       A value of 0.5 means no preference; a value of 1.0 means a bias purely for precision, and a
-   *       value of 0.0 means a bias for recall. Because this is a tradeoff, choosing values close to 1.0
-   *       means very low recall, and choosing values close to 0.0 results in very low precision.</p>
-   *          <p>The precision metric indicates how often your model is correct when it predicts a match. </p>
-   *          <p>The recall metric indicates that for an actual match, how often your model predicts the
-   *       match.</p>
-   */
-  PrecisionRecallTradeoff?: number;
-
-  /**
-   * <p>The value that is selected when tuning your transform for a balance between accuracy and
-   *       cost. A value of 0.5 means that the system balances accuracy and cost concerns. A value of 1.0
-   *       means a bias purely for accuracy, which typically results in a higher cost, sometimes
-   *       substantially higher. A value of 0.0 means a bias purely for cost, which results in a less
-   *       accurate <code>FindMatches</code> transform, sometimes with unacceptable accuracy.</p>
-   *          <p>Accuracy measures how well the transform finds true positives and true negatives. Increasing accuracy requires more machine resources and cost. But it also results in increased recall. </p>
-   *          <p>Cost measures how many compute resources, and thus money, are consumed to run the
-   *       transform.</p>
-   */
-  AccuracyCostTradeoff?: number;
-
-  /**
-   * <p>The value to switch on or off to force the output to match the provided labels from users. If the value is <code>True</code>, the <code>find matches</code> transform forces the output to match the provided labels. The results override the normal conflation results. If the value is <code>False</code>, the <code>find matches</code> transform does not ensure all the labels provided are respected, and the results rely on the trained model.</p>
-   *          <p>Note that setting this value to true may increase the conflation execution time.</p>
-   */
-  EnforceProvidedLabels?: boolean;
-}
-
-/**
- * @public
- * @enum
- */
-export const TransformType = {
-  FIND_MATCHES: "FIND_MATCHES",
-} as const;
-
-/**
- * @public
- */
-export type TransformType = (typeof TransformType)[keyof typeof TransformType];
diff --git a/clients/client-glue/src/models/models_1.ts b/clients/client-glue/src/models/models_1.ts
index ca6e1dbd4e39..287361dd2802 100644
--- a/clients/client-glue/src/models/models_1.ts
+++ b/clients/client-glue/src/models/models_1.ts
@@ -20,7 +20,6 @@ import {
   ErrorDetail,
   EventBatchingCondition,
   FederatedDatabase,
-  FindMatchesParameters,
   GlueTable,
   JobRun,
   Partition,
@@ -32,12 +31,74 @@ import {
   SchemaId,
   StorageDescriptor,
   TaskStatusType,
-  TransformType,
   Trigger,
   TriggerType,
   WorkerType,
 } from "./models_0";
 
+/**
+ * @public
+ */
+export interface CreateJobResponse {
+  /**
+   * <p>The unique name that was provided for this job definition.</p>
+   */
+  Name?: string;
+}
+
+/**
+ * @public
+ * <p>The parameters to configure the find matches transform.</p>
+ */
+export interface FindMatchesParameters {
+  /**
+   * <p>The name of a column that uniquely identifies rows in the source table. Used to help identify matching records.</p>
+   */
+  PrimaryKeyColumnName?: string;
+
+  /**
+   * <p>The value selected when tuning your transform for a balance between precision and recall.
+   *       A value of 0.5 means no preference; a value of 1.0 means a bias purely for precision, and a
+   *       value of 0.0 means a bias for recall. Because this is a tradeoff, choosing values close to 1.0
+   *       means very low recall, and choosing values close to 0.0 results in very low precision.</p>
+   *          <p>The precision metric indicates how often your model is correct when it predicts a match. </p>
+   *          <p>The recall metric indicates that for an actual match, how often your model predicts the
+   *       match.</p>
+   */
+  PrecisionRecallTradeoff?: number;
+
+  /**
+   * <p>The value that is selected when tuning your transform for a balance between accuracy and
+   *       cost. A value of 0.5 means that the system balances accuracy and cost concerns. A value of 1.0
+   *       means a bias purely for accuracy, which typically results in a higher cost, sometimes
+   *       substantially higher. A value of 0.0 means a bias purely for cost, which results in a less
+   *       accurate <code>FindMatches</code> transform, sometimes with unacceptable accuracy.</p>
+   *          <p>Accuracy measures how well the transform finds true positives and true negatives. Increasing accuracy requires more machine resources and cost. But it also results in increased recall. </p>
+   *          <p>Cost measures how many compute resources, and thus money, are consumed to run the
+   *       transform.</p>
+   */
+  AccuracyCostTradeoff?: number;
+
+  /**
+   * <p>The value to switch on or off to force the output to match the provided labels from users. If the value is <code>True</code>, the <code>find matches</code> transform forces the output to match the provided labels. The results override the normal conflation results. If the value is <code>False</code>, the <code>find matches</code> transform does not ensure all the labels provided are respected, and the results rely on the trained model.</p>
+   *          <p>Note that setting this value to true may increase the conflation execution time.</p>
+   */
+  EnforceProvidedLabels?: boolean;
+}
+
+/**
+ * @public
+ * @enum
+ */
+export const TransformType = {
+  FIND_MATCHES: "FIND_MATCHES",
+} as const;
+
+/**
+ * @public
+ */
+export type TransformType = (typeof TransformType)[keyof typeof TransformType];
+
 /**
  * @public
  * <p>The algorithm-specific parameters that are associated with the machine learning
@@ -7011,201 +7072,3 @@ export interface GetUnfilteredPartitionMetadataRequest {
    */
   SupportedPermissionTypes: (PermissionType | string)[] | undefined;
 }
-
-/**
- * @public
- */
-export interface GetUnfilteredPartitionMetadataResponse {
-  /**
-   * <p>A Partition object containing the partition metadata.</p>
-   */
-  Partition?: Partition;
-
-  /**
-   * <p>A list of column names that the user has been granted access to.</p>
-   */
-  AuthorizedColumns?: string[];
-
-  /**
-   * <p>A Boolean value that indicates whether the partition location is registered
-   *           with Lake Formation.</p>
-   */
-  IsRegisteredWithLakeFormation?: boolean;
-}
-
-/**
- * @public
- * <p>The operation timed out.</p>
- */
-export class PermissionTypeMismatchException extends __BaseException {
-  readonly name: "PermissionTypeMismatchException" = "PermissionTypeMismatchException";
-  readonly $fault: "client" = "client";
-  /**
-   * <p>There is a mismatch between the SupportedPermissionType used in the query request
-   *           and the permissions defined on the target table.</p>
-   */
-  Message?: string;
-  /**
-   * @internal
-   */
-  constructor(opts: __ExceptionOptionType<PermissionTypeMismatchException, __BaseException>) {
-    super({
-      name: "PermissionTypeMismatchException",
-      $fault: "client",
-      ...opts,
-    });
-    Object.setPrototypeOf(this, PermissionTypeMismatchException.prototype);
-    this.Message = opts.Message;
-  }
-}
-
-/**
- * @public
- */
-export interface GetUnfilteredPartitionsMetadataRequest {
-  /**
-   * <p>The ID of the Data Catalog where the partitions in question reside. If none is provided,
-   *           the AWS account ID is used by default. </p>
-   */
-  CatalogId: string | undefined;
-
-  /**
-   * <p>The name of the catalog database where the partitions reside.</p>
-   */
-  DatabaseName: string | undefined;
-
-  /**
-   * <p>The name of the table that contains the partition.</p>
-   */
-  TableName: string | undefined;
-
-  /**
-   * <p>An expression that filters the partitions to be returned.</p>
-   *          <p>The expression uses SQL syntax similar to the SQL <code>WHERE</code> filter clause. The
-   *       SQL statement parser <a href="http://jsqlparser.sourceforge.net/home.php">JSQLParser</a> parses the expression. </p>
-   *          <p>
-   *             <i>Operators</i>: The following are the operators that you can use in the
-   *         <code>Expression</code> API call:</p>
-   *          <dl>
-   *             <dt>=</dt>
-   *             <dd>
-   *                <p>Checks whether the values of the two operands are equal; if yes, then the condition becomes
-   *             true.</p>
-   *                <p>Example: Assume 'variable a' holds 10 and 'variable b' holds 20. </p>
-   *                <p>(a = b) is not true.</p>
-   *             </dd>
-   *             <dt>< ></dt>
-   *             <dd>
-   *                <p>Checks whether the values of two operands are equal; if the values are not equal,
-   *             then the condition becomes true.</p>
-   *                <p>Example: (a < > b) is true.</p>
-   *             </dd>
-   *             <dt>></dt>
-   *             <dd>
-   *                <p>Checks whether the value of the left operand is greater than the value of the right
-   *             operand; if yes, then the condition becomes true.</p>
-   *                <p>Example: (a > b) is not true.</p>
-   *             </dd>
-   *             <dt><</dt>
-   *             <dd>
-   *                <p>Checks whether the value of the left operand is less than the value of the right
-   *             operand; if yes, then the condition becomes true.</p>
-   *                <p>Example: (a < b) is true.</p>
-   *             </dd>
-   *             <dt>>=</dt>
-   *             <dd>
-   *                <p>Checks whether the value of the left operand is greater than or equal to the value
-   *             of the right operand; if yes, then the condition becomes true.</p>
-   *                <p>Example: (a >= b) is not true.</p>
-   *             </dd>
-   *             <dt><=</dt>
-   *             <dd>
-   *                <p>Checks whether the value of the left operand is less than or equal to the value of
-   *             the right operand; if yes, then the condition becomes true.</p>
-   *                <p>Example: (a <= b) is true.</p>
-   *             </dd>
-   *             <dt>AND, OR, IN, BETWEEN, LIKE, NOT, IS NULL</dt>
-   *             <dd>
-   *                <p>Logical operators.</p>
-   *             </dd>
-   *          </dl>
-   *          <p>
-   *             <i>Supported Partition Key Types</i>: The following are the supported
-   *       partition keys.</p>
-   *          <ul>
-   *             <li>
-   *                <p>
-   *                   <code>string</code>
-   *                </p>
-   *             </li>
-   *             <li>
-   *                <p>
-   *                   <code>date</code>
-   *                </p>
-   *             </li>
-   *             <li>
-   *                <p>
-   *                   <code>timestamp</code>
-   *                </p>
-   *             </li>
-   *             <li>
-   *                <p>
-   *                   <code>int</code>
-   *                </p>
-   *             </li>
-   *             <li>
-   *                <p>
-   *                   <code>bigint</code>
-   *                </p>
-   *             </li>
-   *             <li>
-   *                <p>
-   *                   <code>long</code>
-   *                </p>
-   *             </li>
-   *             <li>
-   *                <p>
-   *                   <code>tinyint</code>
-   *                </p>
-   *             </li>
-   *             <li>
-   *                <p>
-   *                   <code>smallint</code>
-   *                </p>
-   *             </li>
-   *             <li>
-   *                <p>
-   *                   <code>decimal</code>
-   *                </p>
-   *             </li>
-   *          </ul>
-   *          <p>If an type is encountered that is not valid, an exception is thrown. </p>
-   */
-  Expression?: string;
-
-  /**
-   * <p>A structure containing Lake Formation audit context information.</p>
-   */
-  AuditContext?: AuditContext;
-
-  /**
-   * <p>A list of supported permission types. </p>
-   */
-  SupportedPermissionTypes: (PermissionType | string)[] | undefined;
-
-  /**
-   * <p>A continuation token, if this is not the first call to retrieve
-   *       these partitions.</p>
-   */
-  NextToken?: string;
-
-  /**
-   * <p>The segment of the table's partitions to scan in this request.</p>
-   */
-  Segment?: Segment;
-
-  /**
-   * <p>The maximum number of partitions to return in a single response.</p>
-   */
-  MaxResults?: number;
-}
diff --git a/clients/client-glue/src/models/models_2.ts b/clients/client-glue/src/models/models_2.ts
index abd0061efb6f..c2c0b231c75d 100644
--- a/clients/client-glue/src/models/models_2.ts
+++ b/clients/client-glue/src/models/models_2.ts
@@ -87,6 +87,8 @@ import {
   SchemaId,
   SelectFields,
   SelectFromCollection,
+  SnowflakeSource,
+  SnowflakeTarget,
   SourceControlAuthStrategy,
   SourceControlDetails,
   SourceControlProvider,
@@ -117,6 +119,7 @@ import {
   SchemaStatus,
   SchemaVersionNumber,
   SchemaVersionStatus,
+  Segment,
   Session,
   Statement,
   Table,
@@ -127,6 +130,204 @@ import {
   UserDefinedFunctionInput,
 } from "./models_1";
 
+/**
+ * @public
+ */
+export interface GetUnfilteredPartitionMetadataResponse {
+  /**
+   * <p>A Partition object containing the partition metadata.</p>
+   */
+  Partition?: Partition;
+
+  /**
+   * <p>A list of column names that the user has been granted access to.</p>
+   */
+  AuthorizedColumns?: string[];
+
+  /**
+   * <p>A Boolean value that indicates whether the partition location is registered
+   *           with Lake Formation.</p>
+   */
+  IsRegisteredWithLakeFormation?: boolean;
+}
+
+/**
+ * @public
+ * <p>The operation timed out.</p>
+ */
+export class PermissionTypeMismatchException extends __BaseException {
+  readonly name: "PermissionTypeMismatchException" = "PermissionTypeMismatchException";
+  readonly $fault: "client" = "client";
+  /**
+   * <p>There is a mismatch between the SupportedPermissionType used in the query request
+   *           and the permissions defined on the target table.</p>
+   */
+  Message?: string;
+  /**
+   * @internal
+   */
+  constructor(opts: __ExceptionOptionType<PermissionTypeMismatchException, __BaseException>) {
+    super({
+      name: "PermissionTypeMismatchException",
+      $fault: "client",
+      ...opts,
+    });
+    Object.setPrototypeOf(this, PermissionTypeMismatchException.prototype);
+    this.Message = opts.Message;
+  }
+}
+
+/**
+ * @public
+ */
+export interface GetUnfilteredPartitionsMetadataRequest {
+  /**
+   * <p>The ID of the Data Catalog where the partitions in question reside. If none is provided,
+   *           the AWS account ID is used by default. </p>
+   */
+  CatalogId: string | undefined;
+
+  /**
+   * <p>The name of the catalog database where the partitions reside.</p>
+   */
+  DatabaseName: string | undefined;
+
+  /**
+   * <p>The name of the table that contains the partition.</p>
+   */
+  TableName: string | undefined;
+
+  /**
+   * <p>An expression that filters the partitions to be returned.</p>
+   *          <p>The expression uses SQL syntax similar to the SQL <code>WHERE</code> filter clause. The
+   *       SQL statement parser <a href="http://jsqlparser.sourceforge.net/home.php">JSQLParser</a> parses the expression. </p>
+   *          <p>
+   *             <i>Operators</i>: The following are the operators that you can use in the
+   *         <code>Expression</code> API call:</p>
+   *          <dl>
+   *             <dt>=</dt>
+   *             <dd>
+   *                <p>Checks whether the values of the two operands are equal; if yes, then the condition becomes
+   *             true.</p>
+   *                <p>Example: Assume 'variable a' holds 10 and 'variable b' holds 20. </p>
+   *                <p>(a = b) is not true.</p>
+   *             </dd>
+   *             <dt>< ></dt>
+   *             <dd>
+   *                <p>Checks whether the values of two operands are equal; if the values are not equal,
+   *             then the condition becomes true.</p>
+   *                <p>Example: (a < > b) is true.</p>
+   *             </dd>
+   *             <dt>></dt>
+   *             <dd>
+   *                <p>Checks whether the value of the left operand is greater than the value of the right
+   *             operand; if yes, then the condition becomes true.</p>
+   *                <p>Example: (a > b) is not true.</p>
+   *             </dd>
+   *             <dt><</dt>
+   *             <dd>
+   *                <p>Checks whether the value of the left operand is less than the value of the right
+   *             operand; if yes, then the condition becomes true.</p>
+   *                <p>Example: (a < b) is true.</p>
+   *             </dd>
+   *             <dt>>=</dt>
+   *             <dd>
+   *                <p>Checks whether the value of the left operand is greater than or equal to the value
+   *             of the right operand; if yes, then the condition becomes true.</p>
+   *                <p>Example: (a >= b) is not true.</p>
+   *             </dd>
+   *             <dt><=</dt>
+   *             <dd>
+   *                <p>Checks whether the value of the left operand is less than or equal to the value of
+   *             the right operand; if yes, then the condition becomes true.</p>
+   *                <p>Example: (a <= b) is true.</p>
+   *             </dd>
+   *             <dt>AND, OR, IN, BETWEEN, LIKE, NOT, IS NULL</dt>
+   *             <dd>
+   *                <p>Logical operators.</p>
+   *             </dd>
+   *          </dl>
+   *          <p>
+   *             <i>Supported Partition Key Types</i>: The following are the supported
+   *       partition keys.</p>
+   *          <ul>
+   *             <li>
+   *                <p>
+   *                   <code>string</code>
+   *                </p>
+   *             </li>
+   *             <li>
+   *                <p>
+   *                   <code>date</code>
+   *                </p>
+   *             </li>
+   *             <li>
+   *                <p>
+   *                   <code>timestamp</code>
+   *                </p>
+   *             </li>
+   *             <li>
+   *                <p>
+   *                   <code>int</code>
+   *                </p>
+   *             </li>
+   *             <li>
+   *                <p>
+   *                   <code>bigint</code>
+   *                </p>
+   *             </li>
+   *             <li>
+   *                <p>
+   *                   <code>long</code>
+   *                </p>
+   *             </li>
+   *             <li>
+   *                <p>
+   *                   <code>tinyint</code>
+   *                </p>
+   *             </li>
+   *             <li>
+   *                <p>
+   *                   <code>smallint</code>
+   *                </p>
+   *             </li>
+   *             <li>
+   *                <p>
+   *                   <code>decimal</code>
+   *                </p>
+   *             </li>
+   *          </ul>
+   *          <p>If an type is encountered that is not valid, an exception is thrown. </p>
+   */
+  Expression?: string;
+
+  /**
+   * <p>A structure containing Lake Formation audit context information.</p>
+   */
+  AuditContext?: AuditContext;
+
+  /**
+   * <p>A list of supported permission types. </p>
+   */
+  SupportedPermissionTypes: (PermissionType | string)[] | undefined;
+
+  /**
+   * <p>A continuation token, if this is not the first call to retrieve
+   *       these partitions.</p>
+   */
+  NextToken?: string;
+
+  /**
+   * <p>The segment of the table's partitions to scan in this request.</p>
+   */
+  Segment?: Segment;
+
+  /**
+   * <p>The maximum number of partitions to return in a single response.</p>
+   */
+  MaxResults?: number;
+}
+
 /**
  * @public
  * <p>A partition that contains unfiltered metadata.</p>
@@ -4682,6 +4883,16 @@ export interface CodeGenConfigurationNode {
    * <p>Specifies a Glue DataBrew recipe node.</p>
    */
   Recipe?: Recipe;
+
+  /**
+   * <p>Specifies a Snowflake data source.</p>
+   */
+  SnowflakeSource?: SnowflakeSource;
+
+  /**
+   * <p>Specifies a target that writes to a Snowflake data source.</p>
+   */
+  SnowflakeTarget?: SnowflakeTarget;
 }
 
 /**
diff --git a/clients/client-glue/src/protocols/Aws_json1_1.ts b/clients/client-glue/src/protocols/Aws_json1_1.ts
index 64b659e8394f..730ef0b062e1 100644
--- a/clients/client-glue/src/protocols/Aws_json1_1.ts
+++ b/clients/client-glue/src/protocols/Aws_json1_1.ts
@@ -553,7 +553,6 @@ import {
   Filter,
   FilterExpression,
   FilterValue,
-  FindMatchesParameters,
   GlueEncryptionException,
   GlueRecordType,
   GlueSchema,
@@ -643,6 +642,9 @@ import {
   SelectFromCollection,
   SerDeInfo,
   SkewedInfo,
+  SnowflakeNodeData,
+  SnowflakeSource,
+  SnowflakeTarget,
   SourceControlDetails,
   SparkConnectorSource,
   SparkConnectorTarget,
@@ -731,6 +733,7 @@ import {
   EncryptionConfiguration,
   EvaluationMetrics,
   FindMatchesMetrics,
+  FindMatchesParameters,
   GetBlueprintRequest,
   GetBlueprintResponse,
   GetBlueprintRunRequest,
@@ -828,8 +831,6 @@ import {
   GetTriggerRequest,
   GetTriggersRequest,
   GetUnfilteredPartitionMetadataRequest,
-  GetUnfilteredPartitionMetadataResponse,
-  GetUnfilteredPartitionsMetadataRequest,
   GluePolicy,
   GrokClassifier,
   IcebergInput,
@@ -843,7 +844,6 @@ import {
   OpenTableFormatInput,
   PartitionIndex,
   PermissionType,
-  PermissionTypeMismatchException,
   RegistryId,
   ResourceUri,
   S3Encryption,
@@ -892,6 +892,8 @@ import {
   DevEndpointCustomLibraries,
   GetJobResponse,
   GetJobsResponse,
+  GetUnfilteredPartitionMetadataResponse,
+  GetUnfilteredPartitionsMetadataRequest,
   GetUnfilteredPartitionsMetadataResponse,
   GetUnfilteredTableMetadataRequest,
   GetUnfilteredTableMetadataResponse,
@@ -940,6 +942,7 @@ import {
   MetadataKeyValuePair,
   MLTransformNotReadyException,
   NoScheduleException,
+  PermissionTypeMismatchException,
   PropertyPredicate,
   PutDataCatalogEncryptionSettingsRequest,
   PutResourcePolicyRequest,
@@ -15875,6 +15878,8 @@ const se_CodeGenConfigurationNode = (input: CodeGenConfigurationNode, context: _
     S3ParquetSource: _json,
     SelectFields: _json,
     SelectFromCollection: _json,
+    SnowflakeSource: _json,
+    SnowflakeTarget: _json,
     SparkConnectorSource: _json,
     SparkConnectorTarget: _json,
     SparkSQL: _json,
@@ -17161,6 +17166,12 @@ const se_PIIDetection = (input: PIIDetection, context: __SerdeContext): any => {
 
 // se_SkewedInfo omitted.
 
+// se_SnowflakeNodeData omitted.
+
+// se_SnowflakeSource omitted.
+
+// se_SnowflakeTarget omitted.
+
 // se_SortCriteria omitted.
 
 // se_SortCriterion omitted.
@@ -17907,6 +17918,8 @@ const de_CodeGenConfigurationNode = (output: any, context: __SerdeContext): Code
     S3ParquetSource: _json,
     SelectFields: _json,
     SelectFromCollection: _json,
+    SnowflakeSource: _json,
+    SnowflakeTarget: _json,
     SparkConnectorSource: _json,
     SparkConnectorTarget: _json,
     SparkSQL: _json,
@@ -20373,6 +20386,12 @@ const de_SessionList = (output: any, context: __SerdeContext): Session[] => {
 
 // de_SkewedInfo omitted.
 
+// de_SnowflakeNodeData omitted.
+
+// de_SnowflakeSource omitted.
+
+// de_SnowflakeTarget omitted.
+
 // de_SourceControlDetails omitted.
 
 // de_SparkConnectorSource omitted.
diff --git a/codegen/sdk-codegen/aws-models/glue.json b/codegen/sdk-codegen/aws-models/glue.json
index daf0a51fcb8b..fc3ca241335e 100644
--- a/codegen/sdk-codegen/aws-models/glue.json
+++ b/codegen/sdk-codegen/aws-models/glue.json
@@ -2164,7 +2164,7 @@
         "Data": {
           "target": "com.amazonaws.glue#AmazonRedshiftNodeData",
           "traits": {
-            "smithy.api#documentation": "<p>Specifies the data of the Amazon Reshift target node.</p>"
+            "smithy.api#documentation": "<p>Specifies the data of the Amazon Redshift target node.</p>"
           }
         },
         "Inputs": {
@@ -5288,6 +5288,18 @@
           "traits": {
             "smithy.api#documentation": "<p>Specifies a Glue DataBrew recipe node.</p>"
           }
+        },
+        "SnowflakeSource": {
+          "target": "com.amazonaws.glue#SnowflakeSource",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies a Snowflake data source.</p>"
+          }
+        },
+        "SnowflakeTarget": {
+          "target": "com.amazonaws.glue#SnowflakeTarget",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies a target that writes to a Snowflake data source.</p>"
+          }
         }
       },
       "traits": {
@@ -28880,6 +28892,198 @@
         "smithy.api#documentation": "<p>Specifies skewed values in a table. Skewed values are those that occur with very high\n      frequency.</p>"
       }
     },
+    "com.amazonaws.glue#SnowflakeNodeData": {
+      "type": "structure",
+      "members": {
+        "SourceType": {
+          "target": "com.amazonaws.glue#GenericLimitedString",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies how retrieved data is specified. Valid values: <code>\"table\"</code>, <code>\n      \"query\"</code>.</p>"
+          }
+        },
+        "Connection": {
+          "target": "com.amazonaws.glue#Option",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies a Glue Data Catalog Connection to a Snowflake endpoint.</p>"
+          }
+        },
+        "Schema": {
+          "target": "com.amazonaws.glue#GenericString",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies a Snowflake database schema for your node to use.</p>"
+          }
+        },
+        "Table": {
+          "target": "com.amazonaws.glue#GenericString",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies a Snowflake table for your node to use.</p>"
+          }
+        },
+        "Database": {
+          "target": "com.amazonaws.glue#GenericString",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies a Snowflake database for your node to use.</p>"
+          }
+        },
+        "TempDir": {
+          "target": "com.amazonaws.glue#EnclosedInStringProperty",
+          "traits": {
+            "smithy.api#documentation": "<p>Not currently used.</p>"
+          }
+        },
+        "IamRole": {
+          "target": "com.amazonaws.glue#Option",
+          "traits": {
+            "smithy.api#documentation": "<p>Not currently used.</p>"
+          }
+        },
+        "AdditionalOptions": {
+          "target": "com.amazonaws.glue#AdditionalOptions",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies additional options passed to the Snowflake connector. If options are specified\n      elsewhere in this node, this will take precedence.</p>"
+          }
+        },
+        "SampleQuery": {
+          "target": "com.amazonaws.glue#GenericString",
+          "traits": {
+            "smithy.api#documentation": "<p>A SQL string used to retrieve data with the <code>query</code> sourcetype.</p>"
+          }
+        },
+        "PreAction": {
+          "target": "com.amazonaws.glue#GenericString",
+          "traits": {
+            "smithy.api#documentation": "<p>A SQL string run before the Snowflake connector performs its standard actions.</p>"
+          }
+        },
+        "PostAction": {
+          "target": "com.amazonaws.glue#GenericString",
+          "traits": {
+            "smithy.api#documentation": "<p>A SQL string run after the Snowflake connector performs its standard actions.</p>"
+          }
+        },
+        "Action": {
+          "target": "com.amazonaws.glue#GenericString",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies what action to take when writing to a table with preexisting data. Valid values: <code>\n      append</code>, <code>merge</code>, <code>truncate</code>, <code>drop</code>.</p>"
+          }
+        },
+        "Upsert": {
+          "target": "com.amazonaws.glue#BooleanValue",
+          "traits": {
+            "smithy.api#default": false,
+            "smithy.api#documentation": "<p>Used when Action is <code>append</code>. Specifies the resolution behavior when a row\n      already exists. If true, preexisting rows will be updated. If false, those rows will be inserted.</p>"
+          }
+        },
+        "MergeAction": {
+          "target": "com.amazonaws.glue#GenericLimitedString",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies a merge action. Valid values: <code>simple</code>, <code>custom</code>. If\n      simple, merge behavior is defined by <code>MergeWhenMatched</code> and <code>\n      MergeWhenNotMatched</code>. If custom, defined by <code>MergeClause</code>.</p>"
+          }
+        },
+        "MergeWhenMatched": {
+          "target": "com.amazonaws.glue#GenericLimitedString",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies how to resolve records that match preexisting data when merging. Valid values: <code>\n      update</code>, <code>delete</code>.</p>"
+          }
+        },
+        "MergeWhenNotMatched": {
+          "target": "com.amazonaws.glue#GenericLimitedString",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies how to process records that do not match preexisting data when merging. Valid\n      values: <code>insert</code>, <code>none</code>.</p>"
+          }
+        },
+        "MergeClause": {
+          "target": "com.amazonaws.glue#GenericString",
+          "traits": {
+            "smithy.api#documentation": "<p>A SQL statement that specifies a custom merge behavior.</p>"
+          }
+        },
+        "StagingTable": {
+          "target": "com.amazonaws.glue#GenericString",
+          "traits": {
+            "smithy.api#documentation": "<p>The name of a staging table used when performing <code>merge</code> or upsert <code>append</code>\n      actions. Data is written to this table, then moved to <code>table</code> by a generated\n      postaction.</p>"
+          }
+        },
+        "SelectedColumns": {
+          "target": "com.amazonaws.glue#OptionList",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies the columns combined to identify a record when detecting matches for merges and\n      upserts. A list of structures with <code>value</code>, <code>label</code> and <code>\n      description</code> keys. Each structure describes a column.</p>"
+          }
+        },
+        "AutoPushdown": {
+          "target": "com.amazonaws.glue#BooleanValue",
+          "traits": {
+            "smithy.api#default": false,
+            "smithy.api#documentation": "<p>Specifies whether automatic query pushdown is enabled. If pushdown\n      is enabled, then when a query is run on Spark, if part of the query can be \"pushed down\" to\n      the\n      Snowflake server, it is pushed down. This improves performance of some queries.</p>"
+          }
+        },
+        "TableSchema": {
+          "target": "com.amazonaws.glue#OptionList",
+          "traits": {
+            "smithy.api#documentation": "<p>Manually defines the target schema for the node. A list of structures with <code>value</code>\n      , <code>label</code> and <code>description</code> keys. Each structure defines a column.</p>"
+          }
+        }
+      },
+      "traits": {
+        "smithy.api#documentation": "<p>Specifies configuration for Snowflake nodes in Glue Studio.</p>"
+      }
+    },
+    "com.amazonaws.glue#SnowflakeSource": {
+      "type": "structure",
+      "members": {
+        "Name": {
+          "target": "com.amazonaws.glue#NodeName",
+          "traits": {
+            "smithy.api#documentation": "<p>The name of the Snowflake data source.</p>",
+            "smithy.api#required": {}
+          }
+        },
+        "Data": {
+          "target": "com.amazonaws.glue#SnowflakeNodeData",
+          "traits": {
+            "smithy.api#documentation": "<p>Configuration for the Snowflake data source.</p>",
+            "smithy.api#required": {}
+          }
+        },
+        "OutputSchemas": {
+          "target": "com.amazonaws.glue#GlueSchemas",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies user-defined schemas for your output data.</p>"
+          }
+        }
+      },
+      "traits": {
+        "smithy.api#documentation": "<p>Specifies a Snowflake data source.</p>"
+      }
+    },
+    "com.amazonaws.glue#SnowflakeTarget": {
+      "type": "structure",
+      "members": {
+        "Name": {
+          "target": "com.amazonaws.glue#NodeName",
+          "traits": {
+            "smithy.api#documentation": "<p>The name of the Snowflake target.</p>",
+            "smithy.api#required": {}
+          }
+        },
+        "Data": {
+          "target": "com.amazonaws.glue#SnowflakeNodeData",
+          "traits": {
+            "smithy.api#documentation": "<p>Specifies the data of the Snowflake target node.</p>",
+            "smithy.api#required": {}
+          }
+        },
+        "Inputs": {
+          "target": "com.amazonaws.glue#OneInput",
+          "traits": {
+            "smithy.api#documentation": "<p>The nodes that are inputs to the data target.</p>"
+          }
+        }
+      },
+      "traits": {
+        "smithy.api#documentation": "<p>Specifies a Snowflake target.</p>"
+      }
+    },
     "com.amazonaws.glue#Sort": {
       "type": "enum",
       "members": {