IMPORTANT: This documentation has been discontinued. Read the updated Cassandra DB documentation on our new documentation portal.
Take a look at some of the component's configuration parameters:
Account: account to be used by the component to connect to AWS. It can be of the AWSv4 type, with access key and secret, or Basic for accessing a Cassandra server in a data center, with a username and password.
Operation: operation to be performed (INSERT, UPDATE, SELECT, DELETE).
Connection String: connection string with host, port and keyspace to use.
Query: CQL specification, depending on the selected operation. This parameter accepts Double Braces.
Max Wait For Operation (in ms): time (in ms) the application must wait until the query is finished.
Heartbeat Connection Timeout (in ms):dummy request to keep connections alive in the pool.
Fail On Error: if the option is enabled, the execution of the pipeline with error will be stopped; otherwise, the pipeline execution continues, and the result will show the value false for the "success" property.
Advanced: Opens for further options.
Pool Size By Actual Consumers: If "true", the number of pooled connections will be equivalent to the number of consumers configured during pipeline deployment, if "false", then the pool size is given by the pipeline deployment size, irrespective of the number of consumers
Cassandra DB in Action
CQL (Cassandra Query Language), as the name implies, is the query language for Cassandra. It uses variables in its queries by wrapping them in Double Braces, like {{id}}. To read our article on Double Braces, click here.
Operation INSERT
Output
{
"data": {},
"insertCount": 1
}
Operation UPDATE
Output
{
"data": {},
"updateCount": 1
}
Operation SELECT
Output
{
"data": [{
"id": "5095e726-d790-4f93-9a71-10ecf2cdd72f",
" firstName": "Rafael",
" lastName": "Garbin"
}],
"rowCount": 1
}
Operation DELETE
Output
{
"data": {},
"deleteCount": 1
}
Option Advanced
