![]() This mechanism is intended only to provide a mechanism for storing very 'simple' state. The stateĬan be stored local to the node or across all nodes in a cluster. Very easily store a set of key/value pairs, retrieve those values, and update them atomically. This mechanism is intended to provide developers with the ability to This State Manager is responsible for providing a simple APIįor storing and retrieving state. Processor or ConfigurationContext if the componentįrom the ProcessContext, ReportingContext, and ControllerServiceInitializationContext, components areĪble to call the getStateManager() method. The argument must be of type ProcessContext if the component is a If the single argument variation is used, Methods with this annotation may take zero arguments or may take a Process will start again, until all of the methods annotated have returned without throwing any Exception. That is configured in the nifi.properties file. Referred to as the "Administrative Yield Duration," which is a value TheĬomponent will then yield its execution for some period of time, Methods throws an Exception, those Exceptions are ignored). In this case, methods annotated are then triggered, followed by methods with annotation (during this state, if any of these If any method with thisĪnnotation throws an Exception, other methods with thisĪnnotation will not be invoked, and a notification will be presented Used only for Processors and Reporting Tasks. Because ControllerServicesĪre not scheduled, using this annotation on a ControllerService does This annotation indicates that a method should be called every time That the thread invoking this method is the only thread currentlyĮxecuting code in the Processor, unless the Processor itself The point that this method is invoked, it is guaranteed Value is actually modified, rather than beingĬalled when a user updates a Processor without changing its value. Note that this method will be called regardless of whether Was removed, the third argument will be null. The method takes three arguments: the PropertyDescriptor that OnPropertyModified method will be called for each modified property. Method allows a Processor to do just that. It is sometimes desirable to have a Processor eagerly react when its Exceptions within a callback: IOException, RuntimeException. ![]() ![]() Route Streams Based on Content (One-to-Many).Documenting FlowFile Attribute Interaction. ![]()
0 Comments
Leave a Reply. |