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
