You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@edgent.apache.org by wc...@apache.org on 2016/03/21 22:14:58 UTC
[2/3] incubator-quarks git commit: Remove unnecessary null check.
Remove unnecessary null check.
Project: http://git-wip-us.apache.org/repos/asf/incubator-quarks/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quarks/commit/d122bf86
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quarks/tree/d122bf86
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quarks/diff/d122bf86
Branch: refs/heads/master
Commit: d122bf862b87a9e780169038dcb98a7584c0ad13
Parents: 98e1b88
Author: Cazen <Ca...@korea.com>
Authored: Sat Mar 19 11:34:28 2016 +0900
Committer: Cazen <Ca...@korea.com>
Committed: Sat Mar 19 11:54:27 2016 +0900
----------------------------------------------------------------------
.../src/main/java/quarks/topology/spi/graph/ConnectorStream.java | 3 ---
1 file changed, 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/d122bf86/spi/topology/src/main/java/quarks/topology/spi/graph/ConnectorStream.java
----------------------------------------------------------------------
diff --git a/spi/topology/src/main/java/quarks/topology/spi/graph/ConnectorStream.java b/spi/topology/src/main/java/quarks/topology/spi/graph/ConnectorStream.java
index a97d2b0..73a88be 100644
--- a/spi/topology/src/main/java/quarks/topology/spi/graph/ConnectorStream.java
+++ b/spi/topology/src/main/java/quarks/topology/spi/graph/ConnectorStream.java
@@ -100,9 +100,6 @@ public class ConnectorStream<G extends Topology, T> extends AbstractTStream<G, T
public <E extends Enum<E>> EnumMap<E,TStream<T>> split(Class<E> enumClass, Function<T, E> splitter) {
E[] es = enumClass.getEnumConstants();
- if(es == null) {
- throw new IllegalArgumentException("Class object does not represent an enum type");
- }
List<TStream<T>> outputs = split(es.length, t -> {
E split = splitter.apply(t);