Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Destinations CDK: Add interfaces for operations by responsibility #38107

Merged
merged 1 commit into from
May 17, 2024

Conversation

gisripa
Copy link
Contributor

@gisripa gisripa commented May 9, 2024

What

New interfaces to plug into the existing AsyncStreamConsumer.

image

Review guide

Minor cleanup of Existing code.

  • remove TyperDeduperTransaction.kt and unified the methods to TyperDeduperUtil.kt
  • convert TyperDeduperUtil from class to object

New code.

  • SyncOperation, StreamOperation, StorageOperation (see sequence diagram).
  • Default implementations:
    • DefaultSyncOperation - Sync level orchestration logic
    • AbstractStreamOperation - Stream specific orchestration logic
      • StagingStreamOperation - Concrete implementation accepts SerializableBuffer for all staging destinations
      • StandardStreamOperation - Pass through implementation which using Stream<PartialAirbyteMessage> as the records data type
    • StorageOperation - See reference implementation BigQueryStorageOperation in Destination BigQuery: Adapt to newer interface for Sync operations #38132

User Impact

Can this PR be safely reverted and rolled back?

  • YES 💚
  • NO ❌

Copy link

vercel bot commented May 9, 2024

The latest updates on your projects. Learn more about Vercel for Git ↗︎

1 Ignored Deployment
Name Status Preview Comments Updated (UTC)
airbyte-docs ⬜️ Ignored (Inspect) Visit Preview May 17, 2024 8:08pm

@octavia-squidington-iii octavia-squidington-iii added the CDK Connector Development Kit label May 9, 2024
Copy link
Contributor Author

gisripa commented May 9, 2024

@gisripa gisripa force-pushed the cdk-ops-refactor branch 2 times, most recently from 726b1fe to 75b2191 Compare May 10, 2024 18:47
@gisripa gisripa changed the base branch from master to edgao/catalog_parser_improvements May 10, 2024 23:06
@gisripa gisripa force-pushed the cdk-ops-refactor branch from 75b2191 to 3cd7744 Compare May 10, 2024 23:06
@gisripa gisripa changed the base branch from edgao/catalog_parser_improvements to cdk_generation_id May 12, 2024 19:17
@gisripa gisripa force-pushed the cdk-ops-refactor branch from 3cd7744 to 3586a5c Compare May 12, 2024 19:17
@gisripa gisripa force-pushed the cdk-ops-refactor branch from 3586a5c to c5c5f41 Compare May 12, 2024 22:52
@gisripa gisripa changed the base branch from cdk_generation_id to gireesh/05-10-Bigquery_cdk_signature_changes May 12, 2024 22:52
@gisripa gisripa force-pushed the gireesh/05-10-Bigquery_cdk_signature_changes branch from cf090a7 to 9c0dfc5 Compare May 13, 2024 03:13
@gisripa gisripa force-pushed the cdk-ops-refactor branch from c5c5f41 to a8c0782 Compare May 13, 2024 03:13
@gisripa gisripa force-pushed the gireesh/05-10-Bigquery_cdk_signature_changes branch from 9c0dfc5 to 4328f0a Compare May 13, 2024 03:27
@gisripa gisripa force-pushed the cdk-ops-refactor branch from a8c0782 to f13bbc2 Compare May 13, 2024 03:27
@gisripa gisripa force-pushed the gireesh/05-10-Bigquery_cdk_signature_changes branch from 4328f0a to 3de0d51 Compare May 13, 2024 16:36
@gisripa gisripa force-pushed the cdk-ops-refactor branch from f13bbc2 to 801d603 Compare May 13, 2024 16:36
@gisripa gisripa force-pushed the gireesh/05-10-Bigquery_cdk_signature_changes branch from 3de0d51 to 6bf8684 Compare May 13, 2024 17:43
@gisripa gisripa force-pushed the cdk-ops-refactor branch from 801d603 to eefa86b Compare May 13, 2024 17:43
Base automatically changed from gireesh/05-10-Bigquery_cdk_signature_changes to master May 13, 2024 18:09
@gisripa gisripa force-pushed the cdk-ops-refactor branch from eefa86b to 72bf6f6 Compare May 13, 2024 19:20
@gisripa gisripa force-pushed the cdk-ops-refactor branch from 4097d3b to b8fd6bd Compare May 15, 2024 19:50
@edgao edgao force-pushed the cdk-ops-refactor branch 2 times, most recently from f40bd48 to e7f388f Compare May 15, 2024 22:28
@gisripa gisripa force-pushed the cdk-ops-refactor branch 3 times, most recently from 2f3380f to 4d2fbca Compare May 16, 2024 02:52
@gisripa gisripa mentioned this pull request May 16, 2024
2 tasks
@gisripa gisripa force-pushed the cdk-ops-refactor branch from 4d2fbca to 9c8ff62 Compare May 16, 2024 06:53
@edgao edgao force-pushed the cdk-ops-refactor branch 3 times, most recently from 23be58e to 168f866 Compare May 16, 2024 18:22
@gisripa gisripa force-pushed the cdk-ops-refactor branch 3 times, most recently from ee99124 to 130b089 Compare May 16, 2024 19:46
@gisripa gisripa changed the title Connector operations by responsibility Destinations CDK: Add interfaces for operations by responsibility May 16, 2024
@gisripa gisripa force-pushed the cdk-ops-refactor branch 2 times, most recently from 692bc34 to fb905b5 Compare May 16, 2024 23:41
@edgao edgao force-pushed the cdk-ops-refactor branch 3 times, most recently from ae5741a to c8281d5 Compare May 17, 2024 18:47
@gisripa gisripa marked this pull request as ready for review May 17, 2024 19:15
@gisripa gisripa requested review from a team as code owners May 17, 2024 19:15
@gisripa gisripa force-pushed the cdk-ops-refactor branch from c8281d5 to 4dd2733 Compare May 17, 2024 20:08
@gisripa gisripa merged commit b47f80f into master May 17, 2024
26 checks passed
@gisripa gisripa deleted the cdk-ops-refactor branch May 17, 2024 20:40
@edgao edgao mentioned this pull request May 17, 2024
2 tasks
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
CDK Connector Development Kit
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants