Re: Time controlled ingestion operator

2016-05-23 Thread Devendra Tagare
Hi Sunil, The current implementation of JDBC input operator does not support a time-controlled behavior. As a reference on how to do polling reads there is a PR opened - https://github.com/apache/incubator-apex-malhar/pull/282 One of the solutions for the use-case using Apex features would be as

Re: Time controlled ingestion operator

2016-05-23 Thread Priyanka Gugale
Hi Sunil, I don't think we have exactly pause and resume feature in Malhar yet. But I can think of some other way to achieve this. We are adding bandwidth control feature to Malhar. The pull request is already opened for the same. This doe

Time controlled ingestion operator

2016-05-23 Thread Sunil Parmar
All, We're writing an app for migration data from legacy JDBC system to Kafka. Legacy system as it is still being used in production, we would want to pause the JDBC poll input operator for configured hours. Does malhar ibrary has any operator that we can use for time controlled operator ? Or i