laraschmidt commented on a change in pull request #17126:
URL: https://github.com/apache/beam/pull/17126#discussion_r832724240
##########
File path:
sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSchemaIOProvider.java
##########
@@ -74,17 +80,25 @@ public boolean requiresDataSchema() {
@Override
public PCollection.IsBounded isBounded() {
+ // This supports streaming now as well but there's no option for this. The
move to
+ // SchemaTransform will remove the need to provide this.
return PCollection.IsBounded.BOUNDED;
}
/** An abstraction to create schema aware IOs. */
private static class AvroSchemaIO implements SchemaIO, Serializable {
protected final Schema dataSchema;
protected final String location;
+ protected final Duration windowSize;
Review comment:
Done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
