This is an automated email from the ASF dual-hosted git repository.

mingmxu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit fcb297ce3146a7d09bbfafde60d0d61261e65844
Merge: fe8ee48 cc31fe5
Author: XuMingmin <xuming...@users.noreply.github.com>
AuthorDate: Tue Jun 19 14:38:31 2018 -0700

    Merge pull request #5592: [BEAM-3773] [SQL] Add support for setting 
PipelineOptions
    
    [BEAM-3773] [SQL] Add support for setting PipelineOptions

 .../extensions/sql/src/main/codegen/config.fmpp    |  3 +
 .../sql/src/main/codegen/includes/parserImpls.ftl  | 44 ++++++++++++++
 .../apache/beam/sdk/extensions/sql/BeamSqlCli.java |  6 +-
 .../sdk/extensions/sql/impl/BeamCalciteSchema.java | 12 +++-
 .../sdk/extensions/sql/impl/BeamCalciteTable.java  |  7 ++-
 .../beam/sdk/extensions/sql/impl/BeamSqlEnv.java   |  5 ++
 .../extensions/sql/impl/parser/SqlCreateTable.java | 23 ++------
 .../extensions/sql/impl/parser/SqlDdlNodes.java    | 13 ++++
 .../sql/impl/parser/SqlSetOptionBeam.java          | 69 ++++++++++++++++++++++
 .../sql/impl/rel/BeamEnumerableConverter.java      | 22 +++++--
 .../extensions/sql/impl/rel/BeamIOSourceRel.java   | 16 ++++-
 .../sdk/extensions/sql/impl/rel/BeamRelNode.java   | 13 ++++
 .../sdk/extensions/sql/impl/JdbcDriverTest.java    | 52 ++++++++++++----
 13 files changed, 244 insertions(+), 41 deletions(-)


Reply via email to