// Path: src/main/java/com/stratio/connector/deep/configuration/DeepConnectorConstants.java
// public final class DeepConnectorConstants {
// 	private DeepConnectorConstants(){
// 
// 	}
// 
// 	public static final String HDFS = "hdfs";
// 	public static final String SPARK_MASTER = "spark.master";
// 	public static final String SPARK_HOME = "spark.home";
// 	public static final String SPARK_JARS = "spark.jars";
// 	public static final String CLUSTER_PREFIX_CONSTANT = "cluster";
// 	public static final String IMPL_CLASS_SUFIX_CONSTANT = ".implClass";
// 	public static final String EXTRACTOR_IMPL_CLASS = "extractorImplClass";
// 	public static final String DEEP_CONNECTOR_JOB_CONSTANT = "DeepConnectorJob";
// 
// 	public static final int DEFAULT_RESULT_SIZE = 10000;
// 	public static final String PROPERTY_DEFAULT_LIMIT = "DefaultLimit";
//     public static final String SPARK_EXECUTOR_MEMORY = "spark.executor.memory";
//     public static final String SPARK_DRIVER_MEMORY = "spark.driver.memory";
//     public static final String  SPARK_TASK_CPUS = "spark.task.cpus";
//     public static final String  SPARK_DEFAULT_PARALELISM = "spark.default.parallelism";
//     public static final String  SPARK_CORES_MAX = "spark.cores.max";
//     public static final String  SPARK_DRIVER_RESULTSIZE = "spark.driver.maxResultSize";
// 
// 
// 
// 
// }


import java.util.HashMap;
import java.util.Map;
import com.stratio.connector.deep.configuration.DeepConnectorConstants;
import com.stratio.crossdata.common.connector.ConnectorClusterConfig;
import com.stratio.crossdata.common.data.ClusterName;
import com.stratio.crossdata.common.data.DataStoreName;
import com.stratio.deep.commons.extractor.utils.ExtractorConstants;
package com.stratio.connector.deep;



public class CassandraConnectionConfigurationBuilder {

    private static final String CASSANDRA_CELL_CLASS = "com.stratio.deep.cassandra.extractor.CassandraCellExtractor";

    public static final ClusterName CLUSTERNAME_CONSTANT = new ClusterName("cassandra");

    public static final String CQLPORT = "9042";

    public static final String RPCPORT = "9160";

    public static final String HOST = "10.200.0.58";

    /**
     * Create the configuration object to config the connector cluster information
     * 
     * @return Cluster configuration object
     */
// Path: src/main/java/com/stratio/connector/deep/configuration/DeepConnectorConstants.java
// public final class DeepConnectorConstants {
// 	private DeepConnectorConstants(){
// 
// 	}
// 
// 	public static final String HDFS = "hdfs";
// 	public static final String SPARK_MASTER = "spark.master";
// 	public static final String SPARK_HOME = "spark.home";
// 	public static final String SPARK_JARS = "spark.jars";
// 	public static final String CLUSTER_PREFIX_CONSTANT = "cluster";
// 	public static final String IMPL_CLASS_SUFIX_CONSTANT = ".implClass";
// 	public static final String EXTRACTOR_IMPL_CLASS = "extractorImplClass";
// 	public static final String DEEP_CONNECTOR_JOB_CONSTANT = "DeepConnectorJob";
// 
// 	public static final int DEFAULT_RESULT_SIZE = 10000;
// 	public static final String PROPERTY_DEFAULT_LIMIT = "DefaultLimit";
//     public static final String SPARK_EXECUTOR_MEMORY = "spark.executor.memory";
//     public static final String SPARK_DRIVER_MEMORY = "spark.driver.memory";
//     public static final String  SPARK_TASK_CPUS = "spark.task.cpus";
//     public static final String  SPARK_DEFAULT_PARALELISM = "spark.default.parallelism";
//     public static final String  SPARK_CORES_MAX = "spark.cores.max";
//     public static final String  SPARK_DRIVER_RESULTSIZE = "spark.driver.maxResultSize";
// 
// 
// 
// 
// }


// Path: src/test/java/com/stratio/connector/deep/CassandraConnectionConfigurationBuilder.java
import java.util.HashMap;
import java.util.Map;
import com.stratio.connector.deep.configuration.DeepConnectorConstants;
import com.stratio.crossdata.common.connector.ConnectorClusterConfig;
import com.stratio.crossdata.common.data.ClusterName;
import com.stratio.crossdata.common.data.DataStoreName;
import com.stratio.deep.commons.extractor.utils.ExtractorConstants;

package com.stratio.connector.deep;



public class CassandraConnectionConfigurationBuilder {

    private static final String CASSANDRA_CELL_CLASS = "com.stratio.deep.cassandra.extractor.CassandraCellExtractor";

    public static final ClusterName CLUSTERNAME_CONSTANT = new ClusterName("cassandra");

    public static final String CQLPORT = "9042";

    public static final String RPCPORT = "9160";

    public static final String HOST = "10.200.0.58";

    /**
     * Create the configuration object to config the connector cluster information
     * 
     * @return Cluster configuration object
     */
    public static ConnectorClusterConfig prepareConfiguration() {