Mark, ok that makes sense. I have created a jira for this improvement https://issues.apache.org/jira/browse/NIFI-1805
On Fri, Apr 22, 2016 at 12:27 PM, Mark Payne <marka...@hotmail.com> wrote: > Jeremy, > > It should be relatively easy. In FlowController, we would have to update > getGroupStatus() to set the values on ConnectionStatus > and of course update ConnectionStatus to have getters & setters for the > new values. That should be about it, I think. > > -Mark > > > > On Apr 22, 2016, at 12:17 PM, Jeremy Dyer <jdy...@gmail.com> wrote: > > > > Mark, > > > > What would the process look like for doing that? Would that be something > > trivial or require some reworking? > > > > On Fri, Apr 22, 2016 at 10:26 AM, Mark Payne <marka...@hotmail.com> > wrote: > > > >> I definitely don't think we should be exposing the FlowController to a > >> Reporting Task. > >> However, I think exposing information about whether or not backpressure > is > >> being applied > >> (or even is configured) is a very reasonable idea. > >> > >> -Mark > >> > >> > >>> On Apr 22, 2016, at 10:22 AM, Jeremy Dyer <jdy...@gmail.com> wrote: > >>> > >>> I could see the argument for not making that available. What about some > >>> sort of reference that would allow the ReportingTask to to determine if > >>> backpressure is being applied to a Connection? It currently seems you > can > >>> see the number of bytes and/or objects count queued in a connection but > >>> don't have any reference to the values a user has setup for > backpressure > >> in > >>> the UI. Is there a way to get those values in the scope of the > >>> ReportingTask? > >>> > >>> On Fri, Apr 22, 2016 at 10:03 AM, Bryan Bende <bbe...@gmail.com> > wrote: > >>> > >>>> I think the only way you could do it directly without the REST API is > by > >>>> having access to the FlowController, > >>>> but that is purposely not exposed to extension points... actually > >>>> StandardFlowController is what implements the > >>>> EventAccess interface which ends up providing the path way to the > status > >>>> objects. > >>>> > >>>> I would have to defer to Joe, Mark, and others about whether we would > >> want > >>>> to expose direct access to components > >>>> through controller services, or some other extension point. > >>>> > >>>> On Fri, Apr 22, 2016 at 9:46 AM, Jeremy Dyer <jdy...@gmail.com> > wrote: > >>>> > >>>>> Bryan, > >>>>> > >>>>> The ReportingTask enumeration makes sense and was helpful for > something > >>>>> else I am working on as well. > >>>>> > >>>>> Like Joe however I'm looking for a way to not just get the *Status > >>>> objects > >>>>> but rather start and stop processors. Is there a way to do that from > >> the > >>>>> ReportContext scope? I imagine you could pull the Processor "Id" from > >> the > >>>>> ProcessorStatus and then use the REST API but was looking for > something > >>>>> more direct than having to use the REST API > >>>>> > >>>>> > >>>>> On Fri, Apr 22, 2016 at 9:23 AM, Bryan Bende <bbe...@gmail.com> > wrote: > >>>>> > >>>>>> Hi Joe, > >>>>>> > >>>>>> I'm not sure if a controller service can do this, but a > ReportingTask > >>>> has > >>>>>> access to similar information. > >>>>>> > >>>>>> A ReportingTask gets access to a ReportingContext, which can access > >>>>>> EventAccess which can access ProcessGroupStatus. > >>>>>> > >>>>>> From ProcessGroupStatus you are at the root process group and can > >>>>> enumerate > >>>>>> the flow: > >>>>>> > >>>>>> private Collection<ConnectionStatus> connectionStatus = new > >>>>> ArrayList<>(); > >>>>>> private Collection<ProcessorStatus> processorStatus = new > >>>> ArrayList<>(); > >>>>>> private Collection<ProcessGroupStatus> processGroupStatus = new > >>>>>> ArrayList<>(); > >>>>>> private Collection<RemoteProcessGroupStatus> > remoteProcessGroupStatus > >> = > >>>>> new > >>>>>> ArrayList<>(); > >>>>>> private Collection<PortStatus> inputPortStatus = new ArrayList<>(); > >>>>>> private Collection<PortStatus> outputPortStatus = new ArrayList<>(); > >>>>>> > >>>>>> Not sure if that is what you were looking for. > >>>>>> > >>>>>> -Bryan > >>>>>> > >>>>>> > >>>>>> On Fri, Apr 22, 2016 at 8:25 AM, Joe Skora <jsk...@gmail.com> > wrote: > >>>>>> > >>>>>>> Is it possible and if so what is the best way for a controller > >>>> service > >>>>> to > >>>>>>> get the collection of all processors or queues? > >>>>>>> > >>>>>>> The goal being to iterate over the collection of processors or > queues > >>>>> to > >>>>>>> gather information or make adjustments to the flow. > >>>>>>> > >>>>>> > >>>>> > >>>> > >> > >> > >
