Package | Description |
---|---|
org.apache.flink.streaming.connectors.cassandra |
Modifier and Type | Class and Description |
---|---|
class |
CassandraRowSink
A SinkFunction to write Row records into a Cassandra table.
|
class |
CassandraScalaProductSink<IN extends scala.Product>
Sink to write scala tuples and case classes into a Cassandra cluster.
|
class |
CassandraTupleSink<IN extends Tuple>
Sink to write Flink
Tuple s into a Cassandra cluster. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.