Hello, I wondered why the cassandra connector has such an unusual interface: CassandraSink<Reading> csink = CassandraSink.addSink(readings) while all other sinks seem to look like
RMQSink<Reading> sink = new RMQSink<Reading>(cfg, "readings_persist_out", new JSONReadingSchema()); readings.addSink(sink); best, Stephan
