valid {
    input.Body.CatalogId == STRING
    input.Body.DatabaseName == STRING
    input.Body.TableName == STRING
    input.Body.PartitionInputList[_].Values[_] == STRING
    input.Body.PartitionInputList[_].LastAccessTime == TIMESTAMP
    input.Body.PartitionInputList[_].StorageDescriptor.Columns[_].Name == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.Columns[_].Type == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.Columns[_].Comment == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.Columns[_].Parameters.STRING == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.Location == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.AdditionalLocations[_] == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.InputFormat == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.OutputFormat == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.Compressed == BOOLEAN
    input.Body.PartitionInputList[_].StorageDescriptor.NumberOfBuckets == INTEGER
    input.Body.PartitionInputList[_].StorageDescriptor.SerdeInfo.Name == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.SerdeInfo.SerializationLibrary == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.SerdeInfo.Parameters.STRING == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.BucketColumns[_] == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.SortColumns[_].Column == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.SortColumns[_].SortOrder == INTEGER
    input.Body.PartitionInputList[_].StorageDescriptor.Parameters.STRING == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.SkewedInfo.SkewedColumnNames[_] == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.SkewedInfo.SkewedColumnValues[_] == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.SkewedInfo.SkewedColumnValueLocationMaps.STRING == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.StoredAsSubDirectories == BOOLEAN
    input.Body.PartitionInputList[_].StorageDescriptor.SchemaReference.SchemaId.SchemaArn == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.SchemaReference.SchemaId.SchemaName == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.SchemaReference.SchemaId.RegistryName == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.SchemaReference.SchemaVersionId == STRING
    input.Body.PartitionInputList[_].StorageDescriptor.SchemaReference.SchemaVersionNumber == LONG
    input.Body.PartitionInputList[_].Parameters.STRING == STRING
    input.Body.PartitionInputList[_].LastAnalyzedTime == TIMESTAMP
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.CatalogId == STRING
    input.Body.ConnectionNameList[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.CatalogId == STRING
    input.Body.DatabaseName == STRING
    input.Body.TableName == STRING
    input.Body.PartitionsToDelete[_].Values[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.CatalogId == STRING
    input.Body.DatabaseName == STRING
    input.Body.TablesToDelete[_] == STRING
    input.Body.TransactionId == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.CatalogId == STRING
    input.Body.DatabaseName == STRING
    input.Body.TableName == STRING
    input.Body.VersionIds[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.Names[_] == STRING
    input.Body.IncludeBlueprint == BOOLEAN
    input.Body.IncludeParameterSpec == BOOLEAN
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.CrawlerNames[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.Names[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.ResultIds[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.DevEndpointNames[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.JobNames[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.CatalogId == STRING
    input.Body.DatabaseName == STRING
    input.Body.TableName == STRING
    input.Body.PartitionsToGet[_].Values[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_TableOptimizerType := [ "compaction", "retention", "orphan_file_deletion" ]

valid {
    input.Body.Entries[_].catalogId == STRING
    input.Body.Entries[_].databaseName == STRING
    input.Body.Entries[_].tableName == STRING
    input.Body.Entries[_].type == enum_TableOptimizerType[_]
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.TriggerNames[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.Names[_] == STRING
    input.Body.IncludeGraph == BOOLEAN
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_InclusionAnnotationValue := [ "INCLUDE", "EXCLUDE" ]

valid {
    input.Body.InclusionAnnotations[_].ProfileId == STRING
    input.Body.InclusionAnnotations[_].StatisticId == STRING
    input.Body.InclusionAnnotations[_].InclusionAnnotation == enum_InclusionAnnotationValue[_]
    input.Body.ClientToken == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.JobName == STRING
    input.Body.JobRunIds[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.CatalogId == STRING
    input.Body.DatabaseName == STRING
    input.Body.TableName == STRING
    input.Body.Entries[_].PartitionValueList[_] == STRING
    input.Body.Entries[_].PartitionInput.Values[_] == STRING
    input.Body.Entries[_].PartitionInput.LastAccessTime == TIMESTAMP
    input.Body.Entries[_].PartitionInput.StorageDescriptor.Columns[_].Name == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.Columns[_].Type == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.Columns[_].Comment == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.Columns[_].Parameters.STRING == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.Location == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.AdditionalLocations[_] == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.InputFormat == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.OutputFormat == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.Compressed == BOOLEAN
    input.Body.Entries[_].PartitionInput.StorageDescriptor.NumberOfBuckets == INTEGER
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SerdeInfo.Name == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SerdeInfo.SerializationLibrary == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SerdeInfo.Parameters.STRING == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.BucketColumns[_] == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SortColumns[_].Column == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SortColumns[_].SortOrder == INTEGER
    input.Body.Entries[_].PartitionInput.StorageDescriptor.Parameters.STRING == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SkewedInfo.SkewedColumnNames[_] == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SkewedInfo.SkewedColumnValues[_] == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SkewedInfo.SkewedColumnValueLocationMaps.STRING == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.StoredAsSubDirectories == BOOLEAN
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SchemaReference.SchemaId.SchemaArn == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SchemaReference.SchemaId.SchemaName == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SchemaReference.SchemaId.RegistryName == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SchemaReference.SchemaVersionId == STRING
    input.Body.Entries[_].PartitionInput.StorageDescriptor.SchemaReference.SchemaVersionNumber == LONG
    input.Body.Entries[_].PartitionInput.Parameters.STRING == STRING
    input.Body.Entries[_].PartitionInput.LastAnalyzedTime == TIMESTAMP
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.RunId == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.RunId == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.TransformId == STRING
    input.Body.TaskRunId == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.SessionId == STRING
    input.Body.Id == INTEGER
    input.Body.RequestOrigin == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_DataFormat := [ "AVRO", "JSON", "PROTOBUF" ]

valid {
    input.Body.DataFormat == enum_DataFormat[_]
    input.Body.SchemaDefinition == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.Name == STRING
    input.Body.Description == STRING
    input.Body.BlueprintLocation == STRING
    input.Body.Tags.STRING == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_Permission := [ "ALL", "SELECT", "ALTER", "DROP", "DELETE", "INSERT", "CREATE_DATABASE", "CREATE_TABLE", "DATA_LOCATION_ACCESS" ]

valid {
    input.Body.Name == STRING
    input.Body.CatalogInput.Description == STRING
    input.Body.CatalogInput.FederatedCatalog.Identifier == STRING
    input.Body.CatalogInput.FederatedCatalog.ConnectionName == STRING
    input.Body.CatalogInput.Parameters.STRING == STRING
    input.Body.CatalogInput.TargetRedshiftCatalog.CatalogArn == STRING
    input.Body.CatalogInput.CatalogProperties.DataLakeAccessProperties.DataLakeAccess == BOOLEAN
    input.Body.CatalogInput.CatalogProperties.DataLakeAccessProperties.DataTransferRole == STRING
    input.Body.CatalogInput.CatalogProperties.DataLakeAccessProperties.KmsKey == STRING
    input.Body.CatalogInput.CatalogProperties.DataLakeAccessProperties.CatalogType == STRING
    input.Body.CatalogInput.CatalogProperties.CustomProperties.STRING == STRING
    input.Body.CatalogInput.CreateTableDefaultPermissions[_].Principal.DataLakePrincipalIdentifier == STRING
    input.Body.CatalogInput.CreateTableDefaultPermissions[_].Permissions[_] == enum_Permission[_]
    input.Body.CatalogInput.CreateDatabaseDefaultPermissions[_].Principal.DataLakePrincipalIdentifier == STRING
    input.Body.CatalogInput.CreateDatabaseDefaultPermissions[_].Permissions[_] == enum_Permission[_]
    input.Body.Tags.STRING == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_CsvHeaderOption := [ "UNKNOWN", "PRESENT", "ABSENT" ]
enum_CsvSerdeOption := [ "OpenCSVSerDe", "LazySimpleSerDe", "None" ]

valid {
    input.Body.GrokClassifier.Classification == STRING
    input.Body.GrokClassifier.Name == STRING
    input.Body.GrokClassifier.GrokPattern == STRING
    input.Body.GrokClassifier.CustomPatterns == STRING
    input.Body.XMLClassifier.Classification == STRING
    input.Body.XMLClassifier.Name == STRING
    input.Body.XMLClassifier.RowTag == STRING
    input.Body.JsonClassifier.Name == STRING
    input.Body.JsonClassifier.JsonPath == STRING
    input.Body.CsvClassifier.Name == STRING
    input.Body.CsvClassifier.Delimiter == STRING
    input.Body.CsvClassifier.QuoteSymbol == STRING
    input.Body.CsvClassifier.ContainsHeader == enum_CsvHeaderOption[_]
    input.Body.CsvClassifier.Header[_] == STRING
    input.Body.CsvClassifier.DisableValueTrimming == BOOLEAN
    input.Body.CsvClassifier.AllowSingleColumn == BOOLEAN
    input.Body.CsvClassifier.CustomDatatypeConfigured == BOOLEAN
    input.Body.CsvClassifier.CustomDatatypes[_] == STRING
    input.Body.CsvClassifier.Serde == enum_CsvSerdeOption[_]
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.DatabaseName == STRING
    input.Body.TableName == STRING
    input.Body.Role == STRING
    input.Body.Schedule == STRING
    input.Body.ColumnNameList[_] == STRING
    input.Body.SampleSize == DOUBLE
    input.Body.CatalogID == STRING
    input.Body.SecurityConfiguration == STRING
    input.Body.Tags.STRING == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_AuthenticationType := [ "BASIC", "OAUTH2", "CUSTOM", "IAM" ]
enum_ComputeEnvironment := [ "SPARK", "ATHENA", "PYTHON" ]
enum_ConnectionType := [ "JDBC", "SFTP", "MONGODB", "KAFKA", "NETWORK", "MARKETPLACE", "CUSTOM", "SALESFORCE", "VIEW_VALIDATION_REDSHIFT", "VIEW_VALIDATION_ATHENA", "GOOGLEADS", "GOOGLESHEETS", "GOOGLEANALYTICS4", "SERVICENOW", "MARKETO", "SAPODATA", "ZENDESK", "JIRACLOUD", "NETSUITEERP", "HUBSPOT", "FACEBOOKADS", "INSTAGRAMADS", "ZOHOCRM", "SALESFORCEPARDOT", "SALESFORCEMARKETINGCLOUD", "SLACK", "STRIPE", "INTERCOM", "SNAPCHATADS" ]
enum_OAuth2GrantType := [ "AUTHORIZATION_CODE", "CLIENT_CREDENTIALS", "JWT_BEARER" ]

valid {
    input.Body.CatalogId == STRING
    input.Body.ConnectionInput.Name == STRING
    input.Body.ConnectionInput.Description == STRING
    input.Body.ConnectionInput.ConnectionType == enum_ConnectionType[_]
    input.Body.ConnectionInput.MatchCriteria[_] == STRING
    input.Body.ConnectionInput.ConnectionProperties.HOST == STRING
    input.Body.ConnectionInput.ConnectionProperties.PORT == STRING
    input.Body.ConnectionInput.ConnectionProperties.USERNAME == STRING
    input.Body.ConnectionInput.ConnectionProperties.PASSWORD == STRING
    input.Body.ConnectionInput.ConnectionProperties.ENCRYPTED_PASSWORD == STRING
    input.Body.ConnectionInput.ConnectionProperties.JDBC_DRIVER_JAR_URI == STRING
    input.Body.ConnectionInput.ConnectionProperties.JDBC_DRIVER_CLASS_NAME == STRING
    input.Body.ConnectionInput.ConnectionProperties.JDBC_ENGINE == STRING
    input.Body.ConnectionInput.ConnectionProperties.JDBC_ENGINE_VERSION == STRING
    input.Body.ConnectionInput.ConnectionProperties.CONFIG_FILES == STRING
    input.Body.ConnectionInput.ConnectionProperties.INSTANCE_ID == STRING
    input.Body.ConnectionInput.ConnectionProperties.JDBC_CONNECTION_URL == STRING
    input.Body.ConnectionInput.ConnectionProperties.JDBC_ENFORCE_SSL == STRING
    input.Body.ConnectionInput.ConnectionProperties.CUSTOM_JDBC_CERT == STRING
    input.Body.ConnectionInput.ConnectionProperties.SKIP_CUSTOM_JDBC_CERT_VALIDATION == STRING
    input.Body.ConnectionInput.ConnectionProperties.CUSTOM_JDBC_CERT_STRING == STRING
    input.Body.ConnectionInput.ConnectionProperties.CONNECTION_URL == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_BOOTSTRAP_SERVERS == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SSL_ENABLED == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_CUSTOM_CERT == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SKIP_CUSTOM_CERT_VALIDATION == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_CLIENT_KEYSTORE == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_CLIENT_KEYSTORE_PASSWORD == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_CLIENT_KEY_PASSWORD == STRING
    input.Body.ConnectionInput.ConnectionProperties.ENCRYPTED_KAFKA_CLIENT_KEYSTORE_PASSWORD == STRING
    input.Body.ConnectionInput.ConnectionProperties.ENCRYPTED_KAFKA_CLIENT_KEY_PASSWORD == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SASL_MECHANISM == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SASL_PLAIN_USERNAME == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SASL_PLAIN_PASSWORD == STRING
    input.Body.ConnectionInput.ConnectionProperties.ENCRYPTED_KAFKA_SASL_PLAIN_PASSWORD == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SASL_SCRAM_USERNAME == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SASL_SCRAM_PASSWORD == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SASL_SCRAM_SECRETS_ARN == STRING
    input.Body.ConnectionInput.ConnectionProperties.ENCRYPTED_KAFKA_SASL_SCRAM_PASSWORD == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SASL_GSSAPI_KEYTAB == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SASL_GSSAPI_KRB5_CONF == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SASL_GSSAPI_SERVICE == STRING
    input.Body.ConnectionInput.ConnectionProperties.KAFKA_SASL_GSSAPI_PRINCIPAL == STRING
    input.Body.ConnectionInput.ConnectionProperties.SECRET_ID == STRING
    input.Body.ConnectionInput.ConnectionProperties.CONNECTOR_URL == STRING
    input.Body.ConnectionInput.ConnectionProperties.CONNECTOR_TYPE == STRING
    input.Body.ConnectionInput.ConnectionProperties.CONNECTOR_CLASS_NAME == STRING
    input.Body.ConnectionInput.ConnectionProperties.ENDPOINT == STRING
    input.Body.ConnectionInput.ConnectionProperties.ENDPOINT_TYPE == STRING
    input.Body.ConnectionInput.ConnectionProperties.ROLE_ARN == STRING
    input.Body.ConnectionInput.ConnectionProperties.REGION == STRING
    input.Body.ConnectionInput.ConnectionProperties.WORKGROUP_NAME == STRING
    input.Body.ConnectionInput.ConnectionProperties.CLUSTER_IDENTIFIER == STRING
    input.Body.ConnectionInput.ConnectionProperties.DATABASE == STRING
    input.Body.ConnectionInput.SparkProperties.STRING == STRING
    input.Body.ConnectionInput.AthenaProperties.STRING == STRING
    input.Body.ConnectionInput.PythonProperties.STRING == STRING
    input.Body.ConnectionInput.PhysicalConnectionRequirements.SubnetId == STRING
    input.Body.ConnectionInput.PhysicalConnectionRequirements.SecurityGroupIdList[_] == STRING
    input.Body.ConnectionInput.PhysicalConnectionRequirements.AvailabilityZone == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.AuthenticationType == enum_AuthenticationType[_]
    input.Body.ConnectionInput.AuthenticationConfiguration.OAuth2Properties.OAuth2GrantType == enum_OAuth2GrantType[_]
    input.Body.ConnectionInput.AuthenticationConfiguration.OAuth2Properties.OAuth2ClientApplication.UserManagedClientApplicationClientId == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.OAuth2Properties.OAuth2ClientApplication.AWSManagedClientApplicationReference == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.OAuth2Properties.TokenUrl == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.OAuth2Properties.TokenUrlParametersMap.STRING == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.OAuth2Properties.AuthorizationCodeProperties.AuthorizationCode == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.OAuth2Properties.AuthorizationCodeProperties.RedirectUri == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.OAuth2Properties.OAuth2Credentials.UserManagedClientApplicationClientSecret == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.OAuth2Properties.OAuth2Credentials.AccessToken == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.OAuth2Properties.OAuth2Credentials.RefreshToken == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.OAuth2Properties.OAuth2Credentials.JwtToken == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.SecretArn == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.KmsKeyArn == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.BasicAuthenticationCredentials.Username == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.BasicAuthenticationCredentials.Password == STRING
    input.Body.ConnectionInput.AuthenticationConfiguration.CustomAuthenticationCredentials.STRING == STRING
    input.Body.ConnectionInput.ValidateCredentials == BOOLEAN
    input.Body.ConnectionInput.ValidateForComputeEnvironments[_] == enum_ComputeEnvironment[_]
    input.Body.Tags.STRING == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_CrawlerLineageSettings := [ "ENABLE", "DISABLE" ]
enum_DeleteBehavior := [ "LOG", "DELETE_FROM_DATABASE", "DEPRECATE_IN_DATABASE" ]
enum_JdbcMetadataEntry := [ "COMMENTS", "RAWTYPES" ]
enum_RecrawlBehavior := [ "CRAWL_EVERYTHING", "CRAWL_NEW_FOLDERS_ONLY", "CRAWL_EVENT_MODE" ]
enum_UpdateBehavior := [ "LOG", "UPDATE_IN_DATABASE" ]

valid {
    input.Body.Name == STRING
    input.Body.Role == STRING
    input.Body.DatabaseName == STRING
    input.Body.Description == STRING
    input.Body.Targets.S3Targets[_].Path == STRING
    input.Body.Targets.S3Targets[_].Exclusions[_] == STRING
    input.Body.Targets.S3Targets[_].ConnectionName == STRING
    input.Body.Targets.S3Targets[_].SampleSize == INTEGER
    input.Body.Targets.S3Targets[_].EventQueueArn == STRING
    input.Body.Targets.S3Targets[_].DlqEventQueueArn == STRING
    input.Body.Targets.JdbcTargets[_].ConnectionName == STRING
    input.Body.Targets.JdbcTargets[_].Path == STRING
    input.Body.Targets.JdbcTargets[_].Exclusions[_] == STRING
    input.Body.Targets.JdbcTargets[_].EnableAdditionalMetadata[_] == enum_JdbcMetadataEntry[_]
    input.Body.Targets.MongoDBTargets[_].ConnectionName == STRING
    input.Body.Targets.MongoDBTargets[_].Path == STRING
    input.Body.Targets.MongoDBTargets[_].ScanAll == BOOLEAN
    input.Body.Targets.DynamoDBTargets[_].Path == STRING
    input.Body.Targets.DynamoDBTargets[_].scanAll == BOOLEAN
    input.Body.Targets.DynamoDBTargets[_].scanRate == DOUBLE
    input.Body.Targets.CatalogTargets[_].DatabaseName == STRING
    input.Body.Targets.CatalogTargets[_].Tables[_] == STRING
    input.Body.Targets.CatalogTargets[_].ConnectionName == STRING
    input.Body.Targets.CatalogTargets[_].EventQueueArn == STRING
    input.Body.Targets.CatalogTargets[_].DlqEventQueueArn == STRING
    input.Body.Targets.DeltaTargets[_].DeltaTables[_] == STRING
    input.Body.Targets.DeltaTargets[_].ConnectionName == STRING
    input.Body.Targets.DeltaTargets[_].WriteManifest == BOOLEAN
    input.Body.Targets.DeltaTargets[_].CreateNativeDeltaTable == BOOLEAN
    input.Body.Targets.IcebergTargets[_].Paths[_] == STRING
    input.Body.Targets.IcebergTargets[_].ConnectionName == STRING
    input.Body.Targets.IcebergTargets[_].Exclusions[_] == STRING
    input.Body.Targets.IcebergTargets[_].MaximumTraversalDepth == INTEGER
    input.Body.Targets.HudiTargets[_].Paths[_] == STRING
    input.Body.Targets.HudiTargets[_].ConnectionName == STRING
    input.Body.Targets.HudiTargets[_].Exclusions[_] == STRING
    input.Body.Targets.HudiTargets[_].MaximumTraversalDepth == INTEGER
    input.Body.Schedule == STRING
    input.Body.Classifiers[_] == STRING
    input.Body.TablePrefix == STRING
    input.Body.SchemaChangePolicy.UpdateBehavior == enum_UpdateBehavior[_]
    input.Body.SchemaChangePolicy.DeleteBehavior == enum_DeleteBehavior[_]
    input.Body.RecrawlPolicy.RecrawlBehavior == enum_RecrawlBehavior[_]
    input.Body.LineageConfiguration.CrawlerLineageSettings == enum_CrawlerLineageSettings[_]
    input.Body.LakeFormationConfiguration.UseLakeFormationCredentials == BOOLEAN
    input.Body.LakeFormationConfiguration.AccountId == STRING
    input.Body.Configuration == STRING
    input.Body.CrawlerSecurityConfiguration == STRING
    input.Body.Tags.STRING == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.Name == STRING
    input.Body.RegexString == STRING
    input.Body.ContextWords[_] == STRING
    input.Body.Tags.STRING == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.Name == STRING
    input.Body.Description == STRING
    input.Body.Ruleset == STRING
    input.Body.Tags.STRING == STRING
    input.Body.TargetTable.TableName == STRING
    input.Body.TargetTable.DatabaseName == STRING
    input.Body.TargetTable.CatalogId == STRING
    input.Body.DataQualitySecurityConfiguration == STRING
    input.Body.ClientToken == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_Permission := [ "ALL", "SELECT", "ALTER", "DROP", "DELETE", "INSERT", "CREATE_DATABASE", "CREATE_TABLE", "DATA_LOCATION_ACCESS" ]

valid {
    input.Body.CatalogId == STRING
    input.Body.DatabaseInput.Name == STRING
    input.Body.DatabaseInput.Description == STRING
    input.Body.DatabaseInput.LocationUri == STRING
    input.Body.DatabaseInput.Parameters.STRING == STRING
    input.Body.DatabaseInput.CreateTableDefaultPermissions[_].Principal.DataLakePrincipalIdentifier == STRING
    input.Body.DatabaseInput.CreateTableDefaultPermissions[_].Permissions[_] == enum_Permission[_]
    input.Body.DatabaseInput.TargetDatabase.CatalogId == STRING
    input.Body.DatabaseInput.TargetDatabase.DatabaseName == STRING
    input.Body.DatabaseInput.TargetDatabase.Region == STRING
    input.Body.DatabaseInput.FederatedDatabase.Identifier == STRING
    input.Body.DatabaseInput.FederatedDatabase.ConnectionName == STRING
    input.Body.Tags.STRING == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_WorkerType := [ "Standard", "G.1X", "G.2X", "G.025X", "G.4X", "G.8X", "Z.2X" ]

valid {
    input.Body.EndpointName == STRING
    input.Body.RoleArn == STRING
    input.Body.SecurityGroupIds[_] == STRING
    input.Body.SubnetId == STRING
    input.Body.PublicKey == STRING
    input.Body.PublicKeys[_] == STRING
    input.Body.NumberOfNodes == INTEGER
    input.Body.WorkerType == enum_WorkerType[_]
    input.Body.GlueVersion == STRING
    input.Body.NumberOfWorkers == INTEGER
    input.Body.ExtraPythonLibsS3Path == STRING
    input.Body.ExtraJarsS3Path == STRING
    input.Body.SecurityConfiguration == STRING
    input.Body.Tags.STRING == STRING
    input.Body.Arguments.STRING == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.IntegrationName == STRING
    input.Body.SourceArn == STRING
    input.Body.TargetArn == STRING
    input.Body.Description == STRING
    input.Body.DataFilter == STRING
    input.Body.KmsKeyId == STRING
    input.Body.AdditionalEncryptionContext.STRING == STRING
    input.Body.Tags[_].key == STRING
    input.Body.Tags[_].value == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.ResourceArn == STRING
    input.Body.SourceProcessingProperties.RoleArn == STRING
    input.Body.TargetProcessingProperties.RoleArn == STRING
    input.Body.TargetProcessingProperties.KmsArn == STRING
    input.Body.TargetProcessingProperties.ConnectionName == STRING
    input.Body.TargetProcessingProperties.EventBusArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_UnnestSpec := [ "TOPLEVEL", "FULL", "NOUNNEST" ]

valid {
    input.Body.ResourceArn == STRING
    input.Body.TableName == STRING
    input.Body.SourceTableConfig.Fields[_] == STRING
    input.Body.SourceTableConfig.FilterPredicate == STRING
    input.Body.SourceTableConfig.PrimaryKey[_] == STRING
    input.Body.SourceTableConfig.RecordUpdateField == STRING
    input.Body.TargetTableConfig.UnnestSpec == enum_UnnestSpec[_]
    input.Body.TargetTableConfig.PartitionSpec[_].FieldName == STRING
    input.Body.TargetTableConfig.PartitionSpec[_].FunctionSpec == STRING
    input.Body.TargetTableConfig.TargetTableName == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_AggFunction := [ "avg", "countDistinct", "count", "first", "last", "kurtosis", "max", "min", "skewness", "stddev_samp", "stddev_pop", "sum", "sumDistinct", "var_samp", "var_pop" ]
enum_CompressionType := [ "gzip", "bzip2" ]
enum_DQStopJobOnFailureTiming := [ "Immediate", "AfterDataLoad" ]
enum_DQTransformOutput := [ "PrimaryInput", "EvaluationResults" ]
enum_DeltaTargetCompressionType := [ "uncompressed", "snappy" ]
enum_ExecutionClass := [ "FLEX", "STANDARD" ]
enum_FilterLogicalOperator := [ "AND", "OR" ]
enum_FilterOperation := [ "EQ", "LT", "GT", "LTE", "GTE", "REGEX", "ISNULL" ]
enum_FilterValueType := [ "COLUMNEXTRACTED", "CONSTANT" ]
enum_GlueRecordType := [ "DATE", "STRING", "TIMESTAMP", "INT", "FLOAT", "LONG", "BIGDECIMAL", "BYTE", "SHORT", "DOUBLE" ]
enum_HudiTargetCompressionType := [ "gzip", "lzo", "uncompressed", "snappy" ]
enum_JDBCConnectionType := [ "sqlserver", "mysql", "oracle", "postgresql", "redshift" ]
enum_JobMode := [ "SCRIPT", "VISUAL", "NOTEBOOK" ]
enum_JoinType := [ "equijoin", "left", "right", "outer", "leftsemi", "leftanti" ]
enum_ParamType := [ "str", "int", "float", "complex", "bool", "list", "null" ]
enum_ParquetCompressionType := [ "snappy", "lzo", "gzip", "uncompressed", "none" ]
enum_PiiType := [ "RowAudit", "RowMasking", "ColumnAudit", "ColumnMasking" ]
enum_QuoteChar := [ "quote", "quillemet", "single_quote", "disabled" ]
enum_Separator := [ "comma", "ctrla", "pipe", "semicolon", "tab" ]
enum_SourceControlAuthStrategy := [ "PERSONAL_ACCESS_TOKEN", "AWS_SECRETS_MANAGER" ]
enum_SourceControlProvider := [ "GITHUB", "GITLAB", "BITBUCKET", "AWS_CODE_COMMIT" ]
enum_StartingPosition := [ "latest", "trim_horizon", "earliest", "timestamp" ]
enum_TargetFormat := [ "json", "csv", "avro", "orc", "parquet", "hudi", "delta" ]
enum_UnionType := [ "ALL", "DISTINCT" ]
enum_UpdateCatalogBehavior := [ "UPDATE_IN_DATABASE", "LOG" ]
enum_WorkerType := [ "Standard", "G.1X", "G.2X", "G.025X", "G.4X", "G.8X", "Z.2X" ]

valid {
    input.Body.Name == STRING
    input.Body.JobMode == enum_JobMode[_]
    input.Body.JobRunQueuingEnabled == BOOLEAN
    input.Body.Description == STRING
    input.Body.LogUri == STRING
    input.Body.Role == STRING
    input.Body.ExecutionProperty.MaxConcurrentRuns == INTEGER
    input.Body.Command.Name == STRING
    input.Body.Command.ScriptLocation == STRING
    input.Body.Command.PythonVersion == STRING
    input.Body.Command.Runtime == STRING
    input.Body.DefaultArguments.STRING == STRING
    input.Body.NonOverridableArguments.STRING == STRING
    input.Body.Connections.Connections[_] == STRING
    input.Body.MaxRetries == INTEGER
    input.Body.AllocatedCapacity == INTEGER
    input.Body.Timeout == INTEGER
    input.Body.MaxCapacity == DOUBLE
    input.Body.SecurityConfiguration == STRING
    input.Body.Tags.STRING == STRING
    input.Body.NotificationProperty.NotifyDelayAfter == INTEGER
    input.Body.GlueVersion == STRING
    input.Body.NumberOfWorkers == INTEGER
    input.Body.WorkerType == enum_WorkerType[_]
    input.Body.CodeGenConfigurationNodes.STRING.AthenaConnectorSource.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.AthenaConnectorSource.ConnectionName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.AthenaConnectorSource.ConnectorName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.AthenaConnectorSource.ConnectionType == STRING
    input.Body.CodeGenConfigurationNodes.STRING.AthenaConnectorSource.ConnectionTable == STRING
    input.Body.CodeGenConfigurationNodes.STRING.AthenaConnectorSource.SchemaName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.AthenaConnectorSource.OutputSchemas[_].Columns[_].Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.AthenaConnectorSource.OutputSchemas[_].Columns[_].Type == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.ConnectionName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.ConnectorName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.ConnectionType == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.FilterPredicate == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.PartitionColumn == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.LowerBound == LONG
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.UpperBound == LONG
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.NumPartitions == LONG
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.JobBookmarkKeys[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.JobBookmarkKeysSortOrder == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.ARRAY == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.BIGINT == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.BINARY == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.BIT == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.BLOB == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.BOOLEAN == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.CHAR == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.CLOB == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.DATALINK == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.DATE == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.DECIMAL == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.DISTINCT == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.DOUBLE == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.FLOAT == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.INTEGER == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.JAVA_OBJECT == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.LONGNVARCHAR == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.LONGVARBINARY == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.LONGVARCHAR == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.NCHAR == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.NCLOB == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.NULL == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.NUMERIC == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.NVARCHAR == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.OTHER == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.REAL == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.REF == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.REF_CURSOR == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.ROWID == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.SMALLINT == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.SQLXML == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.STRUCT == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.TIME == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.TIME_WITH_TIMEZONE == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.TIMESTAMP == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.TIMESTAMP_WITH_TIMEZONE == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.TINYINT == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.VARBINARY == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.AdditionalOptions.DataTypeMapping.VARCHAR == enum_GlueRecordType[_]
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.ConnectionTable == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.Query == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.OutputSchemas[_].Columns[_].Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorSource.OutputSchemas[_].Columns[_].Type == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorSource.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorSource.ConnectionName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorSource.ConnectorName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorSource.ConnectionType == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorSource.AdditionalOptions.STRING == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorSource.OutputSchemas[_].Columns[_].Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorSource.OutputSchemas[_].Columns[_].Type == STRING
    input.Body.CodeGenConfigurationNodes.STRING.CatalogSource.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.CatalogSource.Database == STRING
    input.Body.CodeGenConfigurationNodes.STRING.CatalogSource.Table == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftSource.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftSource.Database == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftSource.Table == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftSource.RedshiftTmpDir == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftSource.TmpDirIAMRole == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogSource.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogSource.Database == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogSource.Table == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogSource.PartitionPredicate == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogSource.AdditionalOptions.BoundedSize == LONG
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogSource.AdditionalOptions.BoundedFiles == LONG
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.Paths[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.CompressionType == enum_CompressionType[_]
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.Exclusions[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.GroupSize == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.GroupFiles == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.Recurse == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.MaxBand == INTEGER
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.MaxFilesInBand == INTEGER
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.AdditionalOptions.BoundedSize == LONG
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.AdditionalOptions.BoundedFiles == LONG
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.AdditionalOptions.EnableSamplePath == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.AdditionalOptions.SamplePath == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.Separator == enum_Separator[_]
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.Escaper == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.QuoteChar == enum_QuoteChar[_]
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.Multiline == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.WithHeader == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.WriteHeader == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.SkipFirst == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.OptimizePerformance == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.OutputSchemas[_].Columns[_].Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CsvSource.OutputSchemas[_].Columns[_].Type == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.Paths[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.CompressionType == enum_CompressionType[_]
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.Exclusions[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.GroupSize == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.GroupFiles == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.Recurse == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.MaxBand == INTEGER
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.MaxFilesInBand == INTEGER
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.AdditionalOptions.BoundedSize == LONG
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.AdditionalOptions.BoundedFiles == LONG
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.AdditionalOptions.EnableSamplePath == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.AdditionalOptions.SamplePath == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.JsonPath == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.Multiline == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.OutputSchemas[_].Columns[_].Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3JsonSource.OutputSchemas[_].Columns[_].Type == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.Paths[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.CompressionType == enum_ParquetCompressionType[_]
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.Exclusions[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.GroupSize == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.GroupFiles == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.Recurse == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.MaxBand == INTEGER
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.MaxFilesInBand == INTEGER
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.AdditionalOptions.BoundedSize == LONG
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.AdditionalOptions.BoundedFiles == LONG
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.AdditionalOptions.EnableSamplePath == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.AdditionalOptions.SamplePath == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.OutputSchemas[_].Columns[_].Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3ParquetSource.OutputSchemas[_].Columns[_].Type == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RelationalCatalogSource.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RelationalCatalogSource.Database == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RelationalCatalogSource.Table == STRING
    input.Body.CodeGenConfigurationNodes.STRING.DynamoDBCatalogSource.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.DynamoDBCatalogSource.Database == STRING
    input.Body.CodeGenConfigurationNodes.STRING.DynamoDBCatalogSource.Table == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorTarget.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorTarget.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorTarget.ConnectionName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorTarget.ConnectionTable == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorTarget.ConnectorName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorTarget.ConnectionType == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorTarget.AdditionalOptions.STRING == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorTarget.OutputSchemas[_].Columns[_].Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.JDBCConnectorTarget.OutputSchemas[_].Columns[_].Type == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorTarget.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorTarget.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorTarget.ConnectionName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorTarget.ConnectorName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorTarget.ConnectionType == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorTarget.AdditionalOptions.STRING == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorTarget.OutputSchemas[_].Columns[_].Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SparkConnectorTarget.OutputSchemas[_].Columns[_].Type == STRING
    input.Body.CodeGenConfigurationNodes.STRING.CatalogTarget.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.CatalogTarget.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.CatalogTarget.PartitionKeys[_][_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.CatalogTarget.Database == STRING
    input.Body.CodeGenConfigurationNodes.STRING.CatalogTarget.Table == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftTarget.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftTarget.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftTarget.Database == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftTarget.Table == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftTarget.RedshiftTmpDir == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftTarget.TmpDirIAMRole == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftTarget.UpsertRedshiftOptions.TableLocation == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftTarget.UpsertRedshiftOptions.ConnectionName == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RedshiftTarget.UpsertRedshiftOptions.UpsertKeys[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogTarget.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogTarget.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogTarget.PartitionKeys[_][_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogTarget.Table == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogTarget.Database == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogTarget.SchemaChangePolicy.EnableUpdateCatalog == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3CatalogTarget.SchemaChangePolicy.UpdateBehavior == enum_UpdateCatalogBehavior[_]
    input.Body.CodeGenConfigurationNodes.STRING.S3GlueParquetTarget.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3GlueParquetTarget.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3GlueParquetTarget.PartitionKeys[_][_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3GlueParquetTarget.Path == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3GlueParquetTarget.Compression == enum_ParquetCompressionType[_]
    input.Body.CodeGenConfigurationNodes.STRING.S3GlueParquetTarget.SchemaChangePolicy.EnableUpdateCatalog == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3GlueParquetTarget.SchemaChangePolicy.UpdateBehavior == enum_UpdateCatalogBehavior[_]
    input.Body.CodeGenConfigurationNodes.STRING.S3GlueParquetTarget.SchemaChangePolicy.Table == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3GlueParquetTarget.SchemaChangePolicy.Database == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3DirectTarget.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3DirectTarget.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3DirectTarget.PartitionKeys[_][_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3DirectTarget.Path == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3DirectTarget.Compression == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3DirectTarget.Format == enum_TargetFormat[_]
    input.Body.CodeGenConfigurationNodes.STRING.S3DirectTarget.SchemaChangePolicy.EnableUpdateCatalog == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.S3DirectTarget.SchemaChangePolicy.UpdateBehavior == enum_UpdateCatalogBehavior[_]
    input.Body.CodeGenConfigurationNodes.STRING.S3DirectTarget.SchemaChangePolicy.Table == STRING
    input.Body.CodeGenConfigurationNodes.STRING.S3DirectTarget.SchemaChangePolicy.Database == STRING
    input.Body.CodeGenConfigurationNodes.STRING.ApplyMapping.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.ApplyMapping.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.ApplyMapping.Mapping[_].ToKey == STRING
    input.Body.CodeGenConfigurationNodes.STRING.ApplyMapping.Mapping[_].FromPath[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.ApplyMapping.Mapping[_].FromType == STRING
    input.Body.CodeGenConfigurationNodes.STRING.ApplyMapping.Mapping[_].ToType == STRING
    input.Body.CodeGenConfigurationNodes.STRING.ApplyMapping.Mapping[_].Dropped == BOOLEAN
    input.Body.CodeGenConfigurationNodes.STRING.ApplyMapping.Mapping[_].Children == NESTED
    input.Body.CodeGenConfigurationNodes.STRING.SelectFields.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SelectFields.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SelectFields.Paths[_][_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.DropFields.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.DropFields.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.DropFields.Paths[_][_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RenameField.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RenameField.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RenameField.SourcePath[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.RenameField.TargetPath[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.Spigot.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.Spigot.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.Spigot.Path == STRING
    input.Body.CodeGenConfigurationNodes.STRING.Spigot.Topk == INTEGER
    input.Body.CodeGenConfigurationNodes.STRING.Spigot.Prob == DOUBLE
    input.Body.CodeGenConfigurationNodes.STRING.Join.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.Join.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.Join.JoinType == enum_JoinType[_]
    input.Body.CodeGenConfigurationNodes.STRING.Join.Columns[_].From == STRING
    input.Body.CodeGenConfigurationNodes.STRING.Join.Columns[_].Keys[_][_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SplitFields.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SplitFields.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SplitFields.Paths[_][_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SelectFromCollection.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SelectFromCollection.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.SelectFromCollection.Index == INTEGER
    input.Body.CodeGenConfigurationNodes.STRING.FillMissingValues.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.FillMissingValues.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.FillMissingValues.ImputedPath == STRING
    input.Body.CodeGenConfigurationNodes.STRING.FillMissingValues.FilledPath == STRING
    input.Body.CodeGenConfigurationNodes.STRING.Filter.Name == STRING
    input.Body.CodeGenConfigurationNodes.STRING.Filter.Inputs[_] == STRING
    input.Body.CodeGenConfigurationNodes.STRING.Filter.LogicalOperator == enum_FilterLogicalOperator[_]
    input.Body.CodeGenConfigurationNodes.STRING.Filter.Filters[_].Operation == enum_Fi