Performing the Work
When a Processor has work to do, it is scheduled to do so by having its
onTrigger
method called by the framework. The method takes two
arguments: a ProcessContext
and a ProcessSession
.
The first step in the onTrigger
method is often to obtain a FlowFile
on which the work is to be performed by calling one of the get
methods on the ProcessSession. For Processors that ingest data into NiFi from external
sources, this step is skipped. The Processor is then free to examine FlowFile
attributes; add, remove, or modify attributes; read or modify FlowFile content; and
transfer FlowFiles to the appropriate Relationships.