----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30667/ -----------------------------------------------------------
Review request for samza, Chris Riccomini, Julian Hyde, and Yi Pan (Data Infrastructure). 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 ----- build.gradle 4d0b44f gradle/dependency-versions.gradle 12b324d samza-sql/README PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/api/data/Data.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/api/data/EntityName.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/api/data/Relation.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/api/data/Schema.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/api/data/Tuple.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/api/operators/Operator.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/api/operators/RelationOperator.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/api/operators/SqlOperatorFactory.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/api/operators/TupleOperator.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/api/operators/spec/OperatorSpec.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/api/router/OperatorRouter.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/compiler/SamzaCalciteConnection.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/compiler/SamzaPreparingStmt.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/compiler/SamzaQueryPreparator.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/compiler/SamzaSqlValidator.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/data/IncomingMessageTuple.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/data/avro/AvroData.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/data/avro/AvroSchema.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerde.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerdeFactory.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/data/string/StringData.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/data/string/StringSchema.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperator.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorFactoryImpl.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorSpec.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/partition/PartitionOp.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/partition/PartitionSpec.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/relation/Join.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/relation/JoinSpec.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/stream/InsertStream.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/stream/InsertStreamSpec.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/window/BoundedTimeWindow.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/window/WindowSpec.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/operators/window/WindowState.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/router/SimpleRouter.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/sql/task/StoreMessageCollector.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/task/sql/OperatorMessageCollector.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/task/sql/SqlMessageCollector.java PRE-CREATION samza-sql/src/main/java/org/apache/samza/task/sql/StoreMessageCollector.java PRE-CREATION samza-sql/src/test/java/org/apache/samza/sql/compiler/PrepareQueryTest.java PRE-CREATION samza-sql/src/test/java/org/apache/samza/sql/compiler/SamzaStreamTableFactory.java PRE-CREATION samza-sql/src/test/java/org/apache/samza/sql/task/RandomOperatorTask.java PRE-CREATION samza-sql/src/test/java/org/apache/samza/task/sql/RandomOperatorTask.java PRE-CREATION samza-sql/src/test/java/org/apache/samza/task/sql/StreamSqlTask.java PRE-CREATION settings.gradle bb07a3b Diff: https://reviews.apache.org/r/30667/diff/ Testing ------- Thanks, Milinda Pathirage
