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.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
