edgent-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Rui Shen (JIRA)" <j...@apache.org>
Subject [jira] [Created] (EDGENT-308) Is it possible to use poll() with FileStreams together
Date Fri, 04 Nov 2016 07:08:58 GMT
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

View raw message