feldera
diff --git a/‎sql-to-dbsp-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/visitors/inner/EquivalenceContext.java‎
Lines changed: 6 additions & 0 deletions b/‎sql-to-dbsp-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/visitors/inner/EquivalenceContext.java‎
Lines changed: 6 additions & 0 deletions
diff --git a/‎sql-to-dbsp-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/visitors/outer/CircuitOptimizer.java‎
Lines changed: 1 addition & 0 deletions b/‎sql-to-dbsp-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/visitors/outer/CircuitOptimizer.java‎
Lines changed: 1 addition & 0 deletions
@@ -4,6 +4,7 @@
 import org.dbsp.sqlCompiler.ir.IDBSPDeclaration;
 import org.dbsp.sqlCompiler.ir.expression.DBSPExpression;
 
+import javax.annotation.CheckReturnValue;
 import javax.annotation.Nullable;
 import java.util.List;
 
@@ -31,10 +32,12 @@ public EquivalenceContext() {
         this.leftToRight = new Substitution<>();
     }
 
+    @CheckReturnValue
     public static boolean equiv(@Nullable DBSPExpression left, @Nullable DBSPExpression right) {
         return new EquivalenceContext().equivalent(left, right);
     }
 
+    @CheckReturnValue
     public static boolean equiv(@Nullable DBSPAggregateList left, @Nullable DBSPAggregateList right) {
         if (left == null)
             return right == null;
@@ -43,6 +46,7 @@ public static boolean equiv(@Nullable DBSPAggregateList left, @Nullable DBSPAggr
         return left.equivalent(right);
     }
 
+    @CheckReturnValue
     public boolean equivalent(@Nullable DBSPExpression left, @Nullable DBSPExpression right) {
         if (left == null)
             return right == null;
@@ -51,6 +55,7 @@ public boolean equivalent(@Nullable DBSPExpression left, @Nullable DBSPExpressio
         return left.equivalent(this, right);
     }
 
+    @CheckReturnValue
     public boolean equivalent(@Nullable DBSPExpression[] left, @Nullable DBSPExpression[] right) {
         if (left == null)
             return right == null;
@@ -64,6 +69,7 @@ public boolean equivalent(@Nullable DBSPExpression[] left, @Nullable DBSPExpress
         return true;
     }
 
+    @CheckReturnValue
     public <T extends DBSPExpression> boolean equivalent(@Nullable List<T> left, @Nullable List<T> right) {
         if (left == null)
             return right == null;
 
@@ -108,6 +108,7 @@ void createOptimizer() {
         this.add(new RemoveIAfterD(compiler));
         this.add(new DeadCode(compiler, true));
         this.add(new Simplify(compiler).circuitRewriter(true));
+        this.add(new ShareIndexes(compiler));
         this.add(new RemoveFilters(compiler));
         this.add(new OptimizeWithGraph(compiler, g -> new OptimizeProjectionVisitor(compiler, g)));
         this.add(new OptimizeWithGraph(compiler,