[2/2] beam git commit: [BEAM-2292] This closes #3138

[jbonofre]

[BEAM-2292] This closes #3138


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

Branch: refs/heads/DSL_SQL
Commit: 127790212b8ec3b3b9e0c29117bce594e7549d05
Parents: 25babc9 1232bf1
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Authored: Sun May 21 17:26:12 2017 +0200
Committer: Jean-Baptiste Onofré <jbono...@apache.org>
Committed: Sun May 21 17:26:12 2017 +0200

----------------------------------------------------------------------
 .../beam/dsls/sql/rel/BeamIOSourceRel.java      |  3 +-
 .../beam/dsls/sql/schema/BaseBeamTable.java     |  6 +-
 .../dsls/sql/schema/BeamPCollectionTable.java   | 62 +++++++++++++++++++
 .../dsls/sql/schema/kafka/BeamKafkaTable.java   | 12 +---
 .../dsls/sql/schema/text/BeamTextCSVTable.java  |  8 ++-
 .../schema/text/BeamTextCSVTableIOReader.java   |  9 +--
 .../dsls/sql/planner/MockedBeamSQLTable.java    |  5 +-
 .../sql/schema/BeamPCollectionTableTest.java    | 64 ++++++++++++++++++++
 .../sql/schema/text/BeamTextCSVTableTest.java   | 12 ++--
 9 files changed, 150 insertions(+), 31 deletions(-)
----------------------------------------------------------------------