You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2016/05/11 16:31:15 UTC
[8/9] incubator-beam git commit: Exclude OffsetBasedSource
minBundleSize default
Exclude OffsetBasedSource minBundleSize default
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/007526f5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/007526f5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/007526f5
Branch: refs/heads/master
Commit: 007526f5e8d332b4b38d2403272689f40ae291e7
Parents: 43085f7
Author: Scott Wegner <sw...@google.com>
Authored: Tue May 3 14:13:00 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Tue May 10 16:21:27 2016 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/beam/sdk/io/OffsetBasedSource.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/007526f5/sdks/java/core/src/main/java/org/apache/beam/sdk/io/OffsetBasedSource.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/OffsetBasedSource.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/OffsetBasedSource.java
index 126535a..1c033f8 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/OffsetBasedSource.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/OffsetBasedSource.java
@@ -207,7 +207,7 @@ public abstract class OffsetBasedSource<T> extends BoundedSource<T> {
public void populateDisplayData(DisplayData.Builder builder) {
super.populateDisplayData(builder);
builder
- .add(DisplayData.item("minBundleSize", minBundleSize))
+ .addIfNotDefault(DisplayData.item("minBundleSize", minBundleSize), 1L)
.addIfNotDefault(DisplayData.item("startOffset", startOffset), 0L)
.addIfNotDefault(DisplayData.item("endOffset", endOffset), Long.MAX_VALUE);
}