JdbcHiveRelationProvider.class

JdbcHiveRelationProvider.class

package mykidong.datasources.jdbc.hive;

import org.apache.spark.sql.SQLContext;
import org.apache.spark.sql.sources.BaseRelation;
import org.apache.spark.sql.sources.DataSourceRegister;
import org.apache.spark.sql.sources.RelationProvider;
import scala.collection.immutable.Map;

public class JdbcHiveRelationProvider implements RelationProvider, DataSourceRegister {

    @Override
    public String shortName() {
        return "jdbc-hive";
    }

    @Override
    public BaseRelation createRelation(SQLContext sqlContext, Map<String, String> parameters) {

        JdbcHiveRelation jdbcHiveRelation = new JdbcHiveRelation(sqlContext, parameters);

        return jdbcHiveRelation;
    }
}