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 {}