feat(client-cleanrooms): Added support for running incremental ID mapping for rule-based workflows.

Author: awstools

clients/client-cleanrooms/src/commands/CreatePrivacyBudgetTemplateCommand.ts

@@ -97,6 +97,9 @@ export interface CreatePrivacyBudgetTemplateCommandOutput extends CreatePrivacyB
  * @throws {@link ResourceNotFoundException} (client fault)
  *  <p>Request references a resource which does not exist.</p>
  *
+ * @throws {@link ServiceQuotaExceededException} (client fault)
+ *  <p>Request denied because service quota has been exceeded.</p>
+ *
  * @throws {@link ThrottlingException} (client fault)
  *  <p>Request was denied due to request throttling.</p>
  *

clients/client-cleanrooms/src/commands/PopulateIdMappingTableCommand.ts

@@ -40,6 +40,7 @@ export interface PopulateIdMappingTableCommandOutput extends PopulateIdMappingTa
  * const input = { // PopulateIdMappingTableInput
  *   idMappingTableIdentifier: "STRING_VALUE", // required
  *   membershipIdentifier: "STRING_VALUE", // required
+ *   jobType: "BATCH" || "INCREMENTAL" || "DELETE_ONLY",
  * };
  * const command = new PopulateIdMappingTableCommand(input);
  * const response = await client.send(command);

clients/client-cleanrooms/src/models/models_0.ts

@@ -7083,6 +7083,21 @@ export interface ListIdMappingTablesOutput {
   nextToken?: string | undefined;
 }
 
+/**
+ * @public
+ * @enum
+ */
+export const JobType = {
+  BATCH: "BATCH",
+  DELETE_ONLY: "DELETE_ONLY",
+  INCREMENTAL: "INCREMENTAL",
+} as const;
+
+/**
+ * @public
+ */
+export type JobType = (typeof JobType)[keyof typeof JobType];
+
 /**
  * @public
  */
@@ -7098,6 +7113,12 @@ export interface PopulateIdMappingTableInput {
    * @public
    */
   membershipIdentifier: string | undefined;
+
+  /**
+   * <p>The job type of the rule-based ID mapping job. Valid values include:</p> <p> <code>INCREMENTAL</code>: Processes only new or changed data since the last job run. This is the default job type if the ID mapping workflow was created in Entity Resolution with <code>incrementalRunConfig</code> specified.</p> <p> <code>BATCH</code>: Processes all data from the input source, regardless of previous job runs. This is the default job type if the ID mapping workflow was created in Entity Resolution but <code>incrementalRunConfig</code> wasn't specified.</p> <p> <code>DELETE_ONLY</code>: Processes only deletion requests from <code>BatchDeleteUniqueId</code>, which is set in Entity Resolution.</p> <p>For more information about <code>incrementalRunConfig</code> and <code>BatchDeleteUniqueId</code>, see the <a href="https://docs.aws.amazon.com/entityresolution/latest/apireference/Welcome.html">Entity Resolution API Reference</a>.</p>
+   * @public
+   */
+  jobType?: JobType | undefined;
 }
 
 /**
@@ -7805,20 +7826,6 @@ export interface MembershipPaymentConfiguration {
   jobCompute?: MembershipJobComputePaymentConfig | undefined;
 }
 
-/**
- * @public
- * @enum
- */
-export const MembershipQueryLogStatus = {
-  DISABLED: "DISABLED",
-  ENABLED: "ENABLED",
-} as const;
-
-/**
- * @public
- */
-export type MembershipQueryLogStatus = (typeof MembershipQueryLogStatus)[keyof typeof MembershipQueryLogStatus];
-
 /**
  * @internal
  */

clients/client-cleanrooms/src/models/models_1.ts

@@ -9,7 +9,6 @@ import {
   MembershipPaymentConfiguration,
   MembershipProtectedJobResultConfiguration,
   MembershipProtectedQueryResultConfiguration,
-  MembershipQueryLogStatus,
   MLMemberAbilities,
   PrivacyBudget,
   PrivacyBudgetTemplateAutoRefresh,
@@ -18,6 +17,20 @@ import {
   ProtectedQueryS3OutputConfiguration,
 } from "./models_0";
 
+/**
+ * @public
+ * @enum
+ */
+export const MembershipQueryLogStatus = {
+  DISABLED: "DISABLED",
+  ENABLED: "ENABLED",
+} as const;
+
+/**
+ * @public
+ */
+export type MembershipQueryLogStatus = (typeof MembershipQueryLogStatus)[keyof typeof MembershipQueryLogStatus];
+
 /**
  * @public
  */

clients/client-cleanrooms/src/protocols/Aws_restJson1.ts

@@ -1904,11 +1904,18 @@ export const se_PopulateIdMappingTableCommand = async (
   context: __SerdeContext
 ): Promise<__HttpRequest> => {
   const b = rb(input, context);
-  const headers: any = {};
+  const headers: any = {
+    "content-type": "application/json",
+  };
   b.bp("/memberships/{membershipIdentifier}/idmappingtables/{idMappingTableIdentifier}/populate");
   b.p("idMappingTableIdentifier", () => input.idMappingTableIdentifier!, "{idMappingTableIdentifier}", false);
   b.p("membershipIdentifier", () => input.membershipIdentifier!, "{membershipIdentifier}", false);
   let body: any;
+  body = JSON.stringify(
+    take(input, {
+      jobType: [],
+    })
+  );
   b.m("POST").h(headers).b(body);
   return b.build();
 };