added error checking when creating combolist

Nathan Marz · Nathan Marz · commit bba726328ea7 · 2012-12-10T15:02:46.000-08:00
diff --git a/src/jvm/storm/trident/tuple/ComboList.java b/src/jvm/storm/trident/tuple/ComboList.java
@@ -8,8 +8,10 @@
 public class ComboList extends AbstractList<Object> {    
     public static class Factory implements Serializable {
         Pointer[] index;
+        int numLists;
         
         public Factory(int... sizes) {
+            numLists = sizes.length;
             int total = 0;
             for(int size: sizes) {
                 total+=size;
@@ -27,6 +29,9 @@ public Factory(int... sizes) {
         }
         
         public ComboList create(List[] delegates) {
+            if(delegates.length!=numLists) {
+                throw new RuntimeException("Expected " + numLists + " lists, but instead got " + delegates.length + " lists");
+            }
             return new ComboList(delegates, index);
         }
     }

Original file line number	Diff line number	Diff line change
`@@ -8,8 +8,10 @@`
`8`	`8`	`public class ComboList extends AbstractList<Object> {`
`9`	`9`	`public static class Factory implements Serializable {`
`10`	`10`	`Pointer[] index;`
	`11`	`+ int numLists;`
`11`	`12`
`12`	`13`	`public Factory(int... sizes) {`
	`14`	`+ numLists = sizes.length;`
`13`	`15`	`int total = 0;`
`14`	`16`	`for(int size: sizes) {`
`15`	`17`	`total+=size;`
`@@ -27,6 +29,9 @@ public Factory(int... sizes) {`
`27`	`29`	`}`
`28`	`30`
`29`	`31`	`public ComboList create(List[] delegates) {`
	`32`	`+ if(delegates.length!=numLists) {`
	`33`	`+ throw new RuntimeException("Expected " + numLists + " lists, but instead got " + delegates.length + " lists");`
	`34`	`+ }`
`30`	`35`	`return new ComboList(delegates, index);`
`31`	`36`	`}`
`32`	`37`	`}`