Stack Overflow
Stack Overflow

Questions tagged [apache-edgent]

Apache Edgent is a programming model and runtime for edge devices.

Apache Edgent enables real-time data analytics on edge devices (e.g. embedded systems, Raspberry Pis, smart phones), so they don't need to report every sensor reading over a network.

Edgent is previously named Apache Quarks.

Edgent is open source.

10 questions
2
votes
1 answer

what exactly is tuple in TStream?

Here is the code taken from Apache Edgent Documentation I could not understand what tuple exactly is. The code is given below: public static void main(String[] args) throws Exception { TempSensor sensor = new TempSensor(); DirectProvider dp…
Arun Subba
  • 33
  • 7
1
vote
3 answers

How to change the operators at runtime of a Stream Dataflow program?

I wonder if I can change the operators of a job already submitted to Flink. Suppose I have a word count program and there is a filter on it to count only words larger than 3 characters. I want to change the parameters of this filter at runtime. My…
Felipe
  • 7,013
  • 8
  • 44
  • 102
1
vote
2 answers

Joining streams of different types in Apache Edgent

I have 3 streams: TStream tempReadings=topology.poll(tempSensor, 10, TimeUnit.SECONDS); TStream co2Readings=topology.poll(co2Sensor, 10, TimeUnit.SECONDS); TStream stationaryReadings=topology.poll(stationarySensor, 10,…
E Shindler
  • 425
  • 7
  • 27
1
vote
1 answer

How to filter a stream of tuple with Apache Edgent

I created a source function according to this manual. public static void main(String[] args) throws Exception { DirectProvider dp = new DirectProvider(); Topology top = dp.newTopology(); final URL url = new…
Edelstoff990
  • 41
  • 3
0
votes
1 answer

Is that possible to have the same behavior of CoFlatMapFunction using other basic operators?

Basically, I am using CoFlatMapFunction (https://ci.apache.org/projects/flink/flink-docs-stable/api/java/org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.html) to filter a stream and change the filter parameters at runtime and I am…
Felipe
  • 7,013
  • 8
  • 44
  • 102
0
votes
2 answers

How to filter on Apache Edgent and also show the values which were filtered?

I am using Apache Edgent (Java framework) to poll values from a HCSR04 ultrasonic sensor on a Raspberry Pi every 3 seconds. I use a filter to not get values from 50cm to 80cm. UltrasonicStream sensor = new UltrasonicStream(); DirectProvider…
Felipe
  • 7,013
  • 8
  • 44
  • 102
0
votes
1 answer

How can I shutdown an Apache Edgent background task?

Asume the following code snippet: TStream stream = top.generate(() -> { try{ Thread.sleep(1500); }catch(InterruptedException ex){ //DO NOTHING } return (int)(Math.random() * 100); }); TWindow…
KDW
  • 485
  • 3
  • 17
0
votes
2 answers

Why isn't the filter method working?

As given in the docs of Apache Edgent I tried to filter out my sensor readings wherein the values of the temperature sensor must lie in between 80 to 85 F. But when I tried connecting my sensor the readings were 75F and no message was shown…
Arun Subba
  • 33
  • 7
0
votes
1 answer

Which one to use for implementing Edge Analytics? Apache Edgent or Kaa?

I have came across the term edge analytics in recent times and understood the advantages of pushing intelligence to edge devices. Now coming to implementation, I have gone through Apache Edgent and Kaa. Both seems to perform more or less similar job…
Karthick S
  • 89
  • 1
  • 6
0
votes
1 answer

What is the format of the optionsFile for the IotFDevice class in Quarks?

The IotfDevice Class in Quarks has a constructor with an optionsFile. What is the format of this file and what are the necessary values?
Kathy Saunders
  • 3
  • 1