@@ -84,6 +84,7 @@ import {
8484 GoogleAnalyticsConnectorProfileProperties ,
8585 GoogleAnalyticsMetadata ,
8686 GoogleAnalyticsSourceProperties ,
87+ IncrementalPullConfig ,
8788 InforNexusConnectorProfileCredentials ,
8889 InforNexusConnectorProfileProperties ,
8990 InforNexusMetadata ,
@@ -147,6 +148,7 @@ import {
147148 VeevaConnectorProfileProperties ,
148149 VeevaMetadata ,
149150 VeevaSourceProperties ,
151+ WriteOperationType ,
150152 ZendeskConnectorProfileCredentials ,
151153 ZendeskConnectorProfileProperties ,
152154 ZendeskMetadata ,
@@ -1671,10 +1673,14 @@ export const deserializeAws_restJson1StartFlowCommand = async (
16711673 }
16721674 const contents : StartFlowCommandOutput = {
16731675 $metadata : deserializeMetadata ( output ) ,
1676+ executionId : undefined ,
16741677 flowArn : undefined ,
16751678 flowStatus : undefined ,
16761679 } ;
16771680 const data : any = await parseBody ( output . body , context ) ;
1681+ if ( data . executionId !== undefined && data . executionId !== null ) {
1682+ contents . executionId = data . executionId ;
1683+ }
16781684 if ( data . flowArn !== undefined && data . flowArn !== null ) {
16791685 contents . flowArn = data . flowArn ;
16801686 }
@@ -2626,6 +2632,16 @@ const serializeAws_restJson1GoogleAnalyticsSourceProperties = (
26262632 } ;
26272633} ;
26282634
2635+ const serializeAws_restJson1IdFieldNameList = ( input : string [ ] , context : __SerdeContext ) : any => {
2636+ return input . map ( ( entry ) => entry ) ;
2637+ } ;
2638+
2639+ const serializeAws_restJson1IncrementalPullConfig = ( input : IncrementalPullConfig , context : __SerdeContext ) : any => {
2640+ return {
2641+ ...( input . datetimeTypeFieldName !== undefined && { datetimeTypeFieldName : input . datetimeTypeFieldName } ) ,
2642+ } ;
2643+ } ;
2644+
26292645const serializeAws_restJson1InforNexusConnectorProfileCredentials = (
26302646 input : InforNexusConnectorProfileCredentials ,
26312647 context : __SerdeContext
@@ -2769,6 +2785,7 @@ const serializeAws_restJson1SalesforceConnectorProfileCredentials = (
27692785) : any => {
27702786 return {
27712787 ...( input . accessToken !== undefined && { accessToken : input . accessToken } ) ,
2788+ ...( input . clientCredentialsArn !== undefined && { clientCredentialsArn : input . clientCredentialsArn } ) ,
27722789 ...( input . oAuthRequest !== undefined && {
27732790 oAuthRequest : serializeAws_restJson1ConnectorOAuthRequest ( input . oAuthRequest , context ) ,
27742791 } ) ,
@@ -2794,7 +2811,11 @@ const serializeAws_restJson1SalesforceDestinationProperties = (
27942811 ...( input . errorHandlingConfig !== undefined && {
27952812 errorHandlingConfig : serializeAws_restJson1ErrorHandlingConfig ( input . errorHandlingConfig , context ) ,
27962813 } ) ,
2814+ ...( input . idFieldNames !== undefined && {
2815+ idFieldNames : serializeAws_restJson1IdFieldNameList ( input . idFieldNames , context ) ,
2816+ } ) ,
27972817 ...( input . object !== undefined && { object : input . object } ) ,
2818+ ...( input . writeOperationType !== undefined && { writeOperationType : input . writeOperationType } ) ,
27982819 } ;
27992820} ;
28002821
@@ -2997,6 +3018,9 @@ const serializeAws_restJson1SourceFlowConfig = (input: SourceFlowConfig, context
29973018 return {
29983019 ...( input . connectorProfileName !== undefined && { connectorProfileName : input . connectorProfileName } ) ,
29993020 ...( input . connectorType !== undefined && { connectorType : input . connectorType } ) ,
3021+ ...( input . incrementalPullConfig !== undefined && {
3022+ incrementalPullConfig : serializeAws_restJson1IncrementalPullConfig ( input . incrementalPullConfig , context ) ,
3023+ } ) ,
30003024 ...( input . sourceConnectorProperties !== undefined && {
30013025 sourceConnectorProperties : serializeAws_restJson1SourceConnectorProperties (
30023026 input . sourceConnectorProperties ,
@@ -3541,7 +3565,12 @@ const deserializeAws_restJson1DestinationFieldProperties = (
35413565 return {
35423566 isCreatable : output . isCreatable !== undefined && output . isCreatable !== null ? output . isCreatable : undefined ,
35433567 isNullable : output . isNullable !== undefined && output . isNullable !== null ? output . isNullable : undefined ,
3568+ isUpdatable : output . isUpdatable !== undefined && output . isUpdatable !== null ? output . isUpdatable : undefined ,
35443569 isUpsertable : output . isUpsertable !== undefined && output . isUpsertable !== null ? output . isUpsertable : undefined ,
3570+ supportedWriteOperations :
3571+ output . supportedWriteOperations !== undefined && output . supportedWriteOperations !== null
3572+ ? deserializeAws_restJson1SupportedWriteOperationList ( output . supportedWriteOperations , context )
3573+ : undefined ,
35453574 } as any ;
35463575} ;
35473576
@@ -3768,6 +3797,19 @@ const deserializeAws_restJson1GoogleAnalyticsSourceProperties = (
37683797 } as any ;
37693798} ;
37703799
3800+ const deserializeAws_restJson1IdFieldNameList = ( output : any , context : __SerdeContext ) : string [ ] => {
3801+ return ( output || [ ] ) . map ( ( entry : any ) => entry ) ;
3802+ } ;
3803+
3804+ const deserializeAws_restJson1IncrementalPullConfig = ( output : any , context : __SerdeContext ) : IncrementalPullConfig => {
3805+ return {
3806+ datetimeTypeFieldName :
3807+ output . datetimeTypeFieldName !== undefined && output . datetimeTypeFieldName !== null
3808+ ? output . datetimeTypeFieldName
3809+ : undefined ,
3810+ } as any ;
3811+ } ;
3812+
37713813const deserializeAws_restJson1InforNexusConnectorProfileProperties = (
37723814 output : any ,
37733815 context : __SerdeContext
@@ -3922,7 +3964,15 @@ const deserializeAws_restJson1SalesforceDestinationProperties = (
39223964 output . errorHandlingConfig !== undefined && output . errorHandlingConfig !== null
39233965 ? deserializeAws_restJson1ErrorHandlingConfig ( output . errorHandlingConfig , context )
39243966 : undefined ,
3967+ idFieldNames :
3968+ output . idFieldNames !== undefined && output . idFieldNames !== null
3969+ ? deserializeAws_restJson1IdFieldNameList ( output . idFieldNames , context )
3970+ : undefined ,
39253971 object : output . object !== undefined && output . object !== null ? output . object : undefined ,
3972+ writeOperationType :
3973+ output . writeOperationType !== undefined && output . writeOperationType !== null
3974+ ? output . writeOperationType
3975+ : undefined ,
39263976 } as any ;
39273977} ;
39283978
@@ -4176,6 +4226,10 @@ const deserializeAws_restJson1SourceFlowConfig = (output: any, context: __SerdeC
41764226 : undefined ,
41774227 connectorType :
41784228 output . connectorType !== undefined && output . connectorType !== null ? output . connectorType : undefined ,
4229+ incrementalPullConfig :
4230+ output . incrementalPullConfig !== undefined && output . incrementalPullConfig !== null
4231+ ? deserializeAws_restJson1IncrementalPullConfig ( output . incrementalPullConfig , context )
4232+ : undefined ,
41794233 sourceConnectorProperties :
41804234 output . sourceConnectorProperties !== undefined && output . sourceConnectorProperties !== null
41814235 ? deserializeAws_restJson1SourceConnectorProperties ( output . sourceConnectorProperties , context )
@@ -4199,6 +4253,13 @@ const deserializeAws_restJson1SupportedValueList = (output: any, context: __Serd
41994253 return ( output || [ ] ) . map ( ( entry : any ) => entry ) ;
42004254} ;
42014255
4256+ const deserializeAws_restJson1SupportedWriteOperationList = (
4257+ output : any ,
4258+ context : __SerdeContext
4259+ ) : ( WriteOperationType | string ) [ ] => {
4260+ return ( output || [ ] ) . map ( ( entry : any ) => entry ) ;
4261+ } ;
4262+
42024263const deserializeAws_restJson1TagMap = ( output : any , context : __SerdeContext ) : { [ key : string ] : string } => {
42034264 return Object . entries ( output ) . reduce (
42044265 ( acc : { [ key : string ] : string } , [ key , value ] : [ string , any ] ) => ( {
0 commit comments