Rui Shen created EDGENT-308:
-------------------------------
Summary: Is it possible to use poll() with FileStreams together
Key: EDGENT-308
URL: https://issues.apache.org/jira/browse/EDGENT-308
Project: Edgent
Issue Type: New Feature
Components: Connectors
Reporter: Rui Shen
My requirement is to load data from a file and polling with a specific
frequency (say every 1 second).
I found Topology.poll() can do this, but it requires a Supplier parameter and
the get method is called periodically. With this way, I have to read the file
content myself and create a Iterable instance, then a Supplier.
I want to use FileStreams.textFileReader() to handle the file reading. The
problem is how to use it with Topology.poll() together? I could not find a way
to do this.
Is there any way to do this? Or connectors does not support "polling" at all?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
