Repository: beam Updated Branches: refs/heads/master a9fdc3bc4 -> bc72c9405
Sets desired bundle size on AvroIO.readAll Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/56a1bcea Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/56a1bcea Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/56a1bcea Branch: refs/heads/master Commit: 56a1bceaad8aeec4705c562db4dab08a4d4f36b3 Parents: a9fdc3b Author: Eugene Kirpichov <[email protected]> Authored: Tue Jul 25 20:00:41 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Tue Jul 25 23:22:17 2017 -0700 ---------------------------------------------------------------------- sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/56a1bcea/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java index f201114..bc7fecb 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java @@ -178,6 +178,7 @@ public class AvroIO { return new AutoValue_AvroIO_ReadAll.Builder<GenericRecord>() .setRecordClass(GenericRecord.class) .setSchema(schema) + .setDesiredBundleSizeBytes(64 * 1024 * 1024L) .build(); }
