This feature is currently work in progress.

To use this operator, the Cassandra feature needs to be installed.

CassandraWriter

With this operator, the data can be written to a Apache Cassandra NoSQL storage.

Parameters (required):

• hosts: A list of key value pairs, each representing a hostname and a server port
• keyspace: the Keyspace to write to
• table: the table to write to
• idAttribute: the attribute that is key for cassandra

Parameters (optional):

• datacenter: Name of the datacenter, default "datacenter1"
• username: If authentication is required: The username
• password: If authentication is required: The password
• useHttps (Boolean):  Currently no function
• createKeyspace (Boolean): Create keyspace, if it does not exist. Default is true
• replicationStrategy: Strategy to use, if keyspace is created by Odysseus (Default: SimpleStrategy)
• replicationFactor: Factor to use, if keyspace is created by Odysseus (Default: 1)
• createTable (Boolean):  Create table, if does not exist. Default is true.
• recreateTable (Boolean): If table exists, drop table and create afterwords. Default is false

Example

#PARSER PQL
#ADDQUERY
sink = CassandraWriter({hosts = [['cassandra1.lan',9042]], KEYSPACE = 'Nexmark', TABLE = 'person', IDATTRIBUTE = 'id'},nexmark:person)