Re: Some questions regarding Apache Edgent (adpatable windows width)

[Nuno Coelho <ng...@campus.fct.unl.pt>]

PS: I wrote the e-mail yesterday in a rush, and forgot to link the javadoc:

[1]

https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/execution/mbeans/PeriodMXBean.html

I also noticed that this is an open issue in JIRA:

https://issues.apache.org/jira/projects/EDGENT/issues/EDGENT-147?filter=allopenissues

So I believe this answers the question of whether or not it's possible.. 
it is, but it's not implemented : -)

I'll keep digging on how to do it.

Cheers,

Nuno

On 03/10/19 21:08, Nuno Coelho wrote:
>
> Hello there, thank you so much for your timely responses
>
> I'm still not completely sure that it's not possible though. Mostly 
> because of this right here [1] :
>
> "This mbean lacks a |TYPE| declaration because it's a generic control 
> interface applicable to a variety of object types (e.g., a stream or 
> *window*). The type of the associated object is to be used when 
> registering instances of this mbean with the Control Service."
>
> So I'd guess that whoever built the interface was thinking of that 
> possibility.
>
> However, at the same time I've been looking around through the code 
> and from what I've understood it seems that only sourced streams are 
> able to have their polling time adapted out-of-the-box, while 
> connector streams are not. And with the /last()/ method we always 
> receive a connector stream feeding the window.
>
> It would be really nice to have that feature and I'm not ready to give 
> up just yet.
>
> So if you guys discover anything relevant I'd appreciate it. I'll tell 
> something as well if I come across something.
>
> Cheers,
>
> Nuno.
>
>
>
> |||||| 
> <https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/execution/services/ControlService.html>
>
> On 02/10/19 21:05, Felipe Gutierrez wrote:
>> Hi Nuno.
>>
>> I am not sure if edgent disposes dynamic time for windows. my guess 
>> is no according to this documentation [1]. However you can 
>> implemennnt it using flink UDFs [2].
>>
>> Best. Felipe
>>
>> [1] 
>> https://edgent.incubator.apache.org/javadoc/latest/org/apache/edgent/topology/TStream.html#last-long-java.util.concurrent.TimeUnit-org.apache.edgent.function.Function-
>> [2] 
>> https://stackoverflow.com/questions/45232804/how-to-pass-dynamic-value-to-timewindowdynamic-time-in-flink
>>
>> On Wed, 2 Oct 2019, 16:32 Julian Feinauer, 
>> <j.feinauer@pragmaticminds.de <ma...@pragmaticminds.de>> 
>> wrote:
>>
>>     Hi Nuno,
>>
>>     nice to hear from you : )
>>     I have to admit, that I'm no expert user of edgent and I will
>>     have to dig a bit into the code to see if and how this works.
>>     Alternatives (on other frameworks) for exactly this task could be
>>     Apache Flink or Apache Camel.
>>     In the later it should definetly work to have dynamic windows
>>     with Flink I'm not sure, but I've already used the Time Windows
>>     several times there.
>>
>>     I hope that helps.
>>
>>     Julian
>>
>>     PS.: I've cc'ed the Mailing list, just in case someone is reading
>>     it there (
>>
>>     Am 02.10.19, 16:30 schrieb "Nuno Coelho"
>>     <ng.coelho@campus.fct.unl.pt <ma...@campus.fct.unl.pt>>:
>>
>>         Good afternoon Mr. Feinauer.
>>
>>         My name is Nuno Coelho and I am currently doing my CS Masters
>>     Degree at
>>         FCT. My final project will integrate components of the edge
>>     framework ,
>>         and so I've sent you this e-mail because I have some questions:
>>
>>         -First of all, if I should have send this e-mail to any of
>>     the Edgent
>>         mailing lists, please forgive me. I have peek them lately
>>     (that's how I
>>         got this e-mail) and saw that Edgent is retiring from Apache
>>     so I don't
>>         know if or how active the mailing lists are. I intend to make
>>     more
>>         inquires in the future so I'd appreciate if you told me where
>>     is it
>>         appropriate to do so.
>>
>>         Now my technical question is: is edgent able to create time
>>     windows that
>>         are adaptable at runtime ? If so, how do I do it? I ask this
>>     because
>>         from following your tutorials at the website I got the hint
>>     that the
>>         windows can be registered to a control service like TStream
>>     but I am
>>         failing to understand exactly how to do it...
>>
>>
>>         I'll be waiting for a reply, any advise will be helpfull.
>>     Thanks in advance!
>>
>>         Greetings,
>>
>>         Nuno Coelho
>>
>>
>>