We have 2 independent streams which will receive elements in different
frequency,
DataStream> splittedActivationTuple;
DataStream> unionReloadsStream;
We have a requirement to keep "splittedActivationTuple" stream elements in
a Window of eviction time period of 24 hours. So I created a
"Windowed
Friends, any assistance regarding this?
On Mon, Jul 16, 2018 at 3:34 PM, Titus Rakkesh
wrote:
> We have 2 independent streams which will receive elements in different
> frequency,
>
> DataStream> splittedActivationTuple;
>
> DataStream> unionReloadsStream;
>
>
Dear Friends,
I have 2 streams of the below data types.
DataStream> splittedActivationTuple;
DataStream> unionReloadsStream;
These streams are getting data from Kafka and getting data in different
frequencies. "unionReloadsStream" will receive more data than
"splittedActivationTuple".
t;
> Did you call `execute()`on your `StreamExecutionEnvironment`?
>
> Best,
> Xingcan
>
> > On Jul 18, 2018, at 5:12 PM, Titus Rakkesh
> wrote:
> >
> > Dear Friends,
> > I have 2 streams of the below data types.
> >
> > DataStream> splittedActivat
er/dev/table/sql.html#joins
>
>
> On Jul 18, 2018, at 5:55 PM, Titus Rakkesh
> wrote:
>
> Thanks for the reply. I have called "env.execute()". But nothing getting
> printed. I have a doubt whether "implemented function" is correct with my
> "requirement
Dears,
I have a data stream continuously coming,
DataStream> splitZTuple;
Eg - (775168263,113182,0.0)
I have to store this for 24 hrs expiry in somewhere (Window or somewhere)
to check against another stream.
The second stream is
DataStream> splittedVomsTuple which also
continuously receivin
ction>for
> that.
> Find matching elements via keyBy() on the first field.
> Aggregate into ValueState, send alert if necessary.
> Upon encountering a new key, setup a timer to remove the entry in 24h.
>
> On 08.02.2019 07:43, Titus Rakkesh wrote:
>
> Dears,
>
>
Dears,
We are having the use case of creating and uploading new patterns
dynamically and change the app behavior in runtime. Is the current Flink
version support that?
Thanks
Unsubscribe
