Package | Description |
---|---|
org.apache.flink.batch.connectors.cassandra | |
org.apache.flink.streaming.connectors.cassandra |
Class and Description |
---|
ClusterBuilder
This class is used to configure a
Cluster after deployment. |
MapperOptions
This class is used to configure a
Mapper after deployment. |
Class and Description |
---|
AbstractCassandraTupleSink
Abstract sink to write tuple-like values into a Cassandra cluster.
|
CassandraAppendTableSink
An
AppendStreamTableSink to write an append stream Table to a Cassandra table. |
CassandraFailureHandler
An implementation of
CassandraFailureHandler is provided by the user to define how
Throwable should be handled, e.g. |
CassandraSink
This class wraps different Cassandra sink implementations to provide a common interface for all of them.
|
CassandraSink.CassandraSinkBuilder
Builder for a
CassandraSink . |
CassandraSinkBase
CassandraSinkBase is the common abstract class of
CassandraPojoSink and CassandraTupleSink . |
ClusterBuilder
This class is used to configure a
Cluster after deployment. |
MapperOptions
This class is used to configure a
Mapper after deployment. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.