Description:

Processor to get a JSON document from RethinkDB (https://www.rethinkdb.com/) using the document id. The FlowFile will contain the retrieved document.

Tags:

rethinkdb, get, read, fetch

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, 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 nifi.properties file has an entry for the property nifi.sensitive.props.key.

Name

Default Value

Allowable Values

Description

DB Name

RethinkDB database to connect to

Hostname

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



Document Identifier

A FlowFile attribute, or attribute expression used for determining RethinkDB key for the Flow File content

Supports Expression Language: true



Read Mode

single * Single
* Majority
* Outdated
Read mode used for consistency

Supports Expression Language: true



Max size of documents

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

Relationships:

Name

Description

success Successful FlowFiles are routed to this relationship
not_found Document not found are routed to this relationship
failure Failed FlowFiles are routed to this relationship

Reads Attributes:

None specified.

Writes Attributes:

Name

Description

rethinkdb.error.message Rethink DB error message

State management:

This component does not store state.

Restricted:

This component is not restricted.

Input requirement:

This component requires an incoming relationship.

See Also:

PutRethinkDB, DeleteRethinkDB