@Override
    public void registerTable(EntityMetadata m, SparkClient sparkClient)
    {
        String conn = getConnectionString(m);

        Map<String, String> options = new HashMap<String, String>();
        options.put("url", conn);
        options.put("dbtable", m.getTableName());

        sparkClient.sqlContext.load("jdbc", options).registerTempTable(m.getTableName());
    }
@ Override public void registerTable ( EntityMetadata m , SparkClient sparkClient ) { String conn = getConnectionString ( m ) ; Map < String , String > options = new HashMap < String , String > ( ) ; options . put ( "url" , conn ) ; options . put ( "dbtable" , m . getTableName ( ) ) ; sparkClient . sqlContext . load ( "jdbc" , options ) . registerTempTable ( m . getTableName ( ) ) ; }
/*
(non-Javadoc)

@see
com.impetus.spark.client.SparkDataClient#registerTable(com.impetus.kundera
.metadata.model.EntityMetadata, com.impetus.spark.client.SparkClient)