Return-Path: X-Original-To: apmail-samza-dev-archive@minotaur.apache.org Delivered-To: apmail-samza-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 2FCB717EA7 for ; Tue, 14 Apr 2015 15:14:16 +0000 (UTC) Received: (qmail 55523 invoked by uid 500); 14 Apr 2015 15:14:16 -0000 Delivered-To: apmail-samza-dev-archive@samza.apache.org Received: (qmail 55464 invoked by uid 500); 14 Apr 2015 15:14:16 -0000 Mailing-List: contact dev-help@samza.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@samza.apache.org Delivered-To: mailing list dev@samza.apache.org Received: (qmail 55434 invoked by uid 99); 14 Apr 2015 15:14:15 -0000 Received: from reviews-vm.apache.org (HELO reviews.apache.org) (140.211.11.40) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 14 Apr 2015 15:14:15 +0000 Received: from reviews.apache.org (localhost [127.0.0.1]) by reviews.apache.org (Postfix) with ESMTP id 9F0991D432E; Tue, 14 Apr 2015 15:14:16 +0000 (UTC) Content-Type: multipart/alternative; boundary="===============0508670517776153210==" MIME-Version: 1.0 Subject: Review Request 33170: Renamed samza-sql to samza-sql-core From: "Milinda Pathirage" To: "Chris Riccomini" , "Yi Pan (Data Infrastructure)" Cc: "Milinda Pathirage" , "samza" Date: Tue, 14 Apr 2015 15:14:16 -0000 Message-ID: <20150414151416.31554.57926@reviews.apache.org> X-ReviewBoard-URL: https://reviews.apache.org/ Auto-Submitted: auto-generated Sender: "Milinda Pathirage" X-ReviewGroup: Samza X-ReviewRequest-URL: https://reviews.apache.org/r/33170/ X-Sender: "Milinda Pathirage" Reply-To: "Milinda Pathirage" X-ReviewRequest-Repository: samza --===============0508670517776153210== MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: 7bit ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33170/ ----------------------------------------------------------- Review request for samza, Chris Riccomini and Yi Pan (Data Infrastructure). Bugs: SAMZA-648 https://issues.apache.org/jira/browse/SAMZA-648 Repository: samza Description ------- This patch rename samza-sql module to samza-sql-core. This is the first step of separating samza-sql to multiple modules. samza-sql-core will contain operator layer related code while we will have separate modules for different front-end implementations. After this step, Calcite based front-end code will be moved to samza-sql-calcite module. Diffs ----- build.gradle ee4baa5 gradle/dependency-versions.gradle 46e7c28 samza-sql-core/README.md PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Data.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/data/EntityName.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Relation.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Schema.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/data/Tuple.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/Operator.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/RelationOperator.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/SqlOperatorFactory.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/TupleOperator.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/operators/spec/OperatorSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/api/router/OperatorRouter.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/data/IncomingMessageTuple.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/data/avro/AvroData.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/data/avro/AvroSchema.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlAvroSerde.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlAvroSerdeFactory.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerde.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerdeFactory.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/data/string/StringData.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/data/string/StringSchema.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/metadata/AvroSchemaConverter.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperator.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorFactoryImpl.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/partition/PartitionOp.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/partition/PartitionSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/relation/Join.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/relation/JoinSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/stream/InsertStream.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/stream/InsertStreamSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/BoundedTimeWindow.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/WindowSpec.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/operators/window/WindowState.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/planner/SamzaCalciteConnection.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/planner/SamzaQueryPreparingStatement.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidator.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/sql/router/SimpleRouter.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/task/sql/OperatorMessageCollector.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/task/sql/SqlMessageCollector.java PRE-CREATION samza-sql-core/src/main/java/org/apache/samza/task/sql/StoreMessageCollector.java PRE-CREATION samza-sql-core/src/test/java/org/apache/samza/sql/data/serializers/SqlAvroSerdeTest.java PRE-CREATION samza-sql-core/src/test/java/org/apache/samza/sql/planner/QueryPlannerTest.java PRE-CREATION samza-sql-core/src/test/java/org/apache/samza/sql/planner/SamzaStreamTableFactory.java PRE-CREATION samza-sql-core/src/test/java/org/apache/samza/sql/test/metadata/TestAvroSchemaConverter.java PRE-CREATION samza-sql-core/src/test/java/org/apache/samza/task/sql/RandomOperatorTask.java PRE-CREATION samza-sql-core/src/test/java/org/apache/samza/task/sql/StreamSqlTask.java PRE-CREATION samza-sql/README.md 598670b samza-sql/src/main/java/org/apache/samza/sql/api/data/Data.java d1b8409 samza-sql/src/main/java/org/apache/samza/sql/api/data/EntityName.java 127a677 samza-sql/src/main/java/org/apache/samza/sql/api/data/Relation.java 90b8026 samza-sql/src/main/java/org/apache/samza/sql/api/data/Schema.java 1e8f192 samza-sql/src/main/java/org/apache/samza/sql/api/data/Tuple.java bc8efcf samza-sql/src/main/java/org/apache/samza/sql/api/operators/Operator.java 0169f2d samza-sql/src/main/java/org/apache/samza/sql/api/operators/RelationOperator.java faa0a32 samza-sql/src/main/java/org/apache/samza/sql/api/operators/SqlOperatorFactory.java 67671b9 samza-sql/src/main/java/org/apache/samza/sql/api/operators/TupleOperator.java ac4654e samza-sql/src/main/java/org/apache/samza/sql/api/operators/spec/OperatorSpec.java 96385e2 samza-sql/src/main/java/org/apache/samza/sql/api/router/OperatorRouter.java 2455a62 samza-sql/src/main/java/org/apache/samza/sql/data/IncomingMessageTuple.java f868e5c samza-sql/src/main/java/org/apache/samza/sql/data/avro/AvroData.java d040be9 samza-sql/src/main/java/org/apache/samza/sql/data/avro/AvroSchema.java 577cf74 samza-sql/src/main/java/org/apache/samza/sql/data/serializers/SqlAvroSerde.java f3f7f7d samza-sql/src/main/java/org/apache/samza/sql/data/serializers/SqlAvroSerdeFactory.java aad18f4 samza-sql/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerde.java 1f0c3b2 samza-sql/src/main/java/org/apache/samza/sql/data/serializers/SqlStringSerdeFactory.java 2564479 samza-sql/src/main/java/org/apache/samza/sql/data/string/StringData.java b81d9fa samza-sql/src/main/java/org/apache/samza/sql/data/string/StringSchema.java 348fc0c samza-sql/src/main/java/org/apache/samza/sql/metadata/AvroSchemaConverter.java 7cc43c0 samza-sql/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperator.java c634159 samza-sql/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorFactoryImpl.java 916b166 samza-sql/src/main/java/org/apache/samza/sql/operators/factory/SimpleOperatorSpec.java 93d4ebb samza-sql/src/main/java/org/apache/samza/sql/operators/partition/PartitionOp.java 986d688 samza-sql/src/main/java/org/apache/samza/sql/operators/partition/PartitionSpec.java 29d1784 samza-sql/src/main/java/org/apache/samza/sql/operators/relation/Join.java a8a6eaf samza-sql/src/main/java/org/apache/samza/sql/operators/relation/JoinSpec.java ba8bfb5 samza-sql/src/main/java/org/apache/samza/sql/operators/stream/InsertStream.java 7563100 samza-sql/src/main/java/org/apache/samza/sql/operators/stream/InsertStreamSpec.java 70475ce samza-sql/src/main/java/org/apache/samza/sql/operators/window/BoundedTimeWindow.java 935ffc0 samza-sql/src/main/java/org/apache/samza/sql/operators/window/WindowSpec.java e2ae3aa samza-sql/src/main/java/org/apache/samza/sql/operators/window/WindowState.java 48547f0 samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java 16dbdc3 samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaCalciteConnection.java 63b1da5 samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaQueryPreparingStatement.java 0721573 samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidator.java f46c1f0 samza-sql/src/main/java/org/apache/samza/sql/router/SimpleRouter.java c6fc673 samza-sql/src/main/java/org/apache/samza/task/sql/OperatorMessageCollector.java 1e5310f samza-sql/src/main/java/org/apache/samza/task/sql/SqlMessageCollector.java b98e2d7 samza-sql/src/main/java/org/apache/samza/task/sql/StoreMessageCollector.java b4b0e59 samza-sql/src/test/java/org/apache/samza/sql/data/serializers/SqlAvroSerdeTest.java 7412669 samza-sql/src/test/java/org/apache/samza/sql/planner/QueryPlannerTest.java 36b6f03 samza-sql/src/test/java/org/apache/samza/sql/planner/SamzaStreamTableFactory.java f757d8f samza-sql/src/test/java/org/apache/samza/sql/test/metadata/TestAvroSchemaConverter.java b4ac5f5 samza-sql/src/test/java/org/apache/samza/task/sql/RandomOperatorTask.java 4ec7dbb samza-sql/src/test/java/org/apache/samza/task/sql/StreamSqlTask.java 4796fa6 settings.gradle 08e548c Diff: https://reviews.apache.org/r/33170/diff/ Testing ------- Thanks, Milinda Pathirage --===============0508670517776153210==--