Hi Folks:
I am using 'kafka' connector and joining with data from jdbc source (using
connector). I am using Flink v 1.14.3. If I do a left outer join between
kafka source and jdbc source, and try to save it to another kafka sink using
connectors api, I get the following exception:
Exception
> where you deal with window states and triggering on time yourself. Let me
>>> know if you need some pointers about that one.
>>>
>>> Cheers,
>>> Aljoscha
>>> > On 26 Jan 2016, at 19:32, Alexander Gryzlov <alex.gryz...@gmail.com>
>>&
native I see to that is to implement everything in a custom operator
> where you deal with window states and triggering on time yourself. Let me
> know if you need some pointers about that one.
>
> Cheers,
> Aljoscha
> > On 26 Jan 2016, at 19:32, Alexander Gryzlov <al
tates and triggering on time yourself. Let me
>> know if you need some pointers about that one.
>>
>> Cheers,
>> Aljoscha
>> > On 26 Jan 2016, at 19:32, Alexander Gryzlov <alex.gryz...@gmail.com>
>> wrote:
>> >
>> > Hello,
>> >
>&g
pointers about that one.
Cheers,
Aljoscha
> On 26 Jan 2016, at 19:32, Alexander Gryzlov <alex.gryz...@gmail.com> wrote:
>
> Hello,
>
> I'm trying to implement a left outer join of two Kafka streams within a
> sliding window. So far I have the following code:
>
time yourself. Let me
> know if you need some pointers about that one.
>
> Cheers,
> Aljoscha
> > On 26 Jan 2016, at 19:32, Alexander Gryzlov <alex.gryz...@gmail.com>
> wrote:
> >
> > Hello,
> >
> > I'm trying to implement a left outer join of two
.
On Wed, Apr 15, 2015 at 12:59 PM, Maximilian Michels m...@apache.org
wrote:
Hi Flavio,
Here's an simple example of a Left Outer Join:
https://gist.github.com/mxm/c2e9c459a9d82c18d789
As Stephan pointed out, this can be very easily modified to
construct a Right Outer Join (just exchange
the first call to
'iterator()' will succeed.
On Wed, Apr 15, 2015 at 12:59 PM, Maximilian Michels m...@apache.org
wrote:
Hi Flavio,
Here's an simple example of a Left Outer Join:
https://gist.github.com/mxm/c2e9c459a9d82c18d789
As Stephan pointed out, this can be very easily modified
.
On Wed, Apr 15, 2015 at 12:59 PM, Maximilian Michels
m...@apache.org wrote:
Hi Flavio,
Here's an simple example of a Left Outer Join:
https://gist.github.com/mxm/c2e9c459a9d82c18d789
As Stephan pointed out, this can be very easily modified to
construct a Right Outer Join (just exchange
by: org.apache.flink.util.TraversableOnceException: The
Iterable can be iterated over only once. Only the first call to
'iterator()' will succeed.
On Wed, Apr 15, 2015 at 12:59 PM, Maximilian Michels
m...@apache.org wrote:
Hi Flavio,
Here's an simple example of a Left Outer Join:
https://gist.github.com/mxm
-04-15 5:59 GMT-05:00 Maximilian Michels m...@apache.org:
Hi Flavio,
Here's an simple example of a Left Outer Join:
https://gist.github.com/mxm/c2e9c459a9d82c18d789
As Stephan pointed out, this can be very easily modified to construct a
Right Outer Join (just exchange leftElements
, 2015 at 12:59 PM, Maximilian Michels m...@apache.org wrote:
Hi Flavio,
Here's an simple example of a Left Outer Join:
https://gist.github.com/mxm/c2e9c459a9d82c18d789
As Stephan pointed out, this can be very easily modified to construct a
Right Outer Join (just exchange leftElements
On 15 Apr 2015, at 10:30, Flavio Pompermaier pomperma...@okkam.it wrote:
Hi to all,
I have to join two datasets but I'd like to keep all data in the left also if
there' no right dataset.
How can you achieve that in Flink? maybe I should use coGroup?
Yes, currently you have to implement
Do you have an already working example of it? :)
On Wed, Apr 15, 2015 at 10:32 AM, Ufuk Celebi u...@apache.org wrote:
On 15 Apr 2015, at 10:30, Flavio Pompermaier pomperma...@okkam.it wrote:
Hi to all,
I have to join two datasets but I'd like to keep all data in the left
also if there'
please add link to explain left join using cogroup
or add example
very thanks
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Left-outer-join-tp1031p1034.html
Sent from the Apache Flink User Mailing List archive. mailing list archive
I think this may be a great example to add as a utility function.
Or actually add as an function to the DataSet, internally realized as a
special case of coGroup.
We do not have a ready example of that, but it should be straightforward to
realize. Similar as for the join, coGroup on the join
Hi to all,
I have to join two datasets but I'd like to keep all data in the left also
if there' no right dataset.
How can you achieve that in Flink? maybe I should use coGroup?
Best,
Flavio
Hi Flavio,
Here's an simple example of a Left Outer Join:
https://gist.github.com/mxm/c2e9c459a9d82c18d789
As Stephan pointed out, this can be very easily modified to construct a
Right Outer Join (just exchange leftElements and rightElements in the two
loops).
Here's an excerpt with the most
18 matches
Mail list logo
