Guozhang
I am using 0.10.2.1 version
- Shekar
On Sun, Jun 25, 2017 at 10:36 AM, Guozhang Wang <wangg...@gmail.com> wrote:
> Hi Shekar,
>
> Could you demonstrate your input data. More specifically, what are the key
> types of your input streams, and are they not-null values? It seems the
> root cause is similar to the other thread you asked on the mailing list.
>
> Also, could you provide your used Kafka Streams version?
>
>
> Guozhang
>
>
> On Sun, Jun 25, 2017 at 12:45 AM, Shekar Tippur <ctip...@gmail.com> wrote:
>
> > Hello,
> >
> > I am having trouble implementing streams to table join.
> >
> > I have 2 POJO's each representing streams and table data structures. raw
> > topic contains streams and cache topic contains table structure. The join
> > is not happening since the print statement is not being called.
> >
> > Appreciate any pointers.
> >
> > - Shekar
> >
> > raw.leftJoin(cache, new ValueJoiner<RawPOJOClass,
> > CachePOJOClass,RawPOJOClass>() {
> >
> > @Override
> > public RawPOJOClass apply(RawPOJOClass r, CachePOJOClass c) {
> >
> > String src=r.getSource();
> > String cSrc=c.getSnowHost();
> > Custom custom=new Custom();
> >
> > if (src.matches(snowSrc)){
> > System.out.println("In apply code");
> > custom.setAdditionalProperty("custom",cSrc.getAll());
> > r.setCustom(custom);
> > }
> > return r;
> > }
> > }).to("parser");
> >
>
>
>
> --
> -- Guozhang
>
