This is an automated email from the ASF dual-hosted git repository. kenn pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 048471b5bbe012da73379042b78d595bf0b26f3c Merge: e662b5f adf659e Author: Kenn Knowles <[email protected]> AuthorDate: Tue Nov 27 16:23:39 2018 -0700 Merge pull request #7121: [BEAM-6114] Add isBounded() to BeamRelNode and BeamSqlTable, use for JOIN .../beam/sdk/extensions/sql/BeamSqlTable.java | 3 + .../extensions/sql/impl/rel/BeamIOSourceRel.java | 5 + .../sdk/extensions/sql/impl/rel/BeamJoinRel.java | 124 +++++++++++++-------- .../sdk/extensions/sql/impl/rel/BeamRelNode.java | 17 +++ .../sql/impl/schema/BeamPCollectionTable.java | 5 + .../meta/provider/bigquery/BeamBigQueryTable.java | 5 + .../sql/meta/provider/kafka/BeamKafkaTable.java | 5 + .../meta/provider/pubsub/PubsubIOJsonTable.java | 5 + .../sql/meta/provider/test/TestBoundedTable.java | 5 + .../sql/meta/provider/test/TestTableProvider.java | 5 + .../sql/meta/provider/test/TestUnboundedTable.java | 5 + .../sql/meta/provider/text/TextTable.java | 5 + .../sql/impl/rel/BeamEnumerableConverterTest.java | 5 + .../rel/BeamJoinRelUnboundedVsBoundedTest.java | 5 + 14 files changed, 154 insertions(+), 45 deletions(-)
