diff options
author | Davies Liu <davies@databricks.com> | 2016-02-03 10:38:53 -0800 |
---|---|---|
committer | Davies Liu <davies.liu@gmail.com> | 2016-02-03 10:38:53 -0800 |
commit | c4feec26eb677bfd3bfac38e5e28eae05279956e (patch) | |
tree | fd0da335914c9cbdd6bff0787f902ff42b8dac72 /sql/hive-thriftserver/src/test | |
parent | e9eb248edfa81d75f99c9afc2063e6b3d9ee7392 (diff) | |
download | spark-c4feec26eb677bfd3bfac38e5e28eae05279956e.tar.gz spark-c4feec26eb677bfd3bfac38e5e28eae05279956e.tar.bz2 spark-c4feec26eb677bfd3bfac38e5e28eae05279956e.zip |
[SPARK-12798] [SQL] generated BroadcastHashJoin
A row from stream side could match multiple rows on build side, the loop for these matched rows should not be interrupted when emitting a row, so we buffer the output rows in a linked list, check the termination condition on producer loop (for example, Range or Aggregate).
Author: Davies Liu <davies@databricks.com>
Closes #10989 from davies/gen_join.
Diffstat (limited to 'sql/hive-thriftserver/src/test')
0 files changed, 0 insertions, 0 deletions