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)


  • No labels