Description of changes:
Update the RetrievalFactory implementations to utilize the pre-existing StreamIdentifier from the StreamConfig argument.
A StreamIdentifier provided from Scheduler (through StreamConfig) may contain additional information such as the stream's ARN, and we don't need to reconstruct it from ShardInfo since it is already available here.
By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.
Issue #, if available: N/A.
Description of changes: Update the
RetrievalFactoryimplementations to utilize the pre-existingStreamIdentifierfrom theStreamConfigargument. AStreamIdentifierprovided fromScheduler(throughStreamConfig) may contain additional information such as the stream's ARN, and we don't need to reconstruct it fromShardInfosince it is already available here.By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.