You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2017/06/08 11:44:26 UTC

[2/2] beam git commit: This closes #3323

This closes #3323


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5c1f2cbc
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5c1f2cbc
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5c1f2cbc

Branch: refs/heads/DSL_SQL
Commit: 5c1f2cbc6c54354612c142415b77a2aded84a06d
Parents: 4c5b758 03a913a
Author: Jean-Baptiste Onofré <jb...@apache.org>
Authored: Thu Jun 8 13:44:18 2017 +0200
Committer: Jean-Baptiste Onofré <jb...@apache.org>
Committed: Thu Jun 8 13:44:18 2017 +0200

----------------------------------------------------------------------
 dsls/pom.xml                                    |  2 +-
 dsls/sql/pom.xml                                | 43 +++-----------
 .../beam/dsls/sql/schema/BeamSqlRowCoder.java   | 59 ++++++++++----------
 .../dsls/sql/schema/kafka/BeamKafkaTable.java   | 20 +++++--
 .../dsls/sql/schema/text/BeamTextCSVTable.java  |  2 +-
 .../schema/text/BeamTextCSVTableIOWriter.java   |  2 +-
 6 files changed, 52 insertions(+), 76 deletions(-)
----------------------------------------------------------------------