org.apache.flink.streaming.connectors.cassandra

Class ClusterBuilder

java.lang.Object

org.apache.flink.streaming.connectors.cassandra.ClusterBuilder

All Implemented Interfaces:

Serializable

public abstract class ClusterBuilder
extends Object
implements Serializable

This class is used to configure a Cluster after deployment. The cluster represents the connection that will be established to Cassandra.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ClusterBuilder()

Method Summary

Modifier and Type	Method and Description
protected abstract com.datastax.driver.core.Cluster	buildCluster(com.datastax.driver.core.Cluster.Builder builder) Configures the connection to Cassandra.
com.datastax.driver.core.Cluster	getCluster()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterBuilder

public ClusterBuilder()

Method Detail

getCluster

public com.datastax.driver.core.Cluster getCluster()

buildCluster

protected abstract com.datastax.driver.core.Cluster buildCluster(com.datastax.driver.core.Cluster.Builder builder)

Configures the connection to Cassandra. The configuration is done by calling methods on the builder object and finalizing the configuration with build().

Parameters:

builder - connection builder

Returns:

configured connection