Description:

Processor to remove a JSON document from RethinkDB (https://www.rethinkdb.com/) using the document id.

Tags:

rethinkdb, delete, remove

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
Return deleted value	true	* True * False	Return old value which were deleted Supports Expression Language: true
Durability of documents	hard	* Hard * Soft	Durability of documents being inserted Supports Expression Language: true

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	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

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, GetRethinkDB