You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bo...@apache.org on 2020/11/18 20:39:06 UTC

[beam] branch master updated: Make UsesTestStream extend UsesUnboundedPCollections for exclusion in batch only runners

This is an automated email from the ASF dual-hosted git repository.

boyuanz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new d4c82ec  Make UsesTestStream extend UsesUnboundedPCollections for exclusion in batch only runners
     new 434bce5  Merge pull request #13376 from Make UsesTestStream extend UsesUnboundedPCollections for exclusion in batch-only runners
d4c82ec is described below

commit d4c82ecb6723123dd2a2d3422dcc25e5009db48e
Author: Kenneth Knowles <kl...@google.com>
AuthorDate: Wed Nov 18 09:43:55 2020 -0800

    Make UsesTestStream extend UsesUnboundedPCollections for exclusion in batch only runners
---
 .../core/src/main/java/org/apache/beam/sdk/testing/UsesTestStream.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesTestStream.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesTestStream.java
index 4cd0920..f3e8302 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesTestStream.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesTestStream.java
@@ -24,4 +24,4 @@ import org.apache.beam.sdk.annotations.Internal;
  * special feature currently only implemented by the direct runner and the Flink Runner (streaming).
  */
 @Internal
-public interface UsesTestStream {}
+public interface UsesTestStream extends UsesUnboundedPCollections {}