Processor to write the JSON content of a FlowFile to RethinkDB ( The flow file should contain either JSON Object an array of JSON documents


rethinkdb, stream, insert, update, write, put


In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, whether a property supports the NiFi Expression Language, and whether a property is considered “sensitive”, meaning that its value will be encrypted. Before entering a value in a sensitive property, ensure that the file has an entry for the property nifi.sensitive.props.key.


Default Value

Allowable Values


DB Name

RethinkDB database to connect to


localhost RethinkDB hostname

DB Port

28015 RethinkDB database port to connect to
Username Username for accessing RethinkDB
Password Password for user

Sensitive Property: true

Table name

RethinkDB table to connect to

Character Set

UTF-8 Specifies the character set of the document data.

Supports Expression Language: true

Conflict strategy

update * Update
* Replace
* Error 
Conflict strategy to be used in case of inserting existing document.

Supports Expression Language: true

Durability of documents

hard * Hard
* Soft
Durability of documents being inserted

Supports Expression Language: true

Max size of documents

1 MB Maximum size of documents allowed to be posted in one batch




success Successful FlowFiles are routed to this relationship
failure Failed FlowFiles are routed to this relationship

Reads Attributes:

None specified.

Writes Attributes:



rethinkdb.error.message RethinkDB error message
rethinkdb.insert.errors Error count while inserting documents
rethinkdb.insert.deleted Number of documents deleted
rethinkdb.insert.generated_keys Keys generated on inserting documents
rethinkdb.insert.inserted Number of documents inserted
rethinkdb.insert.replaced Number of documents replaced
rethinkdb.insert.skipped Number of documents skipped because they already existed
rethinkdb.insert.unchanged Number of documents unchanged since they already existed
rethinkdb.insert.first_error First error while inserting documents
rethinkdb.insert.warnings Warning message in case of large number of ids being returned on insertion

State management:

This component does not store state.


This component is not restricted.

Input requirement:

This component requires an incoming relationship.

See Also:

GetRethinkDB, DeleteRethinkDB