Hi,
thanks Nuno for the analysis and yes, please keep us updated : )
And, still, Pull Requests are welcome.
We retire the project from the Apache Foundation but we will move it over to
Github and it will stay there and a new community can gather.
Best
Julian
Am 03.10.19, 23:09 schrieb "Nuno Coelho" <ng.coe...@campus.fct.unl.pt>:
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.feina...@pragmaticminds.de <mailto:j.feina...@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.coe...@campus.fct.unl.pt <mailto:ng.coe...@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
>
>
>
