BuildSchema.java

private void buildSchema()
{
    String dbTable = parametersAsJava.get(JdbcHiveOptions.dbTable);
    String hiveJdbcUrl = parametersAsJava.get(JdbcHiveOptions.hiveJdbcUrl);
    String hiveJdbcUser = parametersAsJava.get(JdbcHiveOptions.hiveJdbcUser);
    String hiveJdbcPassword = parametersAsJava.get(JdbcHiveOptions.hiveJdbcPassword);
    String hiveMetastoreUrl = parametersAsJava.get(JdbcHiveOptions.hiveMetastoreUrl);
    String hiveMetastoreUser = parametersAsJava.get(JdbcHiveOptions.hiveMetastoreUser);
    String hiveMetastorePassword = parametersAsJava.get(JdbcHiveOptions.hiveMetastorePassword);

    HiveMetaResolver hiveMetaResolver = new HiveMetaResolver(dbTable,
            hiveJdbcUrl,
            hiveJdbcUser,
            hiveJdbcPassword,
            hiveMetastoreUrl,
            hiveMetastoreUser,
            hiveMetastorePassword);

    this.schema = hiveMetaResolver.getSparkSchema();
}