Streaming: TPC-H Q19

[lmatz]

Query:

create materialized view tpch_q19 as
select
	sum(l_extendedprice* (1 - l_discount)) as revenue
from
	lineitem,
	part
where
	(
		p_partkey = l_partkey
		and p_brand = 'Brand#52'
		and p_container in ('SM CASE', 'SM BOX', 'SM PACK', 'SM PKG')
		and l_quantity >= 1 and l_quantity <= 11
		and p_size between 1 and 5
		and l_shipmode in ('AIR', 'AIR REG')
		and l_shipinstruct = 'DELIVER IN PERSON'
	)
	or
	(
		p_partkey = l_partkey
		and p_brand = 'Brand#24'
		and p_container in ('MED BAG', 'MED BOX', 'MED PKG', 'MED PACK')
		and l_quantity >= 30 and l_quantity <= 40
		and p_size between 1 and 10
		and l_shipmode in ('AIR', 'AIR REG')
		and l_shipinstruct = 'DELIVER IN PERSON'
	)
	or
	(
		p_partkey = l_partkey
		and p_brand = 'Brand#32'
		and p_container in ('LG CASE', 'LG BOX', 'LG PACK', 'LG PKG')
		and l_quantity >= 10 and l_quantity <= 20
		and p_size between 1 and 15
		and l_shipmode in ('AIR', 'AIR REG')
		and l_shipinstruct = 'DELIVER IN PERSON'
	);

[lmatz]

Missing conversion is RwLogicalJoin[convention: RisingWave Logical -> RisingWave Streaming Plan]
There is 1 empty subset: rel#163659:RelSubset#14.RisingWave Streaming Plan.[].RwDistributionTrait{type=ANY, keys=[]}, the relevant part of the original plan is as follows
163633:RwLogicalJoin(condition=[OR(AND(=($10, $0), $11, $12, $2, $3, $13, $4, $5), AND(=($10, $0), $14, $15, $6, $7, $16, $4, $5), AND(=($10, $0), $17, $18, $8, $9, $19, $4, $5))], joinType=[inner])

Can this be rewritten into using Union, possibly duplicates?

The optimizer may not realize that the conditions are mutually exclusive.