package flinkConnector;

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

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Cluster.Builder;

public class ClusterBuilderProvider {
	
	static ClusterBuilder clusterBuilder =  new ClusterBuilder() {
		
		@Override
		protected Cluster buildCluster(Builder builder) {
			
			return builder.addContactPoint("192.168.15.40").build();
		}
	};
	
	
	static ClusterBuilder getClusterBuilder(){
		
			if( clusterBuilder != null)
				return clusterBuilder ;	
			else
				return new ClusterBuilder() {
		
			@Override
			protected Cluster buildCluster(Builder builder) {
				
				return builder.addContactPoint("192.168.15.40").build();
			}
		
		};
	}
			

}