----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30667/ -----------------------------------------------------------
(Updated Feb. 12, 2015, 3:47 a.m.) Review request for samza, Chris Riccomini, Julian Hyde, and Yi Pan (Data Infrastructure). Changes ------- * Calcite based query planner code moved to 'org.apache.samza.sql.planner' package. * Removed the schema factory prototype. It will be added later with schema-repo based implementaiton. Repository: samza Description ------- # Samza Calcite Integration Prototype - Supports simple stream query planning based on Calcite's 'chi' branch (https://github.com/julianhyde/incubator-calcite/tree/chi) with STREAM support. - No query planning customizations specific to Samza yet. - Calcite integration related code can be found under package 'org.apache.samza.sql.compiler' ## Next Steps - Implement a compiler which converts query plan generated by Calcite to a set of Samza Jobs - Integrate the Calcite query optimizer Diffs (updated) ----- build.gradle b49c313 samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaCalciteConnection.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaQueryPreparingStatement.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidator.java PRE-CREATION samza-sql/src/test/java/org/apache/samza/sql/planner/QueryPlannerTest.java PRE-CREATION samza-sql/src/test/java/org/apache/samza/sql/planner/SamzaStreamTableFactory.java PRE-CREATION Diff: https://reviews.apache.org/r/30667/diff/ Testing (updated) ------- ./gradlew build was successful. But following errors were there in the console. Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-2" Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-7" Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-6" Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-0" Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-9" Exception: java.lang.OutOfMemoryError thrown from the UncaughtExceptionHandler in thread "MockSystemConsumer-10" Thanks, Milinda Pathirage
