Hi Prashant,
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
actually I could make my custom trigger to fire periodically.
The problem is the element set stored in the iterable variable
is always uniform which is not what I'm expecting...
private static class MyWindowFunction_Window...
...
@Override
public void apply(Tuple tuple, W window, Iterable<MyClass> iterable,
...
for(MyClass element : iterable)
does anyone have any idea on this?
thanks a lot in advance,
jad
On Thu, Jul 13, 2017 at 10:55 AM, prashantnayak <
prash...@intellifylearning.com> wrote:
> Hi
>
> We've have custom operators using global windows and are using event time.
>
> How are you specifying event time as the time characteristic?
>
> Prashant
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/global-window-
> trigger-tp14206p14239.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
