[2/2] beam git commit: [BEAM-2149] This closes #3122

[jbonofre]

[BEAM-2149] This closes #3122


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

Branch: refs/heads/DSL_SQL
Commit: 0e08c87d7fcc2b8ccd99a422458d12593b60acc2
Parents: 868bcbd 8044e59
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Authored: Mon May 15 11:23:01 2017 +0200
Committer: Jean-Baptiste Onofré <jbono...@apache.org>
Committed: Mon May 15 11:23:01 2017 +0200

----------------------------------------------------------------------
 .../beam/dsls/sql/schema/BeamTableUtils.java    | 104 +++++++++++++++++
 .../sql/schema/kafka/BeamKafkaCSVTable.java     |  53 ++++-----
 .../schema/text/BeamTextCSVTableIOReader.java   |  66 +----------
 .../schema/text/BeamTextCSVTableIOWriter.java   |  22 +---
 .../sql/schema/kafka/BeamKafkaCSVTableTest.java | 113 +++++++++++++++++++
 .../sql/schema/text/BeamTextCSVTableTest.java   |   2 -
 6 files changed, 245 insertions(+), 115 deletions(-)
----------------------------------------------------------------------