GetRethinkDB

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.

NameDefault ValueAllowable ValuesDescription
DB NameRethinkDB database to connect to
HostnamelocalhostRethinkDB hostname
DB Port28015RethinkDB database port to connect to
UsernameUsername for accessing RethinkDB
PasswordPassword for user
Sensitive Property: true
Table nameRethinkDB table to connect to
Character SetUTF-8Specifies the character set of the document data.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Document IdentifierA FlowFile attribute, or attribute expression used for determining RethinkDB key for the Flow File content
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Read Modesingle
  • Single Read values from memory from primary replica (Default)
  • Majority Read values committed to disk on majority of replicas
  • Outdated Read values from memory from an arbitrary replica
Read mode used for consistency
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Max size of documents1 MBMaximum size of documents allowed to be posted in one batch

Relationships:

NameDescription
successSucessful FlowFiles are routed to this relationship
not_foundDocument not found are routed to this relationship
failureFailed FlowFiles are routed to this relationship

Reads Attributes:

None specified.

Writes Attributes:

NameDescription
rethinkdb.error.messageRethinkDB error message

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:

PutRethinkDB, DeleteRethinkDB