DeleteRethinkDB

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, and whether a property supports the NiFi Expression Language.

Display NameAPI NameDefault ValueAllowable ValuesDescription
DB Namerethinkdb-dbnameRethinkDB database to connect to
Hostnamerethinkdb-hostlocalhostRethinkDB hostname
DB Portrethinkdb-port28015RethinkDB database port to connect to
Usernamerethinkdb-usernameUsername for accessing RethinkDB
Passwordrethinkdb-passwordPassword for user
Sensitive Property: true
Table namerethinkdb-tableRethinkDB table to connect to
Character Setrethinkdb-charsetUTF-8Specifies the character set of the document data.
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Document Identifierrethinkdb-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)
Return deleted valuerethinkdb-return-resultTrue
  • True Return changed document
  • False Do not return changed document
Return old value which were deleted
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)
Durablity of documentsrethinkdb-durabilityHard
  • Hard Save change to disk before ack
  • Soft Don't save changes to disk before ack
Durability of documents being inserted
Supports Expression Language: true (will be evaluated using flow file attributes and variable registry)

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
rethinkdb.delete.errorsError count while delete documents
rethinkdb.delete.deletedNumber of documents deleted
rethinkdb.delete.insertedNumber of documents inserted
rethinkdb.delete.replacedNumber of documents replaced
rethinkdb.delete.skippedNumber of documents skipped
rethinkdb.delete.unchangedNumber 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.

System Resource Considerations:

None specified.

See Also:

PutRethinkDB, GetRethinkDB