Skip to content

Allow GetRecordsResponseAdapter to provide ProcessRecordsInput Mapping - #1713

Merged
chenylee-aws merged 1 commit into
awslabs:masterfrom
yitianwang18:feat/customize-processrecordsinput
Mar 10, 2026
Merged

chenylee-aws merged 1 commit into
awslabs:masterfrom
yitianwang18:feat/customize-processrecordsinput

Conversation

@yitianwang18

Copy link
Copy Markdown
Contributor

Issue #, if available:

As a follow up to PR #1479, this PR allows DataFetcher Implementations that provides GetRecordsResponseAdapter to further customize its mapping to ProcessRecordsInput.

Description of changes:

  • Add default implementation of toProcessRecordsInput() method in GetRecordsResponseAdapter.
  • Update Both BlockingRecordsPublisher and PrefetchRecordsPublisher to use the adapter's method to produce ProcessRecordsInput.
  • Update AsynchronousGetRecordsRetrievalStrategy to invoke DataFetcherResult::acceptAdapter in its getRecordsAdapter() method to be consistent with SynchronousGetRecordsRetrievalStrategy.

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.

@chenylee-aws
chenylee-aws merged commit 3968de1 into awslabs:master Mar 10, 2026
4 of 5 checks passed

This branch had an error being deployed

1 failed deployment
manual-approval β€” 14a3fe1b Deployed Mar 6, 2026 by yitianwang18 via wait-for-approval #90
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants