|
Type |
Name |
Description |
|
Processor |
GroovyExecutionService |
Delegates Groovy script execution to a remote service. This processor is designed
for users who want to run dynamic scripts in a less restrictive execution environment.
The script is responsible for handling the incoming flow file (e.g., transfer to SUCCESS
or remove.) |
|
Processor |
InvokeOSIPI |
OSI PI processor interacts with the PI Web API RESTful interface, giving client applications read and write access to their AF and PI data over HTTPS. The PI Server URL and HTTP Method are configurable. Processor is available in both Cloud and Cloud Connector (DCC). |
|
Processor |
DeleteFile |
Deletes a file from the filesystem. Available only for Cloud Connector (DCC) Process
Groups. |
|
Processor |
FetchFile
|
Reads the contents of a file from disk and streams it into the contents of an incoming
FlowFile. Available only for Cloud Connector (DCC) Process Groups. |
|
Processor |
GetFile
|
Creates FlowFiles from files in a directory. Available only for Cloud Connector (DCC)
Process Groups. |
|
Processor |
ListFile
|
Retrieves a listing of files from the input directory. For each file listed, creates
a FlowFile that represents the file so that it can be fetched in conjunction with
FetchFile. Available only for Cloud Connector (DCC) Process Groups. |
|
Processor |
PutFile |
Writes the contents of a FlowFile to the local file system. Available only for Cloud
Connector (DCC) Process Groups. |
|
Controller Service |
ParquetReader |
Parses Parquet data and returns each Parquet record as a separate Record object. The schema will come from the Parquet data itself. Can be utilized with processors, such as ConvertRecord. |
|
Controller Service |
ParquetRecordSetWriter |
Writes the contents of a RecordSet in Parquet format. Can be utilized with processors, such as ConvertRecord. |