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