Vicky Papavasileiou
Vicky Papavasileiou
**Describe the bug** N-way joins don't work when the join condition is an expression rather than a ColumnReference. Consider this example: ``` select * from tab1 inner join tab2 on...
### Description _What behavior do you want to change, why, how does your patch achieve the changes?_ ### Testing done _Describe the testing strategy. Unit and integration tests are expected...
### Description Add support for Stream-Stream self-joins that were previously prohibited. Table-table self-joins are still not allowed (requires support as in extra work from Streams). To take advantage of the...
KIP can be found here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-862%3A+Self-join It only applies to Stream-Stream joins and not n-way self-joins. This is an inner-join topology (without the optimization) ``` Topologies: Sub-topology: 0 Source: KSTREAM-SOURCE-0000000000...
Integration test and upgrade test for the self-join rewriting. The upgrade test ensures that a user does not lose data if they have a topology without the rewriting and then...
POC for self-join optimization. KIP can be found here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-862%3A+Self-join It only applies to Stream-Stream joins and not n-way self-joins. This is an inner-join topology (without the optimization) ``` Topologies:...
### Description Cherry-pick https://github.com/confluentinc/ksql/pull/9681 There were some conflicts, I addressed by removing code that is not available in 0.28. ### Testing done _Describe the testing strategy. Unit and integration tests...
### Description **Work in progres** Udafs support different types because the `UdfCompiler` had not been updated. I pulled from the `UdfLoader` the code responsible for validating and parsing parameters for...
**Describe the bug** We added the `content type` in the response of the `\query` endpoint (https://github.com/confluentinc/ksql/issues/9282) but did not apply the change to the other endpoints. We need to apply...