Ismaël Mejía created BEAM-3405:
----------------------------------
Summary: Make maxNumRecords a long for KinesisIO
Key: BEAM-3405
URL: https://issues.apache.org/jira/browse/BEAM-3405
Project: Beam
Issue Type: Improvement
Components: sdk-java-extensions
Affects Versions: 2.3.0
Reporter: Ismaël Mejía
Assignee: Ismaël Mejía
Priority: Minor
KinesisIO as other unbounded sources has a method for bounded reads that sets a
maximum number of records to be read, this PR makes this parameter a long as it
is the case with other IOs. It also simplifies the logic for the bounded read.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
