[
https://issues.apache.org/jira/browse/BEAM-3454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16323754#comment-16323754
]
Ismaël Mejía commented on BEAM-3454:
------------------------------------
Thanks for the hint on the effort to unify this. Both are indeed related but I
don't see one blocking the other, I would prefer that we proceed with having
the combined semantics first. I am still not 100% confident that BEAM-671 is
feasible considering the quirks of AutoValue and Beam's use of static methods.
> Make Unbounded to Bounded conversions on IOs able to trigger on maxNumRecords
> and maxReadTime combined
> ------------------------------------------------------------------------------------------------------
>
> Key: BEAM-3454
> URL: https://issues.apache.org/jira/browse/BEAM-3454
> Project: Beam
> Issue Type: Improvement
> Components: sdk-java-extensions
> Reporter: Ismaël Mejía
> Assignee: Ryan Skraba
> Priority: Minor
>
> Some Beam IOs expose the ability to turn an unbounded source into a bounded
> source. These IOs have two methods withMaxNumRecords and withMaxReadTime.
> Both methods are exclusive at runtime but they shouldn't be because
> BoundedReadFromUnboundedSource supports to combine the options so the first
> condition reached can stop the source if the user provides both..
> There is already a ticket for KafkaIO and a fix for KinesisIO on the works,
> this ticket is to add this to the other Sources (e.g. MqttIO, JmsIO, etc).
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
