Cassandra Input

The Cassandra Input transform reads data from a Cassandra table of an Apache Cassandra cluster using CQL (Cassandra Query Language) version 3.x.


Option Description

Cassandra connection

Here you specify the name of the connection to use either as a fixed value or as a variable expression. There are buttons to the right of the input field to hel you manage the metadata.

Transport max length

Set an optional maximum object size that can be sent. Leaving it blank means that the default cluster value is used. (typically 16384000)

Execute query for each incoming row?

This will cause the query to be executed repeatedly: once per input row.


The Cassandra Query Language statement you want to use. For more information on CQL, see Introduction to Cassandra Query Language