Skip to main content

ScriptedRecordSink

Description

Allows the user to provide a scripted RecordSinkService instance in order to transmit records to the desired target. The script must set a variable 'recordSink' to an implementation of RecordSinkService.

Tags

groovy, invoke, record, record sink, script

Properties

In the list below required Properties are shown with an asterisk (*). Other properties are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.

Display NameAPI NameDefault ValueAllowable ValuesDescription
Script Engine *Script EngineGroovy
  • Groovy
Language Engine for executing scripts
Script FileScript FilePath to script file to execute. Only one of Script File or Script Body may be used

Supports Expression Language, using Environment variables.
Script BodyScript BodyBody of script to execute. Only one of Script File or Script Body may be used
Module DirectoryModule DirectoryComma-separated list of paths to files and/or directories which contain modules required by the script.

Supports Expression Language, using Environment variables.

State Management

This component does not store state.

Restricted

Required PermissionExplanation
execute codeProvides operator the ability to execute arbitrary code assuming all permissions that NiFi has.

System Resource Considerations

This component does not specify system resource considerations.

See Also