RE: Implementing Gates with the Wait and Notify Processors

2019-04-24 Thread Shawn Weeks
changed the contents of the cache. -Original Message- From: Koji Kawamura Sent: Wednesday, April 24, 2019 7:11 PM To: users@nifi.apache.org Subject: Re: Implementing Gates with the Wait and Notify Processors Hi Shawn, I have done similar flow before, using Wait/Notify processors

Re: Implementing Gates with the Wait and Notify Processors

2019-04-24 Thread Shawn Weeks
when things are clustered. Thanks Shawn From: Bryan Bende Sent: Wednesday, April 24, 2019 9:25 AM To: users@nifi.apache.org Subject: Re: Implementing Gates with the Wait and Notify Processors I think the Wait/Notify processors may have changed a bit since I last used

Re: Implementing Gates with the Wait and Notify Processors

2019-04-24 Thread Bryan Bende
through that don’t match the >> Target Signal Count. For example if the target signal count is 1 then it’s >> letting things through that have a target signal count of 2? I’ve got to be >> missing something rather obvious. >> >> >> >> Thanks >> &g

Re: Implementing Gates with the Wait and Notify Processors

2019-04-24 Thread Jerry Vinokurov
got > to be missing something rather obvious. > > > > Thanks > > Shawn > > > > *From:* Shawn Weeks > *Sent:* Tuesday, April 23, 2019 8:32 PM > *To:* users@nifi.apache.org > *Subject:* Implementing Gates with the Wait and Notify Processors > > >

Re: Implementing Gates with the Wait and Notify Processors

2019-04-23 Thread Jerry Vinokurov
Hi Shawn, I think it's a hard question to answer in the general sense. A lot depends on your specific implementation. What are you using to originate your flow? Is it a GenerateFlowFile processor, a List, or something else? There are a couple of different strategies that I've discovered for

Implementing Gates with the Wait and Notify Processors

2019-04-23 Thread Shawn Weeks
I'm working to implement a flow where for a given source of data I can only be processing one set at a time due to external dependencies. Each set needs to go through several different steps so this isn't just a matter of limiting concurrency for a single processor. I'm trying to implement this