boyuanzz commented on a change in pull request #10897: [BEAM-2939] Java
UnboundedSource SDF wrapper
URL: https://github.com/apache/beam/pull/10897#discussion_r384846699
##
File path: sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java
##
@@ -375,4 +422,361 @@ pub
boyuanzz commented on a change in pull request #10897: [BEAM-2939] Java
UnboundedSource SDF wrapper
URL: https://github.com/apache/beam/pull/10897#discussion_r384840768
##
File path: sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java
##
@@ -185,6 +200,37 @@ priv