Merge branch 'master' of https://github.com/apache/samza
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/2ffedc9a Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/2ffedc9a Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/2ffedc9a Branch: refs/heads/master Commit: 2ffedc9a9ab376957371cc0068e85db6e1c62a17 Parents: 1befcad 08496c9 Author: Jagadish <jvenkatra...@linkedin.com> Authored: Sat Oct 27 11:15:08 2018 -0700 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Sat Oct 27 11:15:08 2018 -0700 ---------------------------------------------------------------------- .../sql/impl/ConfigBasedIOResolverFactory.java | 13 ++- .../apache/samza/sql/planner/QueryPlanner.java | 3 +- .../sql/runner/SamzaSqlApplicationConfig.java | 20 ++++- .../samza/sql/translator/JoinTranslator.java | 44 ++++++--- .../translator/LogicalAggregateTranslator.java | 7 +- .../samza/sql/translator/QueryTranslator.java | 6 +- .../sql/testutil/TestIOResolverFactory.java | 12 ++- .../sql/translator/TestJoinTranslator.java | 2 +- .../sql/translator/TestQueryTranslator.java | 95 ++++++++++---------- .../apache/samza/test/framework/TestRunner.java | 23 ++++- .../StreamApplicationIntegrationTest.java | 43 ++++++--- .../framework/StreamTaskIntegrationTest.java | 5 +- .../test/samzasql/TestSamzaSqlEndToEnd.java | 34 ++++++- 13 files changed, 218 insertions(+), 89 deletions(-) ----------------------------------------------------------------------
