Processor to remove a JSON document from RethinkDB (https://www.rethinkdb.com/) using the document id.
rethinkdb, delete, remove
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 (will be evaluated using flow file attributes and variable registry) | |
| Document Identifier | A 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) | ||
| Return deleted value | true |
| Return old value which were deleted Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Durablity of documents | hard |
| Durability of documents being inserted Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Name | Description |
|---|---|
| success | Sucessful FlowFiles are routed to this relationship |
| not_found | Document not found are routed to this relationship |
| failure | Failed FlowFiles are routed to this relationship |
| Name | Description |
|---|---|
| rethinkdb.error.message | RethinkDB error message |
| rethinkdb.delete.errors | Error count while delete documents |
| rethinkdb.delete.deleted | Number of documents deleted |
| rethinkdb.delete.inserted | Number of documents inserted |
| rethinkdb.delete.replaced | Number of documents replaced |
| rethinkdb.delete.skipped | Number of documents skipped |
| rethinkdb.delete.unchanged | Number of documents unchanged since they already existed |
