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/05/21 15:26:20 UTC
[2/2] beam git commit: [BEAM-2292] This closes #3138
[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é <jb...@apache.org>
Authored: Sun May 21 17:26:12 2017 +0200
Committer: Jean-Baptiste Onofré <jb...@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(-)
----------------------------------------------------------------------