You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ke...@apache.org on 2018/11/27 23:23:48 UTC

[beam] 01/01: Merge pull request #7121: [BEAM-6114] Add isBounded() to BeamRelNode and BeamSqlTable, use for JOIN

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 <ke...@kennknowles.com>
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(-)