Details
-
Improvement
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
2.15.0
Description
The documented signature for DoFn.SplitRestriction isĀ
List<RestrictionT> splitRestriction( InputT element, RestrictionT restriction);
This fails to compile with, for example:
@SplitRestriction split(long, OffsetRange): Must return void
It looks like the correct signature is:
void splitRestriction(InputT element, RestrictionT restriction, OutputReceiver<RestrictionT> restriction);
Attachments
Issue Links
- links to