Support Needed:The join node input can only be source. Input from other nodes must be supported

[lpf4254302]

The join node input can only be source. Input from other nodes must be supported

[ngjaying]

Consider to remove the restrictions in all nodes, which means each node must handle both a tuple or a tuple list properly. By this way, it is more flexible to connect nodes.

[lpf4254302]

I think it's feasible.

[jesson1]

Is this why stream JOIN table JOIN table or stream JOIN stream JOIN table is not supported?

[jesson1]

I noticed that joining more than two sources is not supported.

examples:

SELECT *  from stream1 as s1
inner join table as t1
on s1.tid = t1.tid

inner join stream2 as s2
on s1.ts - s2.ts between -2000 and 2000

inner join table as t2
on s2.tid = t2.tid and t1.region = t2.region

group by TUMBLINGWINDOW(ss, 2)

SELECT *  from stream1 as s1
inner join table1 as t1
on s1.tid = t1.tid

inner join table2 as t2
on t1.area_id = t2.id