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/590eb14b Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/590eb14b Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/590eb14b Branch: refs/heads/master Commit: 590eb14b707eccd28bfbe64c8768ea353dc214ac Parents: 50fa974 e203db2 Author: Jagadish <jvenkatra...@linkedin.com> Authored: Mon Oct 22 16:30:01 2018 -0700 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Mon Oct 22 16:30:01 2018 -0700 ---------------------------------------------------------------------- build.gradle | 28 + gradle/dependency-versions.gradle | 2 + .../JobNodeConfigurationGenerator.java | 6 +- samza-sql-shell/conf/samza-sql-shell-log4j.xml | 49 ++ samza-sql-shell/conf/shell-defaults.conf | 28 + samza-sql-shell/scripts/samza-sql-shell.sh | 42 + .../apache/samza/sql/client/cli/CliCommand.java | 53 ++ .../samza/sql/client/cli/CliCommandType.java | 78 ++ .../samza/sql/client/cli/CliConstants.java | 57 ++ .../samza/sql/client/cli/CliEnvironment.java | 130 +++ .../samza/sql/client/cli/CliHighlighter.java | 89 ++ .../apache/samza/sql/client/cli/CliShell.java | 821 +++++++++++++++++++ .../apache/samza/sql/client/cli/CliView.java | 29 + .../org/apache/samza/sql/client/cli/Main.java | 117 +++ .../sql/client/cli/QueryResultLogView.java | 291 +++++++ .../sql/client/impl/AvroSqlSchemaConverter.java | 112 +++ .../client/impl/CliLoggingSystemFactory.java | 117 +++ .../FileSystemAvroRelSchemaProviderFactory.java | 75 ++ .../samza/sql/client/impl/SamzaExecutor.java | 511 ++++++++++++ .../sql/client/impl/SamzaSqlFieldType.java | 94 +++ .../sql/client/impl/SamzaSqlUdfDisplayInfo.java | 71 ++ .../sql/client/interfaces/ExecutionContext.java | 41 + .../client/interfaces/ExecutionException.java | 40 + .../sql/client/interfaces/ExecutionStatus.java | 30 + .../sql/client/interfaces/NonQueryResult.java | 62 ++ .../sql/client/interfaces/QueryResult.java | 49 ++ .../sql/client/interfaces/SqlExecutor.java | 171 ++++ .../sql/client/interfaces/SqlFunction.java | 55 ++ .../samza/sql/client/interfaces/SqlSchema.java | 56 ++ .../sql/client/interfaces/SqlSchemaBuilder.java | 63 ++ .../samza/sql/client/util/CliException.java | 41 + .../apache/samza/sql/client/util/CliUtil.java | 43 + .../sql/client/util/RandomAccessQueue.java | 96 +++ .../sql/client/impl/SamzaExecutorTest.java | 79 ++ .../sql/client/util/RandomAccessQueueTest.java | 89 ++ .../src/test/resources/ProfileChangeStream.avsc | 51 ++ .../sql/runner/SamzaSqlApplicationConfig.java | 2 +- settings.gradle | 1 + 38 files changed, 3764 insertions(+), 5 deletions(-) ----------------------------------------------------------------------
