Repository: beam Updated Branches: refs/heads/master 63bcd3916 -> 82b81e518
Make WriteFiles config publicly readable Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0093cf5e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0093cf5e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0093cf5e Branch: refs/heads/master Commit: 0093cf5e53cbe6f3e6d61f91ea44d0d1b0f0f901 Parents: 2ee7d69 Author: Kenneth Knowles <k...@google.com> Authored: Fri May 26 16:06:57 2017 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Wed May 31 20:54:22 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/beam/sdk/io/WriteFiles.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/0093cf5e/sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java index 0786e5d..2fd10ac 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java @@ -97,7 +97,7 @@ public class WriteFiles<T> extends PTransform<PCollection<T>, PDone> { // when a pipeline is updated. @Nullable private final ValueProvider<Integer> numShardsProvider; - private boolean windowedWrites; + private final boolean windowedWrites; /** * Creates a {@link WriteFiles} transform that writes to the given {@link FileBasedSink}, letting @@ -167,6 +167,13 @@ public class WriteFiles<T> extends PTransform<PCollection<T>, PDone> { } /** + * Returns whether or not to perform windowed writes. + */ + public boolean isWindowedWrites() { + return windowedWrites; + } + + /** * Gets the {@link PTransform} that will be used to determine sharding. This can be either a * static number of shards (as following a call to {@link #withNumShards(int)}), dynamic (by * {@link #withSharding(PTransform)}), or runner-determined (by {@link
