PutRethinkDB

Description:

Processor to write the JSON content of a FlowFile to RethinkDB (https://www.rethinkdb.com/). The flow file should contain either JSON Object an array of JSON documents

Tags:

rethinkdb, stream, insert, update, write, put

Properties:

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, and whether a property supports the NiFi Expression Language.

Display NameAPI NameDefault ValueAllowable ValuesDescription
DB Namerethinkdb-dbnameRethinkDB database to connect to
Hostnamerethinkdb-hostlocalhostRethinkDB hostname
DB Portrethinkdb-port28015RethinkDB database port to connect to
Usernamerethinkdb-usernameUsername for accessing RethinkDB
Passwordrethinkdb-passwordPassword for user
Sensitive Property: true
Table namerethinkdb-tableRethinkDB table to connect to
Character Setrethinkdb-charsetUTF-8Specifies the character set of the document data.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Conflict strategyrethinkdb-conflict-strategyUpdate
  • Update Update the document having same id with new values
  • Replace Replace the document with having same id new document
  • Error Return error if the document with same id exists
Conflict strategy to be used in case of inserting existing document.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Durablity of documentsrethinkdb-durabilityHard
  • Hard Save change to disk before ack
  • Soft Don't save changes to disk before ack
Durability of documents being inserted
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Max size of documentsrethinkdb-max-document-size1 MBMaximum size of documents allowed to be posted in one batch

Relationships:

NameDescription
successSucessful FlowFiles are routed to this relationship
failureFailed FlowFiles are routed to this relationship

Reads Attributes:

None specified.

Writes Attributes:

NameDescription
rethinkdb.error.messageRethinkDB error message
rethinkdb.insert.errorsError count while inserting documents
rethinkdb.insert.deletedNumber of documents deleted
rethinkdb.insert.generated_keysKeys generated on inserting documents
rethinkdb.insert.insertedNumber of documents inserted
rethinkdb.insert.replacedNumber of documents replaced
rethinkdb.insert.skippedNumber of documents skipped because they already existed
rethinkdb.insert.unchangedNumber of documents unchanged since they already existed
rethinkdb.insert.first_errorFirst error while inserting documents
rethinkdb.insert.warningsWarning message in case of large number of ids being returned on insertion

State management:

This component does not store state.

Restricted:

This component is not restricted.

Input requirement:

This component requires an incoming relationship.

System Resource Considerations:

None specified.

See Also:

GetRethinkDB, DeleteRethinkDB