Revision 4172
Added by Aaron Marcuse-Kubitza over 12 years ago
| union | ||
|---|---|---|
| 49 | 49 |
mappings = set() |
| 50 | 50 |
for row in map_0_reader: |
| 51 | 51 |
if all_ or non_empty(row): |
| 52 |
if not all_: |
|
| 53 |
mappings.add(row[0]) |
|
| 54 |
mappings.add(row[1]) |
|
| 52 |
if not all_: mappings.add(row[0]) |
|
| 55 | 53 |
writer.writerow(row) |
| 56 | 54 |
|
| 57 | 55 |
if combinable: |
Also available in: Unified diff
union: Don't eliminate duplicate rows based on matches between map_0's output column and map_1's input column, because union is now being used for self-joins and it is legitimate for a term to appear as both an input and an output