You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/11/18 06:32:19 UTC
[6/7] incubator-beam git commit: Added messages to exceptions
Added messages to exceptions
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c0623c10
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c0623c10
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c0623c10
Branch: refs/heads/master
Commit: c0623c10318f95984747bd94fd5d733be5e5de11
Parents: a23ae20
Author: Eugene Kirpichov <ki...@google.com>
Authored: Thu Nov 17 15:36:12 2016 -0800
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Thu Nov 17 15:36:12 2016 -0800
----------------------------------------------------------------------
.../beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/c0623c10/runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java
----------------------------------------------------------------------
diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java
index a5bb214..b946e4d 100644
--- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java
+++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java
@@ -182,12 +182,14 @@ class GroupAlsoByWindowEvaluatorFactory implements TransformEvaluatorFactory {
@Override
public <T> boolean contains(PCollectionView<T> view) {
- throw new UnsupportedOperationException();
+ throw new UnsupportedOperationException(
+ "GroupAlsoByWindow must not have side inputs");
}
@Override
public boolean isEmpty() {
- throw new UnsupportedOperationException();
+ throw new UnsupportedOperationException(
+ "GroupAlsoByWindow must not have side inputs");
}
},
droppedDueToClosedWindow,