// 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 HDFSConnectionConfigurationBuilder {

    private static final ClusterName CLUSTERNAME_CONSTANT = new ClusterName("hdfs");

    public static final String HOST = "10.200.0.60";

    public static final String PORT = "9000";

    private static final String HDFS = "hdfs";

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

        Map<String, String> options = new HashMap<>();
        options.put(ExtractorConstants.HOST, HOST);
        options.put(ExtractorConstants.HOSTS, HOST);
        options.put(ExtractorConstants.PORTS, PORT);
        options.put(ExtractorConstants.INNERCLASS, HDFS);

        options.put(ExtractorConstants.FS_FILE_SEPARATOR, ",");
        options.put(ExtractorConstants.FS_FILE_PATH, "/");

        // options.put(ExtractorConstants.FS_SCHEMA,"[id:java.lang.String,author:java.lang.String," +
        // "title:java.lang.String,year:java.lang.Integer,length:java.lang.Integer,single:java.lang.String]");
        options.put(ExtractorConstants.TYPE, ExtractorConstants.HDFS_TYPE);
        options.put(ExtractorConstants.TABLE, "songs");
        options.put(ExtractorConstants.CATALOG, "test");
        options.put(ExtractorConstants.HDFS_FILE_EXTENSION, ".csv");
        Map<String, String> connectorOptions = new HashMap<>();
        connectorOptions.put(DeepConnectorConstants.PROPERTY_DEFAULT_LIMIT,
// 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/HDFSConnectionConfigurationBuilder.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 HDFSConnectionConfigurationBuilder {

    private static final ClusterName CLUSTERNAME_CONSTANT = new ClusterName("hdfs");

    public static final String HOST = "10.200.0.60";

    public static final String PORT = "9000";

    private static final String HDFS = "hdfs";

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

        Map<String, String> options = new HashMap<>();
        options.put(ExtractorConstants.HOST, HOST);
        options.put(ExtractorConstants.HOSTS, HOST);
        options.put(ExtractorConstants.PORTS, PORT);
        options.put(ExtractorConstants.INNERCLASS, HDFS);

        options.put(ExtractorConstants.FS_FILE_SEPARATOR, ",");
        options.put(ExtractorConstants.FS_FILE_PATH, "/");

        // options.put(ExtractorConstants.FS_SCHEMA,"[id:java.lang.String,author:java.lang.String," +
        // "title:java.lang.String,year:java.lang.Integer,length:java.lang.Integer,single:java.lang.String]");
        options.put(ExtractorConstants.TYPE, ExtractorConstants.HDFS_TYPE);
        options.put(ExtractorConstants.TABLE, "songs");
        options.put(ExtractorConstants.CATALOG, "test");
        options.put(ExtractorConstants.HDFS_FILE_EXTENSION, ".csv");
        Map<String, String> connectorOptions = new HashMap<>();
        connectorOptions.put(DeepConnectorConstants.PROPERTY_DEFAULT_LIMIT,
                        String.valueOf(DeepConnectorConstants.DEFAULT_RESULT_SIZE));