diff --git a/airbyte-config/config-models/src/main/resources/types/StandardSync.yaml b/airbyte-config/config-models/src/main/resources/types/StandardSync.yaml index 2fabb184b4ea..c4e679e408d8 100644 --- a/airbyte-config/config-models/src/main/resources/types/StandardSync.yaml +++ b/airbyte-config/config-models/src/main/resources/types/StandardSync.yaml @@ -42,6 +42,11 @@ properties: type: string catalog: existingJavaType: io.airbyte.protocol.models.ConfiguredAirbyteCatalog + fieldSelectionData: + type: object + description: A map of StreamDescriptor to an indicator of whether field selection is enabled for that stream. + additionalProperties: + type: boolean status: type: string enum: diff --git a/airbyte-config/config-persistence/src/main/java/io/airbyte/config/persistence/DbConverter.java b/airbyte-config/config-persistence/src/main/java/io/airbyte/config/persistence/DbConverter.java index 4ae0619a1257..9c5240fe6967 100644 --- a/airbyte-config/config-persistence/src/main/java/io/airbyte/config/persistence/DbConverter.java +++ b/airbyte-config/config-persistence/src/main/java/io/airbyte/config/persistence/DbConverter.java @@ -20,6 +20,7 @@ import io.airbyte.config.ActorDefinitionResourceRequirements; import io.airbyte.config.DestinationConnection; import io.airbyte.config.DestinationOAuthParameter; +import io.airbyte.config.FieldSelectionData; import io.airbyte.config.Geography; import io.airbyte.config.JobSyncConfig.NamespaceDefinitionType; import io.airbyte.config.Notification; @@ -65,6 +66,8 @@ public static StandardSync buildStandardSync(final Record record, final List standardSyncs() { .withSourceId(SOURCE_ID_1) .withDestinationId(DESTINATION_ID_1) .withCatalog(getConfiguredCatalog()) + .withFieldSelectionData(new FieldSelectionData().withAdditionalProperty("foo", true)) .withName("standard-sync-1") .withManual(true) .withNamespaceDefinition(NamespaceDefinitionType.CUSTOMFORMAT)