Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins

On Tue, Sep 13, 2022 at 12:05 PM Guozhang Wang > wrote: > > > >> Thank Vicky! I'm +1. > >> > >> Guozhang > >> > >> On Mon, Sep 12, 2022 at 7:02 PM John Roesler > wrote: > >> > >>> Thanks for the updates, Vicky! > >>> >

Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins

hat people would think before this config is > enabled, self-join are not allowed at all. Maybe we can rename it to > "single.store.self.join"? > > Guozhang > > On Fri, Sep 9, 2022 at 2:15 AM Vasiliki Papavasileiou > wrote: > > >

Re: [VOTE] KIP-862: Self-join optimization for stream-stream joins

en `all` is > specified in the config right? > > > Guozhang > > > On Thu, Sep 8, 2022 at 12:02 PM Vasiliki Papavasileiou > wrote: > > > Hello everyone, > > > > I'd like to open the vote for KIP-862, which proposes to optimize > > stre

[VOTE] KIP-862: Self-join optimization for stream-stream joins

Hello everyone, I'd like to open the vote for KIP-862, which proposes to optimize stream-stream self-joins by using a single state store for the join. The proposal is here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-862%3A+Self-join+optimization+for+stream-stream+joins Thanks to all

Re: [DISCUSS] KIP-862: Implement self-join optimization

he extra store > in > > > the impl. > > > > > > Re 3): I'm curious how the compatibility is preserved since with > > > optimizations turned on, we would use fewer stores and hence the store > > name > > > suffixes would change. In your experimen

Re: [DISCUSS] KIP-862: Implement self-join optimization

y burning some suffixes as well, b) > the processor names, similar to store names, c) store formats, if we ever > change the store formats, we need to consider a live upgrade path as well. > > Please let me know your thoughts. > > Guozhang > > > On Tue, Aug 2, 2022 at 11:3

[DISCUSS] KIP-862: Implement self-join optimization

Hello everyone, I would like to start the discussion for KIP-862: Implement self-join optimization The KIP can be found here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-862%3A+Self-join Any suggestions are more than welcome. Many thanks, Vicky

Re: [VOTE] KIP-805: Add range and scan query support in IQ v2

with implementing the PR for the queries. Thank you, Vicky On Mon, Dec 13, 2021 at 10:49 AM Vasiliki Papavasileiou < vpapavasile...@confluent.io> wrote: > Hello everyone, > > Thank you for your comments. I applied the changes. > Hope things are clearer now. > > Best, > Vic

Re: [VOTE] KIP-805: Add range and scan query support in IQ v2

> > > It makes sense to have the range and scan query in IQv2, as in IQv1. > > > > > > > > +1 (non-binding) > > > > > > > > Thank you. > > > > Luke > > > > > > > > On Thu, Dec 2, 2021 at 5:41 AM John Roesle

Re: [DISCUSS] KIP-805: Add range and scan query support in IQ v2

; > feedback as follow up work. > > > > IMHO, the hard coded query translation is not ideal and should be > > plugable. But for a v1 of IQv2 (pun intended) the hardcoded translation > > seems to be good enough. > > > > > > -Matthias > > > >

Re: [DISCUSS] KIP-805: Add range and scan query support in IQ v2

KIP. Overall, make sense. > > One question: What is the purpose to `RawRangeQuery`? Seems not very > user friendly. > > -Matthias > > > On 11/30/21 12:48 PM, Vasiliki Papavasileiou wrote: > > Thank you John! Yes, that was a typo from copying and I fixed it. > > >

[VOTE] KIP-805: Add range and scan query support in IQ v2

Hello everyone, I would like to start a vote for KIP-805 that adds range and scan KeyValue queries in IQ2. The KIP can be found here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-805%3A+Add+range+and+scan+query+support+in+IQ+v2 Cheers! Vicky

Re: [DISCUSS] KIP-805: Add range and scan query support in IQ v2

nd > IQv2. > > One thing I noticed, which looks like just a typo is that > the value type of the proposed RangeQuery should probably be > KeyValueIterator, right? > > Otherwise, it looks good to me! > > Thanks, > -John > > On Mon, 2021-11-29 at 12:20 +, Vasil

[DISCUSS] KIP-805: Add range and scan query support in IQ v2

Hello everyone, I would like to start the discussion for KIP-805: Add range and scan query support in IQ v2 The KIP can be found here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-805%3A+Add+range+and+scan+query+support+in+IQ+v2 Any suggestions are more than welcome. Many thanks,

Re: [VOTE} KIP-796: Interactive Query v2

I think this KIP will greatly improve how we handle IQ in streams so +1 (non-binding) from me. Thank you John! On Thu, Nov 18, 2021 at 9:45 PM Patrick Stuedi wrote: > +1 (non-binding), thanks John! > -Patrick > > On Thu, Nov 18, 2021 at 12:27 AM John Roesler wrote: > > > Hello all, > > > >

Re: [VOTE] KIP-791: Add Record Metadata to State Store Context

Hi Patrick, Having the recordMetadata available in the state stores is fundamental for the consistency work and the proposed approach is reasonable. +1 (non-binding) Thank you, Vicky On Mon, Nov 8, 2021 at 10:00 AM Luke Chen wrote: > Hi Patrick, > Thanks for the KIP. > Adding RecordMetadata

Permissions to contribute to Apache Kafka

Wiki ID: vicky_papavas Jira ID: vicky_papavas